You are viewing a plain text version of this content. The canonical link for it is here.
- Discussion: Condition field in the CR status - posted by Lajith Koova <la...@gmail.com> on 2024/05/01 07:05:32 UTC, 6 replies.
- Re: [DISCUSS] FLIP-443: Interruptible watermark processing - posted by Yanfei Lei <fr...@gmail.com> on 2024/05/01 08:34:42 UTC, 12 replies.
- FW: RE: [DISCUSS] FLIP-XXX Apicurio-avro format - posted by David Radley <da...@uk.ibm.com> on 2024/05/01 13:47:05 UTC, 11 replies.
- [jira] [Created] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/05/01 15:01:00 UTC, 0 replies.
- [DISCUSS] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction - posted by Martijn Visser <ma...@apache.org> on 2024/05/01 15:30:24 UTC, 19 replies.
- [jira] [Created] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/02 06:36:00 UTC, 0 replies.
- Re: [Discuss] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding - posted by Muhammet Orazov <mo...@morazow.com.INVALID> on 2024/05/02 07:45:16 UTC, 3 replies.
- Re: [DISCUSS] FLIP-444: Native file copy support - posted by Muhammet Orazov <mo...@morazow.com.INVALID> on 2024/05/02 08:38:58 UTC, 13 replies.
- [jira] [Created] (FLINK-35282) Support for Apache Beam > 2.49 - posted by "APA (Jira)" <ji...@apache.org> on 2024/05/02 09:29:00 UTC, 0 replies.
- [VOTE] FLIP-454: New Apicurio Avro format - posted by David Radley <da...@uk.ibm.com> on 2024/05/02 09:41:09 UTC, 8 replies.
- [jira] [Created] (FLINK-35283) Add support unique Kafka producer client ids - posted by "Francis (Jira)" <ji...@apache.org> on 2024/05/02 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35284) Streaming File Sink end-to-end test times out - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/02 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor - posted by "Trystan (Jira)" <ji...@apache.org> on 2024/05/02 16:51:00 UTC, 0 replies.
- Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1 - posted by Muhammet Orazov <mo...@morazow.com.INVALID> on 2024/05/02 20:52:05 UTC, 6 replies.
- [jira] [Created] (FLINK-35286) Cannot discover Hive connector outside Hive catalog - posted by "Ryan Goldenberg (Jira)" <ji...@apache.org> on 2024/05/02 23:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8 - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/05/03 07:35:00 UTC, 0 replies.
- Re: [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc - posted by João Boto <es...@apache.org> on 2024/05/03 12:25:31 UTC, 7 replies.
- Re: Question around Flink's AdaptiveBatchScheduler - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/05/04 02:09:37 UTC, 2 replies.
- [jira] [Created] (FLINK-35288) Flink Restart Strategy does not work as documented - posted by "Keshav Kansal (Jira)" <ji...@apache.org> on 2024/05/04 04:47:00 UTC, 0 replies.
- Re: Re: Iceberg table maintenance - posted by Péter Váry <pe...@gmail.com> on 2024/05/04 05:15:10 UTC, 0 replies.
- [jira] [Created] (FLINK-35289) Incorrect timestamp of stream elements collected from onTimer in batch mode - posted by "Kanthi Vaidya (Jira)" <ji...@apache.org> on 2024/05/04 12:14:00 UTC, 0 replies.
- Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/04 20:14:19 UTC, 0 replies.
- Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/04 20:14:28 UTC, 0 replies.
- Re: [Vote] FLIP-438: Amazon SQS Sink Connector - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/04 20:33:41 UTC, 3 replies.
- Re: [DISCUSS] FLIP-451: Refactor Async sink API - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/04 20:41:54 UTC, 12 replies.
- Re: [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table - posted by Ron Liu <ro...@gmail.com> on 2024/05/05 05:08:48 UTC, 5 replies.
- [jira] [Created] (FLINK-35290) Wrong Instant type conversion TableAPI to Datastream in thread mode - posted by "Wouter Zorgdrager (Jira)" <ji...@apache.org> on 2024/05/05 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2024/05/05 16:43:00 UTC, 0 replies.
- Re: Flink stateful functions and Agentic Architecture - posted by Yunfeng Zhou <fl...@gmail.com> on 2024/05/06 01:03:43 UTC, 0 replies.
- [RESULT][VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource - posted by Xia Sun <xi...@gmail.com> on 2024/05/06 02:09:08 UTC, 0 replies.
- Re: [DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0 - posted by Yuxin Tan <ta...@gmail.com> on 2024/05/06 02:47:07 UTC, 11 replies.
- [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 - posted by yue ma <ma...@gmail.com> on 2024/05/06 02:53:56 UTC, 18 replies.
- [jira] [Created] (FLINK-35292) Set dummy savepoint path during last-state upgrade - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/05/06 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/05/06 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/06 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35295) Improve jdbc connection pool initialization failure message - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/06 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35296) Flink mysql-cdc connector stops reading data - posted by "Gang Yang (Jira)" <ji...@apache.org> on 2024/05/06 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35297) Add validation for option connect.timeout - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/06 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35298) Improve metric reporter logic - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/06 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/05/06 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/07 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35301) Fix deadlock when loading driver classes - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/07 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2024/05/07 02:37:00 UTC, 0 replies.
- [DISCUSSION] FLIP-456: CompiledPlan support for Batch Execution Mode - posted by Alexey Leonov-Vendrovskiy <ve...@gmail.com> on 2024/05/07 06:38:55 UTC, 5 replies.
- [jira] [Created] (FLINK-35303) Support logical deletion of datax - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/07 08:41:00 UTC, 0 replies.
- Issue in PrefetchCount - posted by ajay pandey <aj...@gmail.com> on 2024/05/07 08:55:04 UTC, 1 replies.
- [SUMMARY] Flink 1.20 Release Sync 05/07/2024 - posted by Rui Fan <19...@gmail.com> on 2024/05/07 09:07:03 UTC, 0 replies.
- [jira] [Created] (FLINK-35304) Mongo ITCase fails due to duplicate records after resuming - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/07 09:17:00 UTC, 0 replies.
- [RabbitMQ Connector]: missing support for per consumer QoS (needed for quorum queues) - posted by charlie vuillemez <cv...@yahoo.fr.INVALID> on 2024/05/07 16:02:51 UTC, 0 replies.
- Alignment with FlinkSQL Standards | Feedback requested - posted by Kanchi Masalia <km...@pinterest.com.INVALID> on 2024/05/07 21:15:41 UTC, 2 replies.
- [VOTE] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2024/05/08 00:01:14 UTC, 4 replies.
- [jira] [Created] (FLINK-35305) FLIP-438: Amazon SQS Sink Connector - posted by "Priya Dhingra (Jira)" <ji...@apache.org> on 2024/05/08 00:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35306) Flink cannot compile with jdk17 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/05/08 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35307) Add Compile CI check on jdk17 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/08 04:29:00 UTC, 0 replies.
- [DISCUSS] Flink CDC 3.2 Release Planning - posted by Qingsheng Ren <re...@apache.org> on 2024/05/08 06:21:43 UTC, 15 replies.
- [jira] [Created] (FLINK-35308) StarRocks sink maps TINYINT type to BOOLEAN incorrectly - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/08 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35309) Enable Notice file ci check and fix Notice - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/05/08 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35310) Replace RBAC verb wildcards with actual verbs - posted by "Tim (Jira)" <ji...@apache.org> on 2024/05/08 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35311) FLIP-454: New Apicurio Avro format - posted by "david radley (Jira)" <ji...@apache.org> on 2024/05/08 14:47:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-454: New Apicurio Avro format - posted by David Radley <da...@uk.ibm.com> on 2024/05/08 15:05:23 UTC, 3 replies.
- FLINK-33759 - posted by Frank Yin <uk...@gmail.com> on 2024/05/08 19:02:19 UTC, 0 replies.
- Best Practices? Fault Isolation for Processing Large Number of Same-Shaped Input Kafka Topics in a Big Flink Job - posted by Kevin Lam <ke...@shopify.com.INVALID> on 2024/05/08 19:52:38 UTC, 1 replies.
- flink-connector-kafka weekly CI job failing - posted by Robert Young <ro...@gmail.com> on 2024/05/08 22:34:05 UTC, 3 replies.
- [jira] [Created] (FLINK-35312) Insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_ - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/09 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35313) Add upsert changelog mode to avoid UPDATE_BEFORE records push down - posted by "JJJJude (Jira)" <ji...@apache.org> on 2024/05/09 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35314) Add Flink CDC pipeline transform user document - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/05/09 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/05/09 03:54:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 - posted by yue ma <ma...@gmail.com> on 2024/05/09 04:56:57 UTC, 0 replies.
- [VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table - posted by Ron Liu <ro...@gmail.com> on 2024/05/09 05:52:57 UTC, 9 replies.
- [jira] [Created] (FLINK-35316) Add CDC e2e test case for on Flink 1.19 - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/09 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35317) Flink CDC CLI Supports submitting multiple YAML job at once - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/09 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35318) incorrect timezone handling for TIMESTAMP_WITH_LOCAL_TIME_ZONE type during predicate pushdown - posted by "linshangquan (Jira)" <ji...@apache.org> on 2024/05/09 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35319) Specific Operator getting stuck in Initialization for a long time - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2024/05/09 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35320) RabbitMQ Source fails to consume from quorum queues when prefetch Count is set - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/09 11:10:00 UTC, 0 replies.
- Request for access - posted by Vikas Garg <vg...@opentext.com.INVALID> on 2024/05/09 11:21:23 UTC, 0 replies.
- [VOTE] FLIP-449: Reorganization of flink-connector-jdbc - posted by Joao Boto <bo...@boto.pro> on 2024/05/09 12:01:04 UTC, 8 replies.
- [jira] [Created] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation - posted by "Lennon Yu (Jira)" <ji...@apache.org> on 2024/05/09 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35322) PubSub Connector Weekly build fails - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/09 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/05/10 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35324) Avro format can not perform projection pushdown for specific fields - posted by "SuDewei (Jira)" <ji...@apache.org> on 2024/05/10 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35325) Paimon connector miss the position of AddColumnEvent - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/05/10 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35326) Implement lineage interface for hive connector - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/05/10 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35327) SQL Explain show push down condition - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/10 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions - posted by "Wenbing Shen (Jira)" <ji...@apache.org> on 2024/05/10 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35329) Support modify table/column comments - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/10 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35330) Support for Vertica Connector - posted by "Vikas Garg (Jira)" <ji...@apache.org> on 2024/05/10 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35331) Download links for binary releases are displayed as source releases on website - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2024/05/10 08:09:00 UTC, 0 replies.
- [DISCUSSION] HybridSource multiway tree feature - posted by Or Keren <or...@gmail.com> on 2024/05/10 08:37:50 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.1.0, release candidate #2 - posted by Qingsheng Ren <re...@apache.org> on 2024/05/10 09:59:46 UTC, 3 replies.
- [VOTE] Apache Flink CDC Release 3.1.0, release candidate #3 - posted by Qingsheng Ren <re...@apache.org> on 2024/05/11 02:09:44 UTC, 7 replies.
- Re: [DISCUSS][QUESTION] Drop jdk 8 support for Flink connector Opensearch - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/05/12 12:41:41 UTC, 0 replies.
- Re: [DISCUSS] Connector releases for Flink 1.19 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/05/12 12:47:59 UTC, 6 replies.
- [jira] [Created] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2024/05/13 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/05/13 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API - posted by "Simon Lee (Jira)" <ji...@apache.org> on 2024/05/13 09:16:00 UTC, 0 replies.
- [VOTE] FLIP-451: Introduce timeout configuration to AsyncSink - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/13 09:50:43 UTC, 12 replies.
- Access to Wiki for raising a Flip request - posted by Vikas Garg <vg...@opentext.com.INVALID> on 2024/05/13 09:58:41 UTC, 1 replies.
- [jira] [Created] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/13 10:19:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Improve JDBC connector extensibility for Table API - posted by lo...@ververica.com.INVALID on 2024/05/13 10:20:59 UTC, 6 replies.
- [jira] [Created] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2024/05/13 10:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-35337) Keep up with the latest version of tikv client - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/05/13 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35338) Enable FS Plugins as non-root - posted by "Rasmus Thygesen (Jira)" <ji...@apache.org> on 2024/05/13 11:26:00 UTC, 0 replies.
- Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism - posted by Keith Lee <le...@gmail.com> on 2024/05/13 12:49:50 UTC, 1 replies.
- [jira] [Created] (FLINK-35339) Compilation timeout while building flink-dist - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/13 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35340) Flink Kubernetes Operator CRDs not applying correctly - posted by "Neil Prasad (Jira)" <ji...@apache.org> on 2024/05/13 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35341) Retraction stop working with Clock dependent function in Filter - posted by "Lim Qing Wei (Jira)" <ji...@apache.org> on 2024/05/13 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/13 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35343) NullPointerException in SourceReaderBase - posted by "zyh (Jira)" <ji...@apache.org> on 2024/05/14 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/14 03:45:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table - posted by Ron Liu <ro...@gmail.com> on 2024/05/14 04:16:05 UTC, 0 replies.
- [jira] [Created] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/05/14 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/05/14 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/05/14 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35348) Implement materialized table refresh rest api - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/05/14 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/14 06:12:00 UTC, 0 replies.
- [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction - posted by Martijn Visser <ma...@apache.org> on 2024/05/14 06:43:49 UTC, 14 replies.
- [jira] [Created] (FLINK-35350) Add documentation for Kudu - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/05/14 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35351) Restore from unaligned checkpoint with custom partitioner fails. - posted by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2024/05/14 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35352) Add -sae submit task to run for a period of time and automatically cancel - posted by "谷金城 (Jira)" <ji...@apache.org> on 2024/05/14 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35353) Translate "Profiler" page into Chinese - posted by "Juan Zifeng (Jira)" <ji...@apache.org> on 2024/05/14 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35354) [discuss] Support host mapping in Flink tikv cdc - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/05/14 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35355) Async aggregating state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/14 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35356) Async reducing state - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/14 13:14:00 UTC, 0 replies.
- Community over Code EU 2024: The countdown has started! - posted by Ryan Skraba <rs...@apache.org> on 2024/05/14 14:57:19 UTC, 0 replies.
- [jira] [Created] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document - posted by "Yang Zhou (Jira)" <ji...@apache.org> on 2024/05/15 05:38:00 UTC, 0 replies.
- Proposal to Add a JDBC Sink Plugin to Flink-CDC-Pipeline - posted by Jerry <ki...@gmail.com> on 2024/05/15 06:59:30 UTC, 0 replies.
- [DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline - posted by Jerry <ki...@gmail.com> on 2024/05/15 07:06:33 UTC, 2 replies.
- Re: [DISCUSS] FLIP suggestion: Flink SQL Scalar Functions. - posted by Сергей Парышев <se...@mail.ru.INVALID> on 2024/05/15 07:08:02 UTC, 0 replies.
- [jira] [Created] (FLINK-35358) Breaking change when loading artifacts - posted by "Rasmus Thygesen (Jira)" <ji...@apache.org> on 2024/05/15 07:56:00 UTC, 0 replies.
- [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/05/15 09:00:00 UTC, 4 replies.
- [jira] [Created] (FLINK-35359) General Improvement to Configuration for Flink 2.0 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/05/15 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35360) [Feature] Submit Flink CDC pipeline job to yarn Application mode - posted by "王俊博 (Jira)" <ji...@apache.org> on 2024/05/15 09:56:00 UTC, 0 replies.
- [DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0 - posted by Jane Chan <qi...@gmail.com> on 2024/05/15 10:19:56 UTC, 11 replies.
- [jira] [Created] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory - posted by "dengxaing (Jira)" <ji...@apache.org> on 2024/05/15 13:25:00 UTC, 0 replies.
- Confirmation on Lambda Support for UDFs in FlinkSQL / Table API - posted by Tucker Harvey <th...@pinterest.com.INVALID> on 2024/05/15 15:49:50 UTC, 3 replies.
- [jira] [Created] (FLINK-35363) Reorganization of flink-connector-jdbc - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35362) Reorganization of flink-connector-jdbc - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35364) Create core module and move code - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 17:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35365) Reorganize catalog and dialect code - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35366) Create all database modules - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35367) Reorganize datastream sink and source - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35368) Reorganize table code - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/15 17:51:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc - posted by Joao Boto <bo...@boto.pro> on 2024/05/15 18:15:49 UTC, 4 replies.
- [jira] [Created] (FLINK-35369) Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2024/05/15 20:45:00 UTC, 0 replies.
- [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option - posted by Keith Lee <le...@gmail.com> on 2024/05/15 20:57:48 UTC, 3 replies.
- [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/05/15 21:56:18 UTC, 6 replies.
- [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1 - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/05/15 21:59:00 UTC, 4 replies.
- [jira] [Created] (FLINK-35370) Create a temp module to test backward compatibility - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/16 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35371) Allow the keystore and truststore type to configured for SSL - posted by "Ammar Master (Jira)" <ji...@apache.org> on 2024/05/16 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35372) flink-cdc from mysql to doris, gives an error Unsupported type:TIME(0) when mysql data type is TIME and synchronise table structure or data. - posted by "joeb (Jira)" <ji...@apache.org> on 2024/05/16 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35373) Beautify Flink CDC Paimon Sink web ui - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/05/16 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35374) Flink 1.14 kafka connector Demo Error - posted by "hongxu han (Jira)" <ji...@apache.org> on 2024/05/16 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2 - posted by "田元志 (Jira)" <ji...@apache.org> on 2024/05/16 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed - posted by "中国无锡周良 (Jira)" <ji...@apache.org> on 2024/05/16 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35377) debezium-json support soft deletion. - posted by "Tongkai Yin (Jira)" <ji...@apache.org> on 2024/05/16 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/05/16 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35379) File merging manager is not properly notified about checkpoint - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/16 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/16 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/16 14:59:00 UTC, 0 replies.
- [DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/05/16 15:34:46 UTC, 4 replies.
- [jira] [Created] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/16 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35383) Update compatibility matrix to include 1.19 release - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/05/16 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2024/05/16 17:11:00 UTC, 0 replies.
- [Discuss] expose TaskIOMetricGroup to custom Partitioner - posted by Steven Wu <st...@gmail.com> on 2024/05/16 17:18:24 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink CDC Release 3.1.0, release candidate #3 - posted by Qingsheng Ren <re...@apache.org> on 2024/05/17 00:27:21 UTC, 0 replies.
- [jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19 - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/17 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/05/17 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35387) PG CDC source support heart beat - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/05/17 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory - posted by "Pedro Mázala (Jira)" <ji...@apache.org> on 2024/05/17 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35389) Implement List Async State API for ForStStateBackend - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/05/17 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35390) Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version - posted by "段志民 (Jira)" <ji...@apache.org> on 2024/05/17 09:00:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink CDC 3.1.0 released - posted by Qingsheng Ren <re...@apache.org> on 2024/05/17 09:32:43 UTC, 8 replies.
- [jira] [Created] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/05/17 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35392) SQL Lookup Join on external database failing when using 'FOR SYSTEM_TIME AS OF' statement - posted by "Glauber M Dantas (Jira)" <ji...@apache.org> on 2024/05/17 13:48:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction - posted by Martijn Visser <ma...@apache.org> on 2024/05/17 15:02:14 UTC, 0 replies.
- [RESULT][VOTE] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding - posted by Alan Sheinberg <as...@confluent.io.INVALID> on 2024/05/18 00:35:05 UTC, 0 replies.
- [jira] [Created] (FLINK-35393) Support flink kafka catalog - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/18 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35394) paimon pipeline support dynamic bucket - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/18 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35395) Fix KeyedStateStore class annotation error - posted by "bradley (Jira)" <ji...@apache.org> on 2024/05/18 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order - posted by "Suxing Lee (Jira)" <ji...@apache.org> on 2024/05/19 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35397) Translate Controller Flow documentation into Chinese - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/05/19 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35398) SqlGatewayE2ECase failed to pull image - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/20 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35399) Add documents for batch job master failure recovery - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2024/05/20 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35400) Rebuild FileMergingSnapshotManager in failover - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/20 06:33:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-mongodb v1.2.0, release candidate #2 - posted by Jiabao Sun <ji...@apache.org> on 2024/05/20 06:52:28 UTC, 2 replies.
- AppClassLoader leakage to MiniCluster - posted by Jan Lukavský <je...@seznam.cz> on 2024/05/20 12:02:42 UTC, 0 replies.
- [jira] [Created] (FLINK-35401) Add SQS Table API support - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/20 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35402) [flink-operator][Deployment] add labels to metadata - posted by "Luís Costa (Jira)" <ji...@apache.org> on 2024/05/20 16:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2024/05/20 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35404) Report metrics of KafkaConsumer in new Kafka source - posted by "Harshit Mittal (Jira)" <ji...@apache.org> on 2024/05/20 20:52:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0 - posted by Xuannan Su <su...@gmail.com> on 2024/05/21 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/05/21 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2024/05/21 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35407) ensure orderly transactions during the full consumption stage of MySQL CDC - posted by "xiaotouming (Jira)" <ji...@apache.org> on 2024/05/21 07:23:00 UTC, 0 replies.
- Re: [DISCUSS] Proposing an LTS Release for the 1.x Line - posted by Alexander Fedulov <al...@gmail.com> on 2024/05/21 09:20:56 UTC, 8 replies.
- [jira] [Created] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/21 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35409) Request more splits if all splits are filtered from addSplits method - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/05/21 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35410) Avoid sync waiting in coordinator thread of ForSt executor - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/21 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35411) Optimize wait logic in draining of async state requests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/21 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35412) Batch execution of async state request callback - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/05/21 10:23:00 UTC, 0 replies.
- [DISCUSS] Flink upgrade compatibility page not updated for Flink 1.19 - posted by Aleksandr Pilipenko <z3...@gmail.com> on 2024/05/21 10:27:55 UTC, 1 replies.
- [DISCUSS] The performance of serializerHeavyString starts regress since April 3 - posted by Rui Fan <19...@gmail.com> on 2024/05/21 10:49:34 UTC, 7 replies.
- [jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239 - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/21 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/05/21 14:52:00 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-cassandra v3.2.0, release candidate #1 - posted by Muhammet Orazov <mo...@morazow.com.INVALID> on 2024/05/21 20:14:36 UTC, 3 replies.
- [jira] [Created] (FLINK-35415) CDC Fails to create sink with Flink 1.19 - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/22 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/22 04:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/22 05:53:00 UTC, 0 replies.
- [SUMMARY] Flink 1.20 Release Sync 05/21/2024 - posted by weijie guo <gu...@gmail.com> on 2024/05/22 06:51:32 UTC, 1 replies.
- Re: [VOTE] Release flink-connector-aws v4.3.0, release candidate #2 - posted by Leonard Xu <xb...@gmail.com> on 2024/05/22 11:49:00 UTC, 1 replies.
- Re: [VOTE] Release flink-connector-gcp-pubsub v3.1.0, release candidate #1 - posted by Leonard Xu <xb...@gmail.com> on 2024/05/22 12:07:44 UTC, 0 replies.
- Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2 - posted by Leonard Xu <xb...@gmail.com> on 2024/05/22 12:13:51 UTC, 1 replies.
- Re: [VOTE] Release flink-connector-kafka v3.2.0, release candidate #1 - posted by Leonard Xu <xb...@gmail.com> on 2024/05/22 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/22 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35419) scan.bounded.latest-offset makes queries never finish if the latest message is a EndTxn Kafka marker - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/05/22 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/05/22 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35421) Schema Operator blocking forever when Akka Rpc timeout - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2024/05/22 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35422) Flink dynamically adjusts operator-level resource usage without stopping the job - posted by "尹博星 (Jira)" <ji...@apache.org> on 2024/05/22 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35423) ARRAY_EXCEPT should support set semantics - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/05/22 14:59:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-451: Introduce timeout configuration to AsyncSink - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/05/22 15:08:46 UTC, 0 replies.
- [jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/05/22 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35425) Support convert Freshness to cron expression for full refresh mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/05/23 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/05/23 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35427) Support fail-on-unknown-field config in json format - posted by "huhuan (Jira)" <ji...@apache.org> on 2024/05/23 03:48:00 UTC, 0 replies.
- [DISCUSS] Flink CDC Upgrade Debezium version to 2.x - posted by gongzhongqiang <go...@apache.org> on 2024/05/23 05:24:53 UTC, 2 replies.
- [jira] [Created] (FLINK-35428) WindowJoinITCase#testInnerJoin failed on AZP as NPE - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/23 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/23 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/05/23 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/05/23 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35432) Support catch modify-event for mysql-cdc - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2024/05/23 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35433) Provide a config parameter to set {{publishNotReadyAddresses}} option for the jobmanager's RPC Kubernetes service - posted by "Pavel (Jira)" <ji...@apache.org> on 2024/05/23 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35434) Support pass exception in StateExecutor to runtime - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2024/05/23 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/23 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35436) Job can't launch when setting the option schema.change.behavior to IGNORE - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2024/05/23 11:39:00 UTC, 0 replies.
- [VOTE] FLIP-443: Interruptible watermark processing - posted by Piotr Nowojski <pn...@apache.org> on 2024/05/23 12:21:26 UTC, 7 replies.
- [jira] [Created] (FLINK-35437) BlockStatementGrouper uses lots of memory - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/05/23 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/23 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35439) Python Support for AvroSchemaConverter - posted by "Greg Wills (Jira)" <ji...@apache.org> on 2024/05/23 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35440) unable to connect tableau to jdbc flink url using flink sql driver - posted by "Zach (Jira)" <ji...@apache.org> on 2024/05/24 00:45:00 UTC, 0 replies.
- [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0 - posted by Jane Chan <qi...@gmail.com> on 2024/05/24 01:51:18 UTC, 11 replies.
- [jira] [Created] (FLINK-35441) Add CDC upgrade compatibility tests - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/24 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35442) Kafka Pipeline Sink may distribute the same key to different partitions after modify parallelism - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/05/24 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/24 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/05/24 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35445) Update Async Sink documentation for Timeout configuration - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/24 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/24 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35447) Flink CDC Document document file had removed but website can access - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/05/24 12:05:00 UTC, 0 replies.
- [DISCUSS] Flink 1.19.1 release - posted by Hong Liang <ho...@apache.org> on 2024/05/24 12:57:00 UTC, 5 replies.
- [jira] [Created] (FLINK-35448) Translate pod templates documentation into Chinese - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/05/24 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35449) MySQL CDC Flink SQL column names are case-sensitive - posted by "linweijiang (Jira)" <ji...@apache.org> on 2024/05/25 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35450) Introduce Tikv pipeline DataSource - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/05/25 08:57:00 UTC, 0 replies.
- [off for 3 months] - posted by Etienne Chauchot <ec...@apache.org> on 2024/05/25 13:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-35451) Support `ALTER CATALOG COMMENT` syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/05/25 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot - posted by "Sharon Xie (Jira)" <ji...@apache.org> on 2024/05/26 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35453) StreamReader Charset fix with UTF8 in core files - posted by "xy (Jira)" <ji...@apache.org> on 2024/05/26 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/26 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35455) Non-idempotent unit tests - posted by "Kaiyao Ke (Jira)" <ji...@apache.org> on 2024/05/26 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35456) WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/27 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/27 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35458) Add serializer upgrade test for set serializer - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/05/27 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/05/27 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35460) Check file size when position read for ForSt - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/05/27 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35461) Improve Runtime Configuration for Flink 2.0 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/05/27 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator. - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/05/27 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed. - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2024/05/27 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity - posted by "yux (Jira)" <ji...@apache.org> on 2024/05/27 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/05/27 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*` - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/05/27 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environment variable. - posted by "Justin.Liu (Jira)" <ji...@apache.org> on 2024/05/28 00:47:00 UTC, 0 replies.
- [DISCUSS] Add Flink CDC Channel to Apache Flink Slack Workspace - posted by gongzhongqiang <go...@apache.org> on 2024/05/28 03:54:47 UTC, 4 replies.
- [jira] [Created] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment - posted by "zhou zhuohan (Jira)" <ji...@apache.org> on 2024/05/28 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/05/28 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35470) Flink 1.18.1 and 1.19.0 having build jdk 1.8 and causing incompatibilities with Java 17 - posted by "Rajat Pratap Singh (Jira)" <ji...@apache.org> on 2024/05/28 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/05/28 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35472) Improve tests for Elasticsearch 8 connector - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/05/28 07:08:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0 - posted by Jane Chan <qi...@gmail.com> on 2024/05/28 07:32:11 UTC, 0 replies.
- [jira] [Created] (FLINK-35473) FLIP-457: Improve Table/SQL Configuration for Flink 2.0 - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2024/05/28 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35474) During the process of catching up after a restart, Flink CDC uses the latest table information to parse old binlogs. - posted by "stevedengzhi (Jira)" <ji...@apache.org> on 2024/05/28 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35475) Introduce isInternalSorterSupport to OperatorAttributes - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/05/28 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35476) The IF built-in function returns an exception when returning a string - posted by "jianhao.Li (Jira)" <ji...@apache.org> on 2024/05/28 09:07:00 UTC, 0 replies.
- [DISCUSS] Flink CDC 3.1.1 Release - posted by Xiqian YU <ko...@outlook.com> on 2024/05/28 11:43:33 UTC, 6 replies.
- [DISCUSS] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn - posted by Yuxin Tan <ta...@gmail.com> on 2024/05/28 12:34:21 UTC, 4 replies.
- [RESULT][VOTE] FLIP-443: Interruptible watermark processing - posted by Piotr Nowojski <pn...@apache.org> on 2024/05/28 13:48:36 UTC, 0 replies.
- [jira] [Created] (FLINK-35477) Pulsar connector resets existing subscription - posted by "Igor Basov (Jira)" <ji...@apache.org> on 2024/05/28 16:02:00 UTC, 0 replies.
- [DISCUSS] FLIP-460: Display source/sink I/O metrics on Flink Web UI - posted by Zhanghao Chen <zh...@outlook.com> on 2024/05/29 02:43:19 UTC, 0 replies.
- [jira] [Created] (FLINK-35478) Pipeline sink Unified primary.key parameter - posted by "melin (Jira)" <ji...@apache.org> on 2024/05/29 02:44:00 UTC, 0 replies.
- [DISCUSS] Flink CEP: to add processing of unmatched events - posted by Anton Sidorov <as...@gmail.com> on 2024/05/29 07:14:13 UTC, 0 replies.
- [jira] [Created] (FLINK-35479) Add end-to-end test for materialized table - posted by "Feng Jin (Jira)" <ji...@apache.org> on 2024/05/29 12:34:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD - posted by Lajith Koova <la...@gmail.com> on 2024/05/29 12:40:11 UTC, 6 replies.
- [jira] [Created] (FLINK-35480) Add FIELD function in SQL & Table API - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2024/05/29 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35481) Add HISTOGRAM function in SQL & Table API - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2024/05/29 13:44:00 UTC, 0 replies.
- Slack Invite - posted by Nelson de Menezes Neto <ne...@gmail.com> on 2024/05/29 22:58:06 UTC, 1 replies.
- [jira] [Created] (FLINK-35482) ParquetInt64TimestampReaderTest unit tests fail due to system timezone - posted by "Rob Young (Jira)" <ji...@apache.org> on 2024/05/30 00:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35483) BatchJobRecoveryTest.testRecoverFromJMFailover produced no output for 900 second - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/30 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35484) Flink Document document file had removed but website can access - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/05/30 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35485) JobMaster failed with "the job xx has not been finished" - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/05/30 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35486) Potential sql expression generation issues on SQL gateway - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/05/30 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35487) ContinuousFileProcessingCheckpointITCase crashed as process exit with code 127 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/05/30 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35488) DataType Support Geometry Type - posted by "Leopold (Jira)" <ji...@apache.org> on 2024/05/30 05:41:00 UTC, 0 replies.
- Slack invite - posted by Sai Sankeerth Rao <sa...@gmail.com> on 2024/05/30 07:30:45 UTC, 1 replies.
- [jira] [Created] (FLINK-35489) Add capability to set min taskmanager.memory.managed.size when enabling autotuning - posted by "Nicolas Fraison (Jira)" <ji...@apache.org> on 2024/05/30 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35490) [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors - posted by "Muhammet Orazov (Jira)" <ji...@apache.org> on 2024/05/30 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules - posted by "Muhammet Orazov (Jira)" <ji...@apache.org> on 2024/05/30 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35492) Add metrics for FlinkStateSnapshot resources - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/05/30 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35493) Make max history age and count configurable for FlinkStateSnapshot resources - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/05/30 12:26:00 UTC, 0 replies.
- Flink 1.18.2 release date - posted by Yang LI <ya...@gmail.com> on 2024/05/30 14:32:28 UTC, 1 replies.
- [jira] [Created] (FLINK-35494) Reorganize sources - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/05/30 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35495) The native metrics for column family are not reported - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/05/31 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/05/31 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35497) The wrong enum value was used to get month in timestampDiff - posted by "haishui (Jira)" <ji...@apache.org> on 2024/05/31 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/05/31 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/05/31 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35500) DynamoDb SinkWriter fails to delete elements due to key not found - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/05/31 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35501) Use common thread pools when transferring RocksDB state files - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/05/31 18:24:00 UTC, 0 replies.