You are viewing a plain text version of this content. The canonical link for it is here.
- MetricRegistryTestUtils java class (flink-runtime/metrics) not found in source code version 1.14.3 - posted by Prasanna kumar <pr...@gmail.com> on 2022/02/01 06:28:48 UTC, 3 replies.
- Re: Flink 1.14 metrics : taskmanager host name missing - posted by Mayur Gubrele <ma...@gojek.com> on 2022/02/01 06:32:37 UTC, 1 replies.
- KafkaSource vs FlinkKafkaConsumer010 - posted by HG <ha...@gmail.com> on 2022/02/01 07:20:20 UTC, 4 replies.
- Re: Kafka Consumer Group Name not set if no checkpointing? - posted by Fabian Paul <fp...@apache.org> on 2022/02/01 08:38:18 UTC, 1 replies.
- Question about object reusing in Flink SQL - posted by LM Kang <mi...@126.com> on 2022/02/01 09:00:24 UTC, 0 replies.
- StateFun deployement options - posted by Christopher Gustafson <ch...@kth.se> on 2022/02/01 10:56:28 UTC, 2 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.2.0 released - posted by Till Rohrmann <tr...@apache.org> on 2022/02/01 11:23:17 UTC, 0 replies.
- regarding flink metrics - posted by Jessy Ping <te...@gmail.com> on 2022/02/01 12:26:08 UTC, 1 replies.
- Re: Show plan in UI not working. - posted by John Smith <ja...@gmail.com> on 2022/02/01 15:14:01 UTC, 0 replies.
- Queryable State Deprecation - posted by "Jatti, Karthik" <KJ...@ezesoft.com> on 2022/02/01 15:36:06 UTC, 5 replies.
- Memory issues with Rocksdb ColumnFamilyOptions - posted by Natalie Dunn <na...@ec.ai> on 2022/02/01 16:15:53 UTC, 1 replies.
- How to proper hashCode() for keys. - posted by John Smith <ja...@gmail.com> on 2022/02/01 19:38:22 UTC, 23 replies.
- GenericType problem in KeyedCoProcessFunction after disableGenericTypes() - posted by Deniz Koçak <le...@gmail.com> on 2022/02/01 20:01:22 UTC, 3 replies.
- Future support for custom FileEnumerator in FileSource? - posted by Kevin Lam <ke...@shopify.com> on 2022/02/01 21:10:15 UTC, 2 replies.
- How to test stateful streaming pipeline? - posted by Marcin Kuthan <ma...@gmail.com> on 2022/02/02 07:18:13 UTC, 0 replies.
- Read Avro type records from kafka using Python - Datastream API - posted by Hussein El Ghoul <hu...@quiqup.com> on 2022/02/02 08:42:38 UTC, 1 replies.
- Re: ParquetColumnarRowInputFormat - parameter description - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2022/02/02 10:34:40 UTC, 0 replies.
- RE: Determinism of interval joins - posted by Alexis Sarda-Espinosa <al...@microfocus.com> on 2022/02/02 11:32:22 UTC, 0 replies.
- Re: BroadCast State not loaded back into the job once its restarted due to a JM failure - posted by Prasanna kumar <pr...@gmail.com> on 2022/02/02 12:52:22 UTC, 4 replies.
- Pojo State Migration - NPE with field deletion - posted by bastien dine <ba...@gmail.com> on 2022/02/02 15:00:51 UTC, 2 replies.
- AbstractMethodError when running StateFun job as jar - posted by Christopher Gustafson <ch...@kth.se> on 2022/02/02 15:49:56 UTC, 1 replies.
- Creating Flink SQL Row with named fields - posted by Vladislav Keda <vl...@glowbyteconsulting.com> on 2022/02/02 16:16:28 UTC, 2 replies.
- Re: IllegalArgumentException: URI is not hierarchical error when initializating jobmanager in cluster - posted by Javier Vegas <jv...@strava.com> on 2022/02/02 22:15:37 UTC, 0 replies.
- Flink 1.12.1 and KafkaSource - posted by Marco Villalobos <mv...@kineteque.com> on 2022/02/03 02:40:00 UTC, 1 replies.
- How to prevent check pointing of timers ? - posted by Alex Drobinsky <al...@gmail.com> on 2022/02/03 12:41:22 UTC, 6 replies.
- flink savepoints not (completely) relocatable ? - posted by Frank Dekervel <fr...@kapernikov.com> on 2022/02/03 13:44:21 UTC, 4 replies.
- Flink High-Availability and Job-Manager recovery - posted by "Koffman, Noa (Nokia - IL/Kfar Sava)" <no...@nokia.com> on 2022/02/03 14:11:44 UTC, 2 replies.
- Json deserialisation with .jsonValue vs format=json in Table API - posted by Илья Соин <il...@gmail.com> on 2022/02/03 14:55:53 UTC, 2 replies.
- Reading from Kafka kafkarecorddeserializationschema - posted by HG <ha...@gmail.com> on 2022/02/03 15:56:55 UTC, 3 replies.
- Question around creating partitioned tables when running Flink from Ververica - posted by Natu Lauchande <nl...@gmail.com> on 2022/02/04 06:25:23 UTC, 3 replies.
- Re: CVE-2021-44228 - Log4j2 vulnerability - posted by Surendra Lalwani <su...@swiggy.in> on 2022/02/04 07:49:04 UTC, 3 replies.
- CDC using Query - posted by mohan radhakrishnan <ra...@gmail.com> on 2022/02/04 12:55:36 UTC, 8 replies.
- java.lang.NoClassDefFoundError: org/apache/kafka/common/network/Selector$CloseMode - posted by HG <ha...@gmail.com> on 2022/02/04 14:29:49 UTC, 4 replies.
- Questions about Kryo setRegistrationRequired(false) - posted by Shane Bishop <sh...@outlook.com> on 2022/02/04 19:12:06 UTC, 3 replies.
- Loading a Hive lookup table data into TM memory takes so long. - posted by Jason Yi <93...@gmail.com> on 2022/02/05 00:00:15 UTC, 3 replies.
- Job requiring a lot of memory despite using rocksdb state backend - posted by Salva Alcántara <sa...@gmail.com> on 2022/02/05 06:12:53 UTC, 2 replies.
- Re: Questions about checkpoint retention - posted by "ChangZhuo Chen (陳昌倬)" <cz...@czchen.org> on 2022/02/05 13:25:40 UTC, 0 replies.
- pyflink datastream job - posted by nagi data monkey <na...@gmail.com> on 2022/02/06 16:08:39 UTC, 2 replies.
- Logging for both JM and TM in the web UI - posted by Nikola Hrusov <n....@gmail.com> on 2022/02/06 17:56:37 UTC, 1 replies.
- Re: Example with JSONKeyValueDeserializationSchema? - posted by HG <ha...@gmail.com> on 2022/02/07 14:15:21 UTC, 0 replies.
- [RESULT] [VOTE] Deprecate Per-Job Mode - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/08 08:23:28 UTC, 0 replies.
- StateFun NoSuchMethodError when deploying to existing Cluster - posted by Christopher Gustafson <ch...@kth.se> on 2022/02/08 13:05:38 UTC, 0 replies.
- Re: Avro BulkFormat for the new FileSource API? - posted by Kevin Lam <ke...@shopify.com> on 2022/02/08 15:11:01 UTC, 1 replies.
- JSONKeyValueDeserializationSchema cannot be converted to ObjectNode> - posted by HG <ha...@gmail.com> on 2022/02/08 16:42:52 UTC, 5 replies.
- Re: Issue with Flink UI for Flink 1.14.0 - posted by Sweta Kalakuntla <sk...@bandwidth.com> on 2022/02/08 18:31:09 UTC, 2 replies.
- Flink Table API and Rules - posted by Shahdat Hossain <sh...@gmail.com> on 2022/02/08 19:25:46 UTC, 1 replies.
- Temporal join unexpected behavior - posted by Ahmad Ebrahimi <ea...@gmail.com> on 2022/02/08 19:33:00 UTC, 1 replies.
- Flink JDBC connector behavior - posted by Qihua Yang <ya...@gmail.com> on 2022/02/08 21:08:48 UTC, 1 replies.
- Using Universal Kafka Connector with Kafka Log Message Version 0.10.2.0 - posted by Mohammad Haseeb <mh...@gmail.com> on 2022/02/08 23:35:02 UTC, 0 replies.
- Re: Inaccurate checkpoint trigger time - posted by Paul Lam <pa...@gmail.com> on 2022/02/09 04:49:25 UTC, 0 replies.
- How to access Task.isBackPressured() from a SourceFunction? - posted by Darren Whobrey <da...@oracle.com> on 2022/02/09 06:01:01 UTC, 1 replies.
- Flink's Data sources - posted by mohan radhakrishnan <ra...@gmail.com> on 2022/02/09 06:43:50 UTC, 1 replies.
- Regarding delayed reading at source with larger checkpoint timeouts - posted by Johny Rufus John <jo...@gmail.com> on 2022/02/09 11:07:44 UTC, 0 replies.
- Changing StateBackend for Statefun Harness E2E tests - posted by Christopher Gustafson <ch...@kth.se> on 2022/02/09 12:34:05 UTC, 2 replies.
- RichAsyncFunction + Cache or Map State? - posted by Clayton Wohl <cl...@gmail.com> on 2022/02/09 15:14:16 UTC, 0 replies.
- huge number of duplicate numbers after experiencing a crash loop in deserializer - posted by Frank Dekervel <fr...@kapernikov.com> on 2022/02/09 16:03:26 UTC, 1 replies.
- Question about both using managed memory with RocksDB and tuning other options - posted by LM Kang <mi...@126.com> on 2022/02/09 16:11:57 UTC, 0 replies.
- Flink 1.12.x DataSet --> Flink 1.14.x DataStream - posted by "Saravanan77@gmail.com" <sa...@gmail.com> on 2022/02/09 16:56:33 UTC, 5 replies.
- unpredictable behaviour on KafkaSource deserialisation error - posted by Frank Dekervel <fr...@kapernikov.com> on 2022/02/09 22:11:15 UTC, 1 replies.
- Use TwoPhaseCommitSinkFunction or StatefulSink+TwoPhaseCommittingSink to achieve EXACTLY_ONCE sink? - posted by Fuyao Li <fu...@oracle.com> on 2022/02/09 23:00:49 UTC, 1 replies.
- Flink SQL kafka debezium CDC and postgreSQL - posted by Francis Conroy <fr...@switchdin.com> on 2022/02/10 03:51:53 UTC, 0 replies.
- Problem with kafka with key=None using pyhton-kafka module - posted by mrAlexTFB <mr...@gmail.com> on 2022/02/10 14:07:20 UTC, 1 replies.
- question on dataSource.collect() on reading states from a savepoint file - posted by Antonio Si <an...@gmail.com> on 2022/02/10 19:31:46 UTC, 4 replies.
- Re: [External] : Re: Use TwoPhaseCommitSinkFunction or StatefulSink+TwoPhaseCommittingSink to achieve EXACTLY_ONCE sink? - posted by Fuyao Li <fu...@oracle.com> on 2022/02/10 23:48:04 UTC, 3 replies.
- There Is a Delay While Over Aggregation Sending Results - posted by wang guanglei <gl...@outlook.com> on 2022/02/11 06:05:20 UTC, 1 replies.
- Illegal reflective access by org.apache.flink.api.java.ClosureCleaner - posted by Антон <an...@yandex.ru> on 2022/02/11 06:44:46 UTC, 1 replies.
- Run same job twice with different parameters - posted by Anton <an...@yandex.ru> on 2022/02/11 07:15:33 UTC, 5 replies.
- Removing unused flink-avro causes savepoint to fail loading - posted by David Causse <dc...@wikimedia.org> on 2022/02/11 09:01:48 UTC, 1 replies.
- table api watermarks, timestamps, outoforderness and head aches - posted by HG <ha...@gmail.com> on 2022/02/11 13:53:02 UTC, 3 replies.
- Apache Flink - Will later events from a table with watermark be propagated and when can CURRENT_WATERMARK be null in that situation - posted by M Singh <ma...@yahoo.com> on 2022/02/11 15:45:18 UTC, 5 replies.
- Need help on implementing custom`snapshotState` in KafkaSource & KafkaSourceReader - posted by santosh joshi <sa...@gmail.com> on 2022/02/12 15:39:15 UTC, 1 replies.
- [statefun] Add new state failure in Greetings example - posted by "casel.chen" <ca...@126.com> on 2022/02/13 03:02:26 UTC, 2 replies.
- [statefun] Does statefun supports query state by http endpoint? - posted by "casel.chen" <ca...@126.com> on 2022/02/13 03:18:04 UTC, 0 replies.
- Synchronization across tasks using checkpoint barriers - posted by Gopi Krishna M <go...@gmail.com> on 2022/02/14 04:27:06 UTC, 6 replies.
- Joining Flink tables with different watermark delay - posted by Meghajit Mazumdar <me...@gojek.com> on 2022/02/14 07:32:10 UTC, 3 replies.
- select($("transactionId)) : cannot find symbol symbol: method $(java.lang.String) - posted by HG <ha...@gmail.com> on 2022/02/14 14:17:07 UTC, 4 replies.
- How to cogroup multiple streams? - posted by Will Lauer <wl...@yahooinc.com> on 2022/02/14 15:08:40 UTC, 1 replies.
- Save app-global cache used by RichAsyncFunction to Flink State? - posted by Clayton Wohl <cl...@gmail.com> on 2022/02/14 15:25:37 UTC, 1 replies.
- Statefun with no Protobuf ingress and egress - posted by mrAlexTFB <mr...@gmail.com> on 2022/02/14 16:05:42 UTC, 1 replies.
- "No operators defined in streaming topology" error when Flink app still starts successfully - posted by Shane Bishop <sh...@outlook.com> on 2022/02/14 16:40:10 UTC, 1 replies.
- Unit test harness for Sources - posted by James Sandys-Lumsdaine <ja...@hotmail.com> on 2022/02/14 17:06:26 UTC, 2 replies.
- TM OOMKilled - posted by Alexey Trenikhun <ye...@msn.com> on 2022/02/14 21:16:50 UTC, 6 replies.
- [statefun] Looking for a polyglot example - posted by "casel.chen" <ca...@126.com> on 2022/02/15 02:25:33 UTC, 2 replies.
- Fraud detection demo with Flink 1.14 - posted by Pramit Vamsi <pr...@gmail.com> on 2022/02/15 06:22:05 UTC, 0 replies.
- Performance Issues in Source Operator while migrating to Flink-1.14 from 1.9 - posted by Arujit Pradhan <ar...@gojek.com> on 2022/02/15 12:06:30 UTC, 3 replies.
- method select(org.apache.flink.table.api.ApiExpression cannot find symbol .select($("handlingTime"), - posted by HG <ha...@gmail.com> on 2022/02/15 14:45:42 UTC, 3 replies.
- Log4j2 configuration - posted by jonas eyob <jo...@gmail.com> on 2022/02/15 15:41:48 UTC, 4 replies.
- Re: Flink 1.14.2/3 - KafkaSink vs deprecated FlinkKafkaProducer - posted by Fabian Paul <fp...@apache.org> on 2022/02/15 15:49:36 UTC, 0 replies.
- Exception Help - posted by Jonathan Weaver <my...@gmail.com> on 2022/02/15 18:02:59 UTC, 5 replies.
- How to get memory specific metrics for tasknodes - posted by Diwakar Jha <di...@gmail.com> on 2022/02/15 21:31:24 UTC, 5 replies.
- Change column names Pyflink Table/Datastream API - posted by Francis Conroy <fr...@switchdin.com> on 2022/02/16 00:07:17 UTC, 2 replies.
- Failed to serialize the result for RPC call : requestMultipleJobDetails after Upgrading to Flink 1.14.3 - posted by Chirag Dewan <ch...@yahoo.in> on 2022/02/16 04:48:47 UTC, 3 replies.
- Job manager slots are in bad state. - posted by Josson Paul <jo...@gmail.com> on 2022/02/16 07:15:08 UTC, 1 replies.
- Flink 1.12.8 release - posted by Joey L <jo...@gmail.com> on 2022/02/16 07:54:02 UTC, 2 replies.
- Python Function for Datastream Transformation in Flink Java Job - posted by Jesry Pandawa <je...@gmail.com> on 2022/02/16 08:45:43 UTC, 1 replies.
- getting "original" ingestion timestamp after using a TimestampAssigner - posted by Frank Dekervel <fr...@kapernikov.com> on 2022/02/16 08:46:11 UTC, 1 replies.
- AWS Kinesis Flink vs K8s - posted by Puneet Duggal <pu...@gmail.com> on 2022/02/16 10:25:41 UTC, 2 replies.
- Implement watermark buffering with Process Function - posted by Ruibin Xing <xi...@gmail.com> on 2022/02/16 11:04:07 UTC, 2 replies.
- SQL / Table Api lag() over partition by ... and windowing - posted by HG <ha...@gmail.com> on 2022/02/16 13:34:59 UTC, 4 replies.
- Basic questions about resuming stateful Flink jobs - posted by James Sandys-Lumsdaine <ja...@hotmail.com> on 2022/02/16 15:43:44 UTC, 5 replies.
- Task manager errors with Flink ZooKeeper High Availability - posted by "Koffman, Noa (Nokia - IL/Kfar Sava)" <no...@nokia.com> on 2022/02/16 21:00:24 UTC, 6 replies.
- Apache Flink - User Defined Functions - Exception when passing all arguments - posted by M Singh <ma...@yahoo.com> on 2022/02/17 00:34:10 UTC, 2 replies.
- Flink 1.15 deduplication view and lookup join - posted by Francis Conroy <fr...@switchdin.com> on 2022/02/17 03:25:53 UTC, 2 replies.
- Pyflink with pulsar - posted by Ananth Gundabattula <ag...@darwinium.com> on 2022/02/17 08:56:32 UTC, 3 replies.
- java.io.IOException: Failed to deserialize consumer record due to/ How to serialize table output for KafkaSink - posted by HG <ha...@gmail.com> on 2022/02/17 14:05:50 UTC, 2 replies.
- Apache Flink - Continuously monitoring directory using filesystem connector - 1.14.3 - posted by M Singh <ma...@yahoo.com> on 2022/02/18 00:28:37 UTC, 2 replies.
- Flink Overwrite parameters in ExecutorUtils - posted by Zou Dan <zo...@163.com> on 2022/02/18 13:01:30 UTC, 2 replies.
- [ANNOUNCE] Apache Flink 1.13.6 released - posted by Konstantin Knauf <kn...@apache.org> on 2022/02/18 13:32:03 UTC, 0 replies.
- RMQSource non-parallel, seems inconsistent with documentation - posted by Daniel Hristov <dh...@dragos.com> on 2022/02/18 22:09:35 UTC, 1 replies.
- No effect from --allowNonRestoredState or "execution.savepoint.ignore-unclaimed-state" in K8S application mode - posted by Andrey Bulgakov <ma...@andreiko.ru> on 2022/02/18 22:14:22 UTC, 5 replies.
- DataStream API: Parquet File Format with Scala Case Classes - posted by Ryan van Huuksloot <ry...@shopify.com> on 2022/02/18 22:20:34 UTC, 3 replies.
- Option Types not recognized in Table API - posted by Praneeth Ramesh <sr...@gmail.com> on 2022/02/19 04:51:37 UTC, 0 replies.
- How to flatten ARRAY in Table API - posted by Matthias Broecheler <ma...@dataeng.ai> on 2022/02/20 01:25:14 UTC, 2 replies.
- Job Manager High Availability using Kubernetes HA Services is not working with custom S3 encrypted client - posted by Almog Rozencwajg <Al...@niceactimize.com> on 2022/02/20 11:03:37 UTC, 0 replies.
- Flink Statefun and Feature computation - posted by Federico D'Ambrosio <fe...@gmail.com> on 2022/02/20 12:54:16 UTC, 1 replies.
- Apache Flink - Continuously streaming data using jdbc connector - posted by M Singh <ma...@yahoo.com> on 2022/02/20 22:23:22 UTC, 2 replies.
- Pulsar connector 2.9.1 failing job submission in standalone. - posted by Ananth Gundabattula <ag...@darwinium.com> on 2022/02/21 01:48:11 UTC, 7 replies.
- CSV join in batch mode - posted by Killian GUIHEUX <ki...@thalesdigital.io> on 2022/02/21 10:33:25 UTC, 1 replies.
- [Table API] [JDBC CDC] Caching Configuration from MySql instance needed in multiple Flink Jobs - posted by Dan Serb <da...@boatyardx.com> on 2022/02/21 13:11:43 UTC, 1 replies.
- watermark/timestamp between kafka datastream - table - datastream - posted by HG <ha...@gmail.com> on 2022/02/21 15:06:14 UTC, 0 replies.
- Cannot upgrade helm chart - posted by marco andreas <ma...@gmail.com> on 2022/02/21 19:39:45 UTC, 2 replies.
- Apache Flink - Exception on left outer join with 'kafka' connector - posted by M Singh <ma...@yahoo.com> on 2022/02/22 09:20:30 UTC, 0 replies.
- java.lang.Exception: Job leader for job id 0efd8681eda64b072b72baef58722bc0 lost leadership. - posted by Jai Patel <ja...@cloudkitchens.com> on 2022/02/22 20:19:19 UTC, 3 replies.
- Avro Flink Row Conversion - posted by Haizhou Zhao <zh...@gmail.com> on 2022/02/22 22:54:38 UTC, 0 replies.
- Trouble sinking to Kafka - posted by Marco Villalobos <mv...@kineteque.com> on 2022/02/22 23:02:40 UTC, 4 replies.
- Joining a flink materialised view table with a streaming table - posted by Francis Conroy <fr...@switchdin.com> on 2022/02/23 03:12:22 UTC, 0 replies.
- Flink metrics via permethous or opentelemerty - posted by Sigalit Eliazov <e....@gmail.com> on 2022/02/23 07:42:13 UTC, 1 replies.
- Restart from checkpoint - kinesis consumer - posted by Vijayendra Yadav <co...@gmail.com> on 2022/02/23 11:24:52 UTC, 2 replies.
- Flink SQL: HOW to define `ANY` subtype in constructured Constructured Data Types(MAP, ARRAY...) - posted by zhouhaifengmath <zh...@gmail.com> on 2022/02/23 14:29:24 UTC, 1 replies.
- Flink job recovery after task manager failure - posted by "Afek, Ifat (Nokia - IL/Kfar Sava)" <if...@nokia.com> on 2022/02/23 16:24:47 UTC, 4 replies.
- [Flink-1.14.3] Restart of pod due to duplicatejob submission - posted by Parag Somani <so...@gmail.com> on 2022/02/24 05:41:43 UTC, 2 replies.
- Possible BUG in 1.15 SQL JSON_OBJECT() - posted by Jonathan Weaver <my...@gmail.com> on 2022/02/24 22:17:43 UTC, 1 replies.
- pyflink object to java object - posted by Francis Conroy <fr...@switchdin.com> on 2022/02/25 06:35:29 UTC, 0 replies.
- streaming mode with both finite and infinite input sources - posted by Jin Yi <ji...@promoted.ai> on 2022/02/25 07:18:40 UTC, 2 replies.
- source code build failure - posted by Edwin <xu...@163.com> on 2022/02/25 08:49:49 UTC, 0 replies.
- Pods are OOMKilled with RocksDB backend after a few checkpoints - posted by Alexandre Montecucco <al...@grabtaxi.com> on 2022/02/25 12:14:36 UTC, 0 replies.
- Low Watermark - posted by Isidoros Ioannou <ak...@gmail.com> on 2022/02/25 13:09:39 UTC, 1 replies.
- Issue upgrading to Flink v1.14.3; non-restored state - posted by Dan Hill <qu...@gmail.com> on 2022/02/26 19:01:18 UTC, 2 replies.
- Pyflink with FlinkTypeInfo failing for Byte Array Deserializations - posted by Ananth Gundabattula <ag...@darwinium.com> on 2022/02/26 19:49:36 UTC, 0 replies.
- Kafka order info to MySQL discard middle status and guarantee final correctness - posted by Lei Wang <le...@gmail.com> on 2022/02/28 02:16:01 UTC, 1 replies.
- processwindowfunction output Iterator - posted by HG <ha...@gmail.com> on 2022/02/28 15:25:08 UTC, 0 replies.