You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/11/01 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36648) bump flink version to 2.0-preview1 for Kafka connector - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/11/01 03:53:00 UTC, 0 replies.
- Re:Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by Xuyang <xy...@163.com> on 2024/11/01 04:10:35 UTC, 12 replies.
- [jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed - posted by "Di Wu (Jira)" <ji...@apache.org> on 2024/11/01 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists - posted by "Jerome Gagnon (Jira)" <ji...@apache.org> on 2024/11/01 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36651) Fix CI tests for ElasticSearch Connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/11/02 19:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36652) Upgrade Apache ORC to 1.9.4 - posted by "Yuchi Duan (Jira)" <ji...@apache.org> on 2024/11/03 14:30:00 UTC, 0 replies.
- Re: Re: [DISCUSS] FLIP-480: Support to deploy script in application mode - posted by Shengkai Fang <fs...@gmail.com> on 2024/11/04 02:00:32 UTC, 12 replies.
- [jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2024/11/04 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36654) Decimal divide Integer reports Null pointer exception - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2024/11/04 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36655) using flink state processor api to process big state in rocksdb is very slow - posted by "guanghua pi (Jira)" <ji...@apache.org> on 2024/11/04 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36656) Flink CDC treats MySQL Sharding table with boolean type conversion error - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/11/04 09:22:00 UTC, 0 replies.
- Re:[DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set - posted by Xuyang <xy...@163.com> on 2024/11/04 11:30:30 UTC, 1 replies.
- Flink technical debt. - posted by David Radley <da...@uk.ibm.com> on 2024/11/04 15:05:09 UTC, 26 replies.
- [jira] [Created] (FLINK-36657) Release Flink 1.20 - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2024/11/04 16:01:00 UTC, 0 replies.
- Re: Micro batching with flink - posted by Gabor Somogyi <ga...@gmail.com> on 2024/11/04 17:34:23 UTC, 2 replies.
- [VOTE] Release flink-connector-aws v5.0.0, release candidate #2 - posted by Hong Liang <ho...@apache.org> on 2024/11/04 23:00:25 UTC, 9 replies.
- [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1 - posted by Hong Liang <hl...@gmail.com> on 2024/11/04 23:28:03 UTC, 7 replies.
- Re: Kafka connector releases - posted by Yanquan Lv <de...@gmail.com> on 2024/11/05 03:48:21 UTC, 3 replies.
- [DISCUSS] AdaptiveScheduler slots assignment strategy optimization - posted by Yuepeng Pan <pa...@apache.org> on 2024/11/05 04:47:59 UTC, 1 replies.
- [jira] [Created] (FLINK-36658) Support and Release Connectors for Flink 2.0 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/11/05 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/11/05 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36660) Release flink-connector-elasticsearch vx.x.x for Flink 2.0 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/11/05 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36661) the managed memory setting is relatively small, resulting in duplicate processing results for batch tasks - posted by "陈磊 (Jira)" <ji...@apache.org> on 2024/11/05 07:54:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Junrui Li - posted by Zhu Zhu <zh...@apache.org> on 2024/11/05 11:59:36 UTC, 24 replies.
- [jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/11/05 15:51:00 UTC, 0 replies.
- Flink Kubernetes operator - posted by santhosh venkat <sa...@gmail.com> on 2024/11/06 01:11:04 UTC, 1 replies.
- Planned release dates for 1.19.2 and 1.20.1 - posted by Prasanna kumar <pr...@gmail.com> on 2024/11/06 01:16:25 UTC, 1 replies.
- [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? - posted by Yuepeng Pan <pa...@apache.org> on 2024/11/06 06:31:15 UTC, 3 replies.
- Re: [ANNOUNCE] Apache Flink 2.0 Preview released - posted by Zakelly Lan <za...@gmail.com> on 2024/11/06 08:16:03 UTC, 0 replies.
- [jira] [Created] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "kaitian (Jira)" <ji...@apache.org> on 2024/11/06 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36664) [Window]The window with window_offset will lose data. - posted by "kaitian (Jira)" <ji...@apache.org> on 2024/11/06 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/11/06 14:28:00 UTC, 0 replies.
- [DISCUSS] Changing return type of window properties (WINDOW_START/END) - posted by Dawid Wysakowicz <dw...@apache.org> on 2024/11/06 14:38:54 UTC, 4 replies.
- [jira] [Created] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/06 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36667) Remove `proto` schema definitions from source - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2024/11/06 16:24:00 UTC, 0 replies.
- RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD - posted by David Radley <da...@uk.ibm.com> on 2024/11/06 16:33:50 UTC, 3 replies.
- [VOTE] Release flink-connector-aws v5.0.0, release candidate #3 - posted by Hong Liang <hl...@gmail.com> on 2024/11/06 16:48:16 UTC, 5 replies.
- [jira] [Created] (FLINK-36668) Release flink-connector-aws v5.0.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/06 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36669) The flink version of ES should use parent's pom - posted by "Gianzie (Jira)" <ji...@apache.org> on 2024/11/07 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36670) Optimize port range out-of-bounds exception log - posted by "Gianzie (Jira)" <ji...@apache.org> on 2024/11/07 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/07 13:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-481: Introduce Event Reporting - posted by Piotr Nowojski <pi...@gmail.com> on 2024/11/07 13:33:48 UTC, 1 replies.
- [DISCUSS] FLIP-482: Add OpenTelemetryEventReporter - posted by Piotr Nowojski <pn...@apache.org> on 2024/11/07 13:36:06 UTC, 1 replies.
- [DISCUSS] FLIP-483: Add support for children Spans - posted by Piotr Nowojski <pn...@apache.org> on 2024/11/07 13:39:00 UTC, 1 replies.
- FLIP-484: Add custom metric variables to operators - posted by Piotr Nowojski <pn...@apache.org> on 2024/11/07 13:44:19 UTC, 1 replies.
- [DISCUSS] FLIP-484: Add custom metric variables to operators - posted by Piotr Nowojski <pn...@apache.org> on 2024/11/07 13:45:24 UTC, 0 replies.
- [jira] [Created] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/07 14:21:00 UTC, 0 replies.
- Flink V1 to V2 state migration - posted by David Radley <da...@uk.ibm.com> on 2024/11/07 17:10:25 UTC, 9 replies.
- [jira] [Created] (FLINK-36673) Operator is not properly handling failed deployments without savepoints - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2024/11/07 23:52:00 UTC, 0 replies.
- [DISCUSS] Feature Freeze for Flink 2.0 - Jan 13 - posted by Xintong Song <to...@gmail.com> on 2024/11/08 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36674) Flink will not commit if checkpointing is not enabled - posted by "slankka (Jira)" <ji...@apache.org> on 2024/11/08 05:13:00 UTC, 0 replies.
- [VOTE]FLIP-480: Support to deploy script in application mode - posted by Shengkai Fang <fs...@gmail.com> on 2024/11/08 07:09:20 UTC, 12 replies.
- [DISCUSS] Flink PubSub connector bump release needed - posted by Radek Stankiewicz <ra...@google.com.INVALID> on 2024/11/08 07:48:21 UTC, 2 replies.
- [RESULT][VOTE] flink-connector-prometheus v1.0.0, release candidate #1 - posted by Hong Liang <ho...@apache.org> on 2024/11/08 08:46:37 UTC, 0 replies.
- [jira] [Created] (FLINK-36675) Dynamic option hints will not take effect when restoring exec plan from json plan without setting 'table.plan.compile.catalog-objects' to 'all' - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/11/08 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36676) Flink CDC SQL Server Connector Missing Data - posted by "Chance (Jira)" <ji...@apache.org> on 2024/11/08 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36677) Instruct users to change log level dynamically in operator - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/11/08 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36678) The Flink CDC Yarn deployment mode document description is incorrect - posted by "xuweiwei (Jira)" <ji...@apache.org> on 2024/11/08 14:08:00 UTC, 0 replies.
- [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/11/08 17:22:57 UTC, 9 replies.
- [jira] [Created] (FLINK-36679) Add a metric to track checkpoint _metadata size - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/11/08 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36680) Flink K8S operator image 1.20.0 is still using Flink 1.19.1 - posted by "Maxime (Jira)" <ji...@apache.org> on 2024/11/08 19:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36681) Wrong chunks splitting query in incremental snapshot reading section in mysql cdc doc - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/11/09 01:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36682) Add split assign strategy to avoid OOM error in TaskManager - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/11/09 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36683) Support metadata 'row_kind' virtual column for Mongo CDC Connector - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/11/09 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36684) Support append only mode for MySQL CDC connector - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/11/10 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2024/11/11 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36686) allow customizing envs for flink-webhook container - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2024/11/11 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1 - posted by "Di Wu (Jira)" <ji...@apache.org> on 2024/11/11 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/11/11 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to v15 - posted by "Jason TANG (Jira)" <ji...@apache.org> on 2024/11/11 09:40:00 UTC, 0 replies.
- [RESULT][VOTE] flink-connector-aws v5.0.0, release candidate #3 - posted by Hong Liang <hl...@gmail.com> on 2024/11/11 09:49:28 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-prometheus 1.0.0 released - posted by Hong Liang <ho...@apache.org> on 2024/11/11 12:35:40 UTC, 0 replies.
- [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by Timo Walther <tw...@apache.org> on 2024/11/11 13:42:57 UTC, 11 replies.
- [ANNOUNCE] Apache flink-connector-aws 5.0.0 released - posted by Hong Liang <ho...@apache.org> on 2024/11/11 14:20:35 UTC, 0 replies.
- [jira] [Created] (FLINK-36690) Pipeline occasionally blocks when handling schema change events in parallel - posted by "yux (Jira)" <ji...@apache.org> on 2024/11/12 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/11/12 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36692) Flink Table HBase connector - posted by "cris niu (Jira)" <ji...@apache.org> on 2024/11/12 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36693) Implement checkpoint for ForStSyncKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/11/12 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36694) Update Hadoop shaded from 3.3.4 to 3.4.1 - posted by "Rasmus Thygesen (Jira)" <ji...@apache.org> on 2024/11/12 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36695) Bump Parquet dependency - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/11/12 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/11/12 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36697) Quickly evolving schema change in Doris fails - posted by "yux (Jira)" <ji...@apache.org> on 2024/11/13 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/11/13 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36699) Fix nullability when converting cdc data type to flink data type - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/11/13 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36700) Elasticsearch pipeline sink support authentication - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/11/13 05:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36701) Pipeline failover again after handling a schema change event as the first event after a failover - posted by "zjjiang (Jira)" <ji...@apache.org> on 2024/11/13 08:30:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-480: Support to deploy script in application mode - posted by Shengkai Fang <fs...@gmail.com> on 2024/11/13 09:07:44 UTC, 0 replies.
- [jira] [Created] (FLINK-36702) FLIP-480: Support to deploy SQL script in application mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/13 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36703) FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/13 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36704) Update TypeInference with StaticArgument and StateTypeStrategy - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/13 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36705) Add ProcessTableFunction class and annotations - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/13 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36706) Update TypeInferenceExtractor for PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/13 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36707) Integrate PTF TypeInference into Calcite validator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/13 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency - posted by "wanghaofeng (Jira)" <ji...@apache.org> on 2024/11/13 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36709) Flink parquet will throw exception when reading nested row data with last column is array. - posted by "Wenchao Wu (Jira)" <ji...@apache.org> on 2024/11/13 10:55:00 UTC, 0 replies.
- Dynamic Iceberg Sink - posted by Péter Váry <pe...@gmail.com> on 2024/11/13 11:27:14 UTC, 7 replies.
- [jira] [Created] (FLINK-36710) JobIDLoggingITCase fails on SourceCoordinator logs - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/11/13 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36711) Add tips when System out and err are redirected to LOG or discarded - posted by "Vincent Woo (Jira)" <ji...@apache.org> on 2024/11/13 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36712) Autoscaler should skip resource check when new parallelism/memory is lower than current - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/11/13 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2024/11/14 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36714) sstmerge/CompactionScheduler termination can be interrupted - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/11/14 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/11/14 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36716) Address vulnerabilities in Flink UI - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/11/14 13:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36717) Add health check to detect tasks stuck in DEPLOYING state - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/11/14 15:37:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by Timo Walther <tw...@apache.org> on 2024/11/14 16:22:14 UTC, 0 replies.
- [jira] [Created] (FLINK-36719) Add CompiledPlan annotations to BatchExecMultipleInput - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36718) Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36722) Add CompiledPlan annotations to BatchExecSortWindowAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36720) Add CompiledPlan annotations to BatchExecWindowTableFunction - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36721) Add CompiledPlan annotations to BatchExecHashWindowAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36724) Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36726) Add CompiledPlan annotations to BatchExecInputAdapter - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36723) Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36727) Add a completeness test to cover BatchExecNodes - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/14 19:55:00 UTC, 0 replies.
- Subject: [VOTE] Release flink-connector-kafka v3.4.0, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2024/11/14 20:01:46 UTC, 6 replies.
- [jira] [Created] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/11/15 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36734) Potential issue in autoscaler algorithm - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/11/15 22:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2024/11/16 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2024/11/16 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36737) flink-shaded-hadoop-2-uber contains the common io version incompatible with the flink client - posted by "melin (Jira)" <ji...@apache.org> on 2024/11/17 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21 - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/11/18 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS) - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/11/18 09:16:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36740) Dependencies update to address vulnerabilities - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/11/18 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36741) The precision of Decimal has been lost when use FlinkCDC transform - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/11/18 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36742) Filter unacked split for no capture tables when task restore from state - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/11/18 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36743) Rescale from unaligend checkpoint failed - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2024/11/18 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36744) Document operator's FlinkVersion compatibility - posted by "Dylan Meissner (Jira)" <ji...@apache.org> on 2024/11/18 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs - posted by "Andrei Kaigorodov (Jira)" <ji...@apache.org> on 2024/11/18 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "xiongraorao (Jira)" <ji...@apache.org> on 2024/11/19 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36747) History server can manage archived jobs - posted by "vertern (Jira)" <ji...@apache.org> on 2024/11/19 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36748) Web UI can stop job with savepoint and upload yaml file - posted by "vertern (Jira)" <ji...@apache.org> on 2024/11/19 09:29:00 UTC, 0 replies.
- Join slack - posted by Ecaterina-Sonia Lazarescu <ec...@gmail.com> on 2024/11/19 11:10:32 UTC, 0 replies.
- [jira] [Created] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/11/19 12:23:00 UTC, 0 replies.
- [DISCUSS] Release Flink CDC version 3.2.1 - posted by Hang Ruan <ru...@gmail.com> on 2024/11/20 03:00:56 UTC, 1 replies.
- [jira] [Created] (FLINK-36750) Paimon connector would reuse sequence number when schema evolution happened - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/11/20 05:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36751) PausableRelativeClock does not pause when the source only has one split - posted by "haishui (Jira)" <ji...@apache.org> on 2024/11/20 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36752) Emit state related metrics when checkpoints are disabled - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/11/20 19:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/11/21 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36754) When projection is empty or null, it is treated as an asterisk - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/11/21 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36755) Relax the limit about the pipeline.jar must have one in application mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36757) Introduce splitter to split scripts - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36756) Bump up the sql-gateway rest api version - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36758) Introduce driver to load the application in application mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36759) Intrdouce REST API to deploy script - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36760) Support to deploy script via sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36762) Add E2ECase to run sql client in application mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/11/21 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources - posted by "yux (Jira)" <ji...@apache.org> on 2024/11/21 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36764) Add checkpoint type to checkpoint trace - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/11/21 08:59:00 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 - posted by Hang Ruan <ru...@gmail.com> on 2024/11/21 10:05:14 UTC, 5 replies.
- [jira] [Created] (FLINK-36765) How to Handle Multi-Type Maps in Avro Schema with Flink Table API? - posted by "Maneendra (Jira)" <ji...@apache.org> on 2024/11/21 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36766) Use pyflink to create remote env - posted by "William Que (Jira)" <ji...@apache.org> on 2024/11/21 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/11/21 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same - posted by "Eaugene Thomas (Jira)" <ji...@apache.org> on 2024/11/21 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36769) Suport fury Serializer for pyflink - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2024/11/21 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36770) Support Request Timeout for AWS sinks - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/11/21 16:25:00 UTC, 0 replies.
- Plans for JDBC connector for 1.20? - posted by David Radley <da...@uk.ibm.com> on 2024/11/21 17:15:54 UTC, 1 replies.
- 回复: [jira] [Created] (FLINK-36768) Empty Checkpoint Directory created when older checkpoint fails due to timeout and the checkpoint interval is same - posted by Xia Rui <xi...@hotmail.com> on 2024/11/22 02:25:04 UTC, 0 replies.
- [jira] [Created] (FLINK-36771) Flink cdc UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/11/22 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36772) Fix Preconditions errorMessageTemplate is error - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/11/22 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36773) Introduce new Group Agg Operator with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/11/22 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36774) SQL gateway should support executing multiple SQL statements once - posted by "tim yu (Jira)" <ji...@apache.org> on 2024/11/22 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36775) fetchSize set in OracleIncrementalSource is not working - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/11/22 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36776) OracleIncrementalSource does not support partitioned table - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/11/22 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/11/22 10:03:00 UTC, 0 replies.
- [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler - posted by Yuepeng Pan <pa...@apache.org> on 2024/11/22 10:37:28 UTC, 1 replies.
- [jira] [Created] (FLINK-36778) The default implementation - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/11/22 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time - posted by "Roman Boyko (Jira)" <ji...@apache.org> on 2024/11/22 12:07:00 UTC, 0 replies.
- [DISCUSS] Flink 1.19.2 release - posted by Alexander Fedulov <al...@gmail.com> on 2024/11/22 14:35:10 UTC, 2 replies.
- [DISCUSS] Flink 1.20.1 release - posted by Alexander Fedulov <al...@gmail.com> on 2024/11/22 14:41:21 UTC, 8 replies.
- [Discussion] Session Clusters Support Heterogeneous Task Manager Images - posted by Ryan van Huuksloot <ry...@shopify.com.INVALID> on 2024/11/22 21:14:41 UTC, 0 replies.
- [jira] [Created] (FLINK-36780) Kafka source disable partition discovery unexpectedly - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/11/23 02:22:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-connector-hbase v4.0.0, release candidate #1 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/11/24 10:11:39 UTC, 0 replies.
- [jira] [Created] (FLINK-36781) Flink SQL REPL Remote Gateway lag - posted by "k walton (Jira)" <ji...@apache.org> on 2024/11/25 00:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36782) Incorrect comment syntax - posted by "altenchen (Jira)" <ji...@apache.org> on 2024/11/25 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36783) CTAS from VALUES throws ValidatioonException - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2024/11/25 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36784) Support to add metadata columns for data in the meta fields of DataChangeEvent at transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/11/25 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36785) Improve Starrocks unsupported field error return value - posted by "hunter (Jira)" <ji...@apache.org> on 2024/11/25 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36786) Memory leak in SplitFetcherManager#close - posted by "Zhen Wang (Jira)" <ji...@apache.org> on 2024/11/25 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36787) Flink SQL mode kafka join jdbc Dimension Table Yarn node OOM - posted by "zhengyuan (Jira)" <ji...@apache.org> on 2024/11/25 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36788) Add coverage for GlobalCommitter for SinkV2 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/11/25 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/11/25 15:32:00 UTC, 0 replies.
- [RESULT][VOTE] flink-connector-kafka 3.4.0, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2024/11/25 15:39:27 UTC, 0 replies.
- Blue/Green Deployments support for Flink - posted by Sergio Chong Loo <sc...@apple.com.INVALID> on 2024/11/25 18:23:59 UTC, 2 replies.
- [jira] [Created] (FLINK-36790) Flink CDC to Paimon: DeletionVectorsMaintainer CME problem - posted by "Rascal Wu (Jira)" <ji...@apache.org> on 2024/11/26 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/11/26 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/11/26 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36793) oracle cdc的增量快照的块分割器逻辑有问题导致分割的片过大的问题 - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36794) mysql cdc和postgres cdc对于分表分库场景的支持 - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36795) postgres cdc支持pipeline配置方式的connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36796) oracle cdc支持pipeline配置方式的connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36797) hudi sink支持pipeline配置方式的connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36798) Improve data processing speed during the phase from snapshot to incremental phase - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/11/26 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36799) iceberg sink支持pipeline配置方式的connector - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/11/26 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36800) Upgrade hadoop-aws to avoid CVE-2019-14887 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/11/26 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36801) Update CI image to Ubuntu 22.04 - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/11/26 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36802) Add CompiledPlan annotations to BatchExecSortMergeJoin - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/11/26 18:46:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-kafka 3.4.0 released - posted by Arvid Heise <ar...@apache.org> on 2024/11/26 20:58:04 UTC, 0 replies.
- [jira] [Created] (FLINK-36803) Use fixed format for splitId in all connectors - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/11/27 02:20:00 UTC, 0 replies.
- [RESULT][VOTE] Apache Flink CDC Release 3.2.1, release candidate #1 - posted by Hang Ruan <ru...@gmail.com> on 2024/11/27 03:21:49 UTC, 0 replies.
- [jira] [Created] (FLINK-36804) When the same number of characters in Chinese names exists, initiate error reporting. - posted by "hzk (Jira)" <ji...@apache.org> on 2024/11/27 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36805) Add support for using encrypted passwords in pipeline definitions - posted by "zjjiang (Jira)" <ji...@apache.org> on 2024/11/27 06:48:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink CDC 3.2.1 released - posted by Hang Ruan <ru...@apache.org> on 2024/11/27 08:24:17 UTC, 0 replies.
- [jira] [Created] (FLINK-36806) Support for synchronization between timestamp fields with and without time zones to avoid time offsets - posted by "zjjiang (Jira)" <ji...@apache.org> on 2024/11/27 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36807) Add coverage for pre-writer and pre-commit topologies for SinkV2 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/11/27 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36808) UNION ALL after lookup join produces unexpected results - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/11/27 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36809) Add ifNotExists param to createTable - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/11/27 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36810) Reflective access warning not addressed causing Flink failing to process job creation - posted by "Yusu Gao (Jira)" <ji...@apache.org> on 2024/11/27 15:08:00 UTC, 0 replies.
- Upsert to Kafka with flink SQL - posted by "Emil Hjelle (ekstern)" <em...@elvia.no> on 2024/11/27 15:35:19 UTC, 1 replies.
- [jira] [Created] (FLINK-36811) MySQL CDC - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/11/28 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/11/28 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36813) MySQLCDC supports synchronization of specified fields - posted by "Di Wu (Jira)" <ji...@apache.org> on 2024/11/28 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36814) Flink CDC Support Mutil Datasource - posted by "melin (Jira)" <ji...@apache.org> on 2024/11/28 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36815) series bugs of DSv2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/11/28 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36816) Support source parallelism setting for JDBC connector - posted by "Grzegorz Kołakowski (Jira)" <ji...@apache.org> on 2024/11/28 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36817) Give users ability to provide their own KafkaConsumer when using flink-connector-kafka - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2024/11/28 09:49:00 UTC, 0 replies.
- [DISCUSS] FLINK-36817 Feedback - posted by Levani Kokhreidze <le...@gmail.com> on 2024/11/28 10:04:02 UTC, 0 replies.
- RE: [jira] [Created] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint - posted by Ammu P <am...@gmail.com> on 2024/11/29 06:19:32 UTC, 0 replies.
- [jira] [Created] (FLINK-36818) Securing credentials in SQL connectors - posted by "Kunal Rohitas (Jira)" <ji...@apache.org> on 2024/11/29 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36819) [state/forst] Support link() in ForStFlinkFileSystem - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/11/29 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36820) SourceCoordinator#addSplitsBack() should not be called on full failover - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/29 09:44:00 UTC, 0 replies.
- Access to Slack - posted by Lauri Mäkinen <ls...@gmail.com> on 2024/11/29 10:35:10 UTC, 0 replies.
- [jira] [Created] (FLINK-36821) Upgrade Kafka Client version to 3.9.0 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/11/29 10:41:00 UTC, 0 replies.
- [QUESTION] Several unreleased 1.20.x and and 1.19.x versions in jira - posted by Sergey Nuyanzin <sn...@gmail.com> on 2024/11/30 15:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-36822) Enable spotless for java 21 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/11/30 15:52:00 UTC, 0 replies.