You are viewing a plain text version of this content. The canonical link for it is here.

---

- [jira] [Created] (FLINK-34555) Migrate JoinConditionTypeCoerceRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/01 03:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-423 ～FLIP-428: Introduce Disaggregated State Storage and Management in Flink 2.0 - posted by Zakelly Lan <za...@gmail.com> on 2024/03/01 04:00:54 UTC, 28 replies.
- [jira] [Created] (FLINK-34556) Migrate EnumerableToLogicalTableScan - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/01 04:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34557) When the Flink task ends in application mode, there may be issues with the Znode and HDFS files not being deleted - posted by "tanliang (Jira)" <ji...@apache.org> on 2024/03/01 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34558) Add RocksDB key/value size metrics - posted by "Jufang He (Jira)" <ji...@apache.org> on 2024/03/01 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34559) TVF Window Aggregations might stuck - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/03/01 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34560) JoinITCase seems to fail on a broader scale (MiniCluster issue?) - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/01 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34561) Downgrading flink-kubernetes-operator causes failure - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2024/03/01 11:14:00 UTC, 0 replies.
- Assistance Needed: Community Over Code Connections - posted by Brian Proffitt <bk...@apache.org> on 2024/03/01 15:05:25 UTC, 0 replies.
- Re: [DISCUSS] Apache Bahir retired - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/03/01 16:23:31 UTC, 2 replies.
- [jira] [Created] (FLINK-34562) Port Debezium Avro Confluent changes (FLINK-34509) to Chinese - posted by "Lorenzo Affetti (Jira)" <ji...@apache.org> on 2024/03/01 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34563) Autoscaling decision improvement - posted by "Yang LI (Jira)" <ji...@apache.org> on 2024/03/01 17:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34564) Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/03/02 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34565) Enhance flink kubernetes configMap to accommodate additional configuration files - posted by "Surendra Singh Lilhore (Jira)" <ji...@apache.org> on 2024/03/02 06:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-399: Flink Connector Doris - posted by Yanquan Lv <de...@gmail.com> on 2024/03/02 09:13:58 UTC, 19 replies.
- Default scale and precision SQL data types - posted by Sergei Morozov <mo...@tut.by> on 2024/03/03 01:33:06 UTC, 3 replies.
- [jira] [Created] (FLINK-34566) Flink Kubernetes Operator reconciliation parallelism setting not work - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2024/03/04 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34567) flink task manager error occur, msg: Encountered error while consuming partitions - posted by "yamanda (Jira)" <ji...@apache.org> on 2024/03/04 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34568) YarnFileStageTest.destroyHDFS timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/04 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34569) 'Streaming File Sink s3 end-to-end test' failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/04 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34570) JoinITCase.testLeftJoinWithEqualPk times out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/04 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/04 07:54:00 UTC, 0 replies.
- [connectors] Notice to connector authors - posted by Etienne Chauchot <ec...@apache.org> on 2024/03/04 09:21:36 UTC, 3 replies.
- Re: [DISCUSS] Move CheckpointingMode to flink-core - posted by Zakelly Lan <za...@gmail.com> on 2024/03/04 11:02:55 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-314: Support Customized Job Lineage Listener - posted by Yong Fang <zj...@gmail.com> on 2024/03/04 11:16:31 UTC, 0 replies.
- [jira] [Created] (FLINK-34572) JDBC: Support OceanBase catalog - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/03/04 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34573) the task is stuck on the high presure - posted by "LSZ (Jira)" <ji...@apache.org> on 2024/03/04 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34574) Add CPU and memory size autoscaler quota - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/03/04 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34575) Vulnerabilities in commons-compress 1.24.0; upgrade to 1.26.0 needed. - posted by "Adrian Vasiliu (Jira)" <ji...@apache.org> on 2024/03/04 15:26:04 UTC, 0 replies.
- [jira] [Created] (FLINK-34576) Flink deployment keep staying at RECONCILING/STABLE status - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/03/05 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34577) Add IssueNavigationLink for IDEA git log - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/05 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34578) Remove issue template - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/05 08:16:00 UTC, 0 replies.
- [DISCUSS] Add "Special Thanks" Page on the Flink Website - posted by Jark Wu <im...@gmail.com> on 2024/03/05 08:56:13 UTC, 17 replies.
- Re: Temporal join on rolling aggregate - posted by lo...@ververica.com.INVALID on 2024/03/05 08:57:12 UTC, 2 replies.
- [jira] [Created] (FLINK-34579) Introduce metric for time since last completed checkpoint - posted by "Stefan Richter (Jira)" <ji...@apache.org> on 2024/03/05 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34580) Job run via REST erases "pipeline.classpaths" config - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/03/05 12:55:00 UTC, 0 replies.
- [VOTE] Release 1.19.0, release candidate #1 - posted by Lincoln Lee <li...@gmail.com> on 2024/03/05 16:24:57 UTC, 5 replies.
- [jira] [Created] (FLINK-34581) streaming code throws java.lang.reflect.InaccessibleObjectException - posted by "Henning Schmiedehausen (Jira)" <ji...@apache.org> on 2024/03/06 01:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/03/06 04:52:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.19.0 rc1 cancelled & sync summary on 03/05/2024 - posted by Lincoln Lee <li...@gmail.com> on 2024/03/06 06:09:14 UTC, 0 replies.
- [jira] [Created] (FLINK-34584) Change package name to org.apache.flink.cdc - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2024/03/06 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2024/03/06 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34586) Update the README in Flink CDC - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2024/03/06 09:20:00 UTC, 0 replies.
- [DISCUSS] FLIP-433: State Access on DataStream API V2 - posted by weijie guo <gu...@gmail.com> on 2024/03/06 10:16:36 UTC, 16 replies.
- [jira] [Created] (FLINK-34587) Suport MODE aggregate function - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 11:12:00 UTC, 0 replies.
- [VOTE] FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes - posted by Jinzhong Li <li...@gmail.com> on 2024/03/06 12:29:45 UTC, 9 replies.
- [DISCUSS] FLIP Suggestion: Externalize Kudu Connector from Bahir - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/03/06 15:23:51 UTC, 10 replies.
- [jira] [Created] (FLINK-34588) FineGrainedSlotManager checks whether resources need to reconcile but doesn't act on the result - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/06 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34591) CLONE - Build and stage Java and Python artifacts - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34592) CLONE - Stage source and binary releases on dist.apache.org - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34594) CLONE - Vote on the release candidate - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34589) FineGrainedSlotManager doesn't handle errors in the resource reconcilliation step - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34590) Build Release Candidate: 1.19.0-rc2 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34593) CLONE - Propose a pull request for website updates - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/06 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/06 16:32:00 UTC, 0 replies.
- Flink Kubernetes Operator Failing Over FlinkDeployments to a New Cluster - posted by Kevin Lam <ke...@shopify.com.INVALID> on 2024/03/06 19:07:15 UTC, 9 replies.
- [jira] [Created] (FLINK-34596) Migrate RemoveRedundantLocalHashAggRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34597) Migrate SimplifyFilterConditionRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 21:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34598) Migrate RemoveRedundantLocalRankRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34599) Migrate BatchPhysicalConstantTableFunctionScanRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 23:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34600) Migrate PushLimitIntoLegacyTableSourceScanRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34601) Migrate StreamPhysicalConstantTableFunctionScanRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/06 23:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34602) Migrate StreamPhysicalWindowJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/07 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34604) Migrate BatchPhysicalCalcRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34605) Migrate BatchPhysicalDistributionRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34606) Migrate BatchPhysicalExpandRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34607) Migrate BatchPhysicalUnionRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34608) Migrate BatchPhysicalValuesRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34610) Migrate StreamPhysicalLimitRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34612) Migrate StreamPhysicalValuesRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34611) Migrate StreamPhysicalUnionRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34613) allow specifing a savepoint file to restart using cli script. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/07 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34614) Add e2e test for Flink CDC pipeline job. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/07 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34615) Move ExternalizedCheckpointCleanup to flink-core - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2024/03/07 07:53:00 UTC, 0 replies.
- [DISCUSS] FLIP-424: Asynchronous State APIs - posted by Zakelly Lan <za...@gmail.com> on 2024/03/07 08:45:52 UTC, 23 replies.
- [DISCUSS] FLIP-426: Grouping Remote State Access - posted by Jinzhong Li <li...@gmail.com> on 2024/03/07 08:52:47 UTC, 8 replies.
- [DISCUSS] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by Jinzhong Li <li...@gmail.com> on 2024/03/07 08:55:14 UTC, 15 replies.
- [DISCUSS] FLIP-425: Asynchronous Execution Model - posted by Yanfei Lei <fr...@gmail.com> on 2024/03/07 09:04:05 UTC, 14 replies.
- [DISCUSS] FLIP-427: Disaggregated State Store - posted by Hangxiang Yu <ma...@gmail.com> on 2024/03/07 09:07:09 UTC, 11 replies.
- [jira] [Created] (FLINK-34616) python dist doesn't clean when open method construct resource - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/07 09:58:00 UTC, 0 replies.
- [VOTE] Release 1.19.0, release candidate #2 - posted by Lincoln Lee <li...@gmail.com> on 2024/03/07 10:00:19 UTC, 32 replies.
- [jira] [Created] (FLINK-34617) Correct the Javadoc of org.apache.flink.api.common.time.Time - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/03/07 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule - posted by "Yongming Zhang (Jira)" <ji...@apache.org> on 2024/03/07 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34619) Do not wait for scaling completion in UPGRADE state with in-place scaling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/03/07 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34620) Process recursive protobuf schemas in PbToRowTypeUtil - posted by "Artem (Jira)" <ji...@apache.org> on 2024/03/07 15:03:00 UTC, 0 replies.
- [VOTE] FLIP-402: Extend ZooKeeper Curator configurations - posted by Alex Nitavsky <al...@gmail.com> on 2024/03/07 15:07:41 UTC, 6 replies.
- [jira] [Created] (FLINK-34621) Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/03/07 20:20:00 UTC, 0 replies.
- Re: [DISCUSS] Support the Ozone Filesystem - posted by Martijn Visser <ma...@apache.org> on 2024/03/08 04:43:45 UTC, 1 replies.
- [jira] [Created] (FLINK-34622) Typo of execution_mode configuration name in Chinese document - posted by "Yu Chen (Jira)" <ji...@apache.org> on 2024/03/08 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34623) Flink creating main.jar files in jobmanager jars upload folder - posted by "Nikhil_D (Jira)" <ji...@apache.org> on 2024/03/08 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/03/08 10:43:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-419: Optimize multi-sink query plan generation - posted by Martijn Visser <ma...@apache.org> on 2024/03/08 11:00:51 UTC, 1 replies.
- Re: [DISCUSS] Externalized Google Cloud Connectors - posted by Martijn Visser <ma...@apache.org> on 2024/03/08 11:03:13 UTC, 1 replies.
- [jira] [Created] (FLINK-34625) TTL doesn't seem to work in pyflink - posted by "Mark Lidenberg (Jira)" <ji...@apache.org> on 2024/03/08 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34628) Pulsar source lost topic subscribe - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2024/03/08 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34627) Pulsar source lost topic subscribe - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2024/03/08 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34626) Pulsar source lost topic subscribe - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2024/03/08 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34629) Pulsar source lost topic subscribe - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2024/03/08 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34630) Pulsar source lost topic subscribe - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2024/03/08 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34631) Memory leak in pyflink when using state with RocksDB - posted by "Mark Lidenberg (Jira)" <ji...@apache.org> on 2024/03/08 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/03/09 01:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34633) Support unnesting array constants - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/03/09 01:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34634) Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/09 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34635) Clear successful records from the batch in JDBC connector - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/03/09 09:04:00 UTC, 0 replies.
- 退订 - posted by bai年 <82...@qq.com.INVALID> on 2024/03/09 16:22:41 UTC, 4 replies.
- [jira] [Created] (FLINK-34636) Requesting exclusive buffers timeout causes repeated restarts and cannot be automatically recovered - posted by "Vincent Woo (Jira)" <ji...@apache.org> on 2024/03/10 10:21:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes - posted by Jing Ge <ji...@ververica.com.INVALID> on 2024/03/10 16:28:53 UTC, 3 replies.
- [DISCUSS] FLIP-434: Support optimizations for pre-partitioned data sources - posted by Jeyhun Karimov <je...@gmail.com> on 2024/03/10 19:38:00 UTC, 13 replies.
- [jira] [Created] (FLINK-34637) Migrate JoinConditionEqualityTransferRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/11 00:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34638) Support default value of table column. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/11 05:34:00 UTC, 0 replies.
- [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines - posted by Ron liu <ro...@gmail.com> on 2024/03/11 07:23:32 UTC, 16 replies.
- 退订 unsubscribe - posted by 95...@sina.com on 2024/03/11 08:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/03/11 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34640) Replace DummyMetricGroup usage with UnregisteredMetricsGroup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/03/11 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34641) Possibility to add Python Files from http/https sources in PythonDriver - posted by "Aleksei Perminov (Jira)" <ji...@apache.org> on 2024/03/11 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34642) Add a dedicated test for when the lower utilization boundary is zero - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/03/11 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34643) JobIDLoggingITCase failed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/11 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/11 14:32:00 UTC, 0 replies.
- Re: [VOTE] FLIP-314: Support Customized Job Lineage Listener - posted by Maximilian Michels <mx...@apache.org> on 2024/03/11 14:48:06 UTC, 0 replies.
- [jira] [Created] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/11 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34646) AggregateITCase.testDistinctWithRetract timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/11 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34647) Path normalization is allocation intensive - posted by "David Schlosnagle (Jira)" <ji...@apache.org> on 2024/03/12 00:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/12 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34649) Migrate PushFilterIntoLegacyTableSourceScanRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/12 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/12 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3 - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2024/03/12 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34652) Use CheckpointStreamFactory for StateChangeFsUploader - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/03/12 06:28:00 UTC, 0 replies.
- Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format - posted by Anupam Aggarwal <an...@gmail.com> on 2024/03/12 06:32:42 UTC, 4 replies.
- [jira] [Created] (FLINK-34653) Support table merging with route in Flink CDC - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/12 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34654) Add "Special Thanks" Page on the Flink Website - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2024/03/12 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34655) Autoscaler doesn't work for flink 1.15 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/12 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34656) Generated code for `ITEM` operator should return null when getting element of a null map/array/row - posted by "yisha zhou (Jira)" <ji...@apache.org> on 2024/03/12 13:59:00 UTC, 0 replies.
- Re: [DISCUSS] Manual savepoint triggering in flink-kubernetes-operator - posted by Robert Metzger <rm...@apache.org> on 2024/03/12 14:53:18 UTC, 4 replies.
- [jira] [Created] (FLINK-34657) Implement Lineage Graph for streaming API use cases - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/03/12 18:21:00 UTC, 0 replies.
- [DISCUSS] FLIP-437: Support ML Models in Flink SQL - posted by Hao Li <hl...@confluent.io.INVALID> on 2024/03/12 21:55:04 UTC, 23 replies.
- Additional metadata available for Kafka serdes - posted by Balint Bene <ba...@shopify.com.INVALID> on 2024/03/12 22:18:22 UTC, 3 replies.
- [jira] [Created] (FLINK-34658) Scala API unusable on Flink 1.18.1/Java 17 Docker image - posted by "Matthew Ernst (Jira)" <ji...@apache.org> on 2024/03/12 23:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34659) How to implement global sort in latest flink datastream API - posted by "Junyao Huang (Jira)" <ji...@apache.org> on 2024/03/13 03:22:00 UTC, 0 replies.
- Re: Question around Flink's AdaptiveBatchScheduler - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/03/13 05:11:27 UTC, 0 replies.
- Re: Flink's treatment to "hadoop" and "yarn" configuration overrides seems unintuitive - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/03/13 05:13:05 UTC, 0 replies.
- [jira] [Created] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2024/03/13 06:12:00 UTC, 0 replies.
- [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax - posted by Yubin Li <ly...@gmail.com> on 2024/03/13 09:08:44 UTC, 28 replies.
- [jira] [Created] (FLINK-34661) TaskExecutor supports retain partitions after JM crashed. - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/03/13 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34662) Add new issue template for Flink CDC repo - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/13 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34663) flink-opensearch connector Unable to parse response body for Response - posted by "wael shehata (Jira)" <ji...@apache.org> on 2024/03/13 19:07:00 UTC, 0 replies.
- Unable to override PrometheusReporter using PrometheusGateway 'filterLabelValueCharacters' - posted by Ryan van Huuksloot <ry...@shopify.com.INVALID> on 2024/03/13 20:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-34664) Add .asf.yaml for Flink CDC - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/14 02:22:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes - posted by Jinzhong Li <li...@gmail.com> on 2024/03/14 06:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/14 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34666) Keep assigned splits in order to fix wrong meta group calculation - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/14 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34667) Changelog state backend support local rescaling - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/03/14 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34668) Report State handle of file merging directory to JM - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/03/14 09:57:00 UTC, 0 replies.
- Re: [DISCUSS] Kubernetes Operator 1.8.0 release planning - posted by Maximilian Michels <mx...@apache.org> on 2024/03/14 10:34:28 UTC, 0 replies.
- [DISCUSS] Removing documentation on Azure Pipelines for Flink forks - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2024/03/14 10:40:49 UTC, 2 replies.
- [jira] [Created] (FLINK-34669) Optimization of Arch Rules for Connector Constraints and Violation File Updates - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2024/03/14 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34670) Use SynchronousQueue to create asyncOperationsThreadPool for SubtaskCheckpointCoordinatorImpl - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/03/14 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34671) Update the content of README.md in FlinkCDC project - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/14 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/03/14 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/14 14:23:00 UTC, 0 replies.
- ARM flink docker image - posted by Yang LI <ya...@gmail.com> on 2024/03/14 15:33:18 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.8.0, release candidate #1 - posted by Maximilian Michels <mx...@apache.org> on 2024/03/14 17:44:46 UTC, 8 replies.
- Efficient Use of Disk Resources (Only Attach Disks to Stateful Task Managers) - posted by Kevin Lam <ke...@shopify.com.INVALID> on 2024/03/14 19:10:10 UTC, 0 replies.
- [jira] [Created] (FLINK-34674) Migrate CalcSnapshotTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/14 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34675) Migrate AggregateReduceGroupingRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/14 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34676) Migrate ConvertToNotInOrInRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/14 23:04:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.19.0, release candidate #2 - posted by Lincoln Lee <li...@gmail.com> on 2024/03/15 02:09:33 UTC, 0 replies.
- [jira] [Created] (FLINK-34677) Refactor the structure of documentation for Flink CDC - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 02:58:05 UTC, 0 replies.
- [jira] [Created] (FLINK-34678) "Introduction" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34680) "Overview" Page for Connectors in Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34681) "Deployment" Pages for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34682) "Developer Guide - Understanding Flink CDC" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34683) "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34685) "Deployment - Kubernetes" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34686) "Deployment - YARN" Page for Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34687) Home Page of Flink CDC Documentation - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34688) CDC framework split snapshot chunks asynchronously - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/15 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34689) check binlog_row_value_optoins - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2024/03/15 03:58:00 UTC, 0 replies.
- 回复: [DISCUSS] FLIP-426: Grouping Remote State Access - posted by 夏 瑞 <xi...@hotmail.com> on 2024/03/15 04:06:53 UTC, 0 replies.
- [jira] [Created] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/15 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34691) failed to convert time type when using mysql to doris pipeline. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/15 06:09:00 UTC, 0 replies.
- Re: Unaligned checkpoint blocked by long Async operation - posted by Gyula Fóra <gy...@gmail.com> on 2024/03/15 06:58:49 UTC, 1 replies.
- [jira] [Created] (FLINK-34692) Update Flink website to point to the new Flink CDC “Get Started” page - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/03/15 07:36:00 UTC, 0 replies.
- Chained rebalance() guarantees - posted by Jan Lukavský <je...@seznam.cz> on 2024/03/15 07:43:47 UTC, 0 replies.
- [jira] [Created] (FLINK-34693) Memory leak in KafkaWriter - posted by "Stefan Richter (Jira)" <ji...@apache.org> on 2024/03/15 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34694) Delete num of associations for streaming outer join - posted by "Roman Boyko (Jira)" <ji...@apache.org> on 2024/03/15 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34695) Move Flink's CI docker container into a public repo - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/15 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs - posted by "Simon-Shlomo Poil (Jira)" <ji...@apache.org> on 2024/03/15 14:04:00 UTC, 1 replies.
- [jira] [Created] (FLINK-34697) Finalize release 1.19.0 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/16 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34701) CLONE - Publish the Dockerfiles for the new release - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/16 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34698) CLONE - Deploy Python artifacts to PyPI - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/16 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34699) CLONE - Deploy artifacts to Maven Central Repository - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/16 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34700) CLONE - Create Git tag and mark version as released in Jira - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/16 00:54:00 UTC, 0 replies.
- Apache Flink : Vector database connector - posted by Asimansu Bera <as...@gmail.com> on 2024/03/16 18:18:53 UTC, 1 replies.
- [jira] [Created] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/03/17 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34703) Correct Scala Example for ORC Bulker Writer's Vectorizer - posted by "Colten Pilgreen (Jira)" <ji...@apache.org> on 2024/03/17 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/03/18 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34705) org.apache.flink.connector.elasticsearch.sink.ElasticsearchWriterITCase FAILURE - posted by "baihailiang (Jira)" <ji...@apache.org> on 2024/03/18 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34706) Promote release 1.19 - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34708) CLONE - Merge website pull request - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34712) CLONE - Update reference data for Migration Tests - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34713) CLONE - Updates the docs stable version - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34707) CLONE - Update japicmp configuration - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34714) CLONE - Start End of Life discussion thread for now outdated Flink minor version - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34711) CLONE - Other announcements - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34710) CLONE - Apache mailing lists announcements - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34709) CLONE - Remove outdated versions - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34715) Fix mysql ut about closing BinlogSplitReader - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/03/18 08:04:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.19.0 released - posted by Lincoln Lee <li...@gmail.com> on 2024/03/18 08:25:33 UTC, 32 replies.
- [jira] [Created] (FLINK-34716) Build 1.19 docs in GitHub Action and mark 1.19 as stable in docs - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/18 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34717) BroadcastStateITCase failed fatally with 127 exit code - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/18 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34718) PartitionedWindowed - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/18 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/18 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34720) Deploy Maven Snapshot failed on AZP - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/18 13:40:00 UTC, 0 replies.
- Wiki permissions - posted by Ryan Skraba <ry...@aiven.io.INVALID> on 2024/03/18 14:37:15 UTC, 0 replies.
- [jira] [Created] (FLINK-34721) An grammar error occurs in the Barrier test file - posted by "Haifei Chen (Jira)" <ji...@apache.org> on 2024/03/18 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34722) Support conditional upserts with Postgres JDBC sink - posted by "Pietro (Jira)" <ji...@apache.org> on 2024/03/18 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34723) Parquet writer should restrict map keys to be not null - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/03/19 00:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34724) Fix broken web link in document of legacy Flink CDC Sources - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/19 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34725) Dockerfiles for release publishing has incorrect config.yaml path - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/19 04:54:00 UTC, 0 replies.
- Support minibatch for TopNFunction - posted by Roman Boyko <ro...@gmail.com> on 2024/03/19 05:24:12 UTC, 5 replies.
- [jira] [Created] (FLINK-34726) Flink Kubernetes Operator has some room for optimizing performance. - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2024/03/19 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large - posted by "Wancheng Xiao (Jira)" <ji...@apache.org> on 2024/03/19 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34728) operator does not need to upload and download the jar when deploying session job - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2024/03/19 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34729) "Core Concept" Pages for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34730) "Deployment" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34731) Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/03/19 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34732) Add document dead link check for Flink CDC Documentation - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/19 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34733) OSS Filesystem throws ClassNotFoundException - posted by "zhuoshaojian (Jira)" <ji...@apache.org> on 2024/03/19 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34734) Update the titles for Chinese Documents. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:15:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 1.20 - posted by weijie guo <gu...@gmail.com> on 2024/03/19 09:29:30 UTC, 15 replies.
- [jira] [Created] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34739) "Connectors" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34740) "legacy-flink-cdc-sources" Pages for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34741) "get-started" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:55:00 UTC, 0 replies.
- [VOTE] FLIP-436: Introduce Catalog-related Syntax - posted by Yubin Li <ly...@gmail.com> on 2024/03/19 09:56:42 UTC, 10 replies.
- [jira] [Created] (FLINK-34742) Translate "FAQ" Page for Flink CDC Chinese Documentation - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/19 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34743) Memory tuning takes effect even if the parallelism isn't changed - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/19 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34744) autoscaling-dynamic cannot run - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/19 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34745) Parsing temporal table join throws cryptic exceptions - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/03/19 14:58:00 UTC, 0 replies.
- [SUMMARY] Flink 1.19 last sync summary on 03/19/2024 - posted by Lincoln Lee <li...@gmail.com> on 2024/03/19 15:49:58 UTC, 1 replies.
- Proposal to modify Flink’s startup sequence for MINIMUM downtime across deployments - posted by Sergio Chong Loo <sc...@apple.com.INVALID> on 2024/03/19 18:27:26 UTC, 3 replies.
- [jira] [Created] (FLINK-34746) Switching to the Apache CDN for Dockerfile - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/20 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34750) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34751) RestClusterClient APIs doesn't work with running Flink application on YARN - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2024/03/20 04:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34753) Update outdated MongoDB CDC FAQ in doc - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/03/20 07:44:00 UTC, 0 replies.
- [NOTICE] Flink CDC is importing GitHub issues into Apache Jira - posted by Qingsheng Ren <re...@apache.org> on 2024/03/20 07:47:20 UTC, 2 replies.
- [jira] [Created] (FLINK-34754) [tidb-cdc]When the task runs for a period of time, there are only Resolved Events - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34755) Encountered a problem reading tidb data - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34756) [MySQL-CDC] serverId parameter out of Integer range - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34757) Flink CDC Clinkhouse - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34758) Caused by: io.debezium.DebeziumException: could not find next log; - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34759) Can not start FlinkCDC 2.3 with startupOptions = specificOffset - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34760) Refactor state serializers in MySQL CDC source - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34761) Support table.exclude.list as Debezium does - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34769) [mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records push down - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34766) Ensure checkpointing is enabled for Postgres connector - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34771) Flink CDC connector with YugabyteDB - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34774) Supports synchronizing data from the oracle standby database - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34763) OracleIncrementalSource at Oracle CDB mode - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34770) Unify download links of legacy connector to fat jar - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34773) [Bug][mysql-cdc] com.ververica.cdc.connectors.mysql.source.utils.StatementUtils#initStatement leads to uncommitted transactions - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34762) use earliest-offset or timestamp mode to consume data,flink job always restart - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34768) simple tidb cdc demo,but caused 'java.lang.IllegalArgumentException: Invalid range: ' - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34764) FlinkCDC is incompatible with MariaDB 10.0.24 - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34765) Does flink cdc plan to support duckdb sink - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34772) [Bug] [Critical] cdc-myql-connector snapshot/binlog phase MySQL -> MySQL temporal related field transfer WRONG with/or wrong epoch time across timezone - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34767) flink-sql-connector-mysql-cdc cannot read incremental data in initial mode - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34781) [Bug] [oracle] oracle real-time synchronization is slow - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34783) [Bug] TiDB Flink CDC not support exactly once - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34782) Multiple source read binlogs of the same job are all assigned to SubTask-0, which may have performance problems. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34776) mysql cdc restart from checkpoint failed when some binlog file has been purged - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34779) look forward to adding dameng（dm8） connectors - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34778) look forward to adding greenplum connectors - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34777) [Bug] Select mysql cdc table in flink sql client caused java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/ObjectMapper - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34780) [Bug] Oracle cdc repeatedly consumes snapshot data and does not consume binlog data - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34775) [Bug] oracle cdc logminer can't catch up the latest records when scn huge increment occured. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34784) [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34793) Supports synchronizing data from the postgreSQL standby database? - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34788) [Bug] Flink CDC Orcale Connection Pool Number settings cannot take effect - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34789) [Bug] DBZ-5589 Mysql connector can't handle the case sensitive of rename/change column statement - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34785) [bug] MySQL using utf8_ general_ Ci encoding, splitting will end prematurely - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34794) [Bug] if splitTable method execute fast than getNext, job will be blocked - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34791) Add docs for the experimental features. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34790) The program encountered a blockage preventing it from reading snapshot data from mysql-cdc [Bug] - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34787) Tidb, please support synchronization of multiple tables at the same time - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34786) [Bug] [tidb cdc]a error:java.lang.IllegalArgumentException: Invalid range: [+INF..{xxx}) at org.apache.flink.shaded.guava30.com.google.common.collect.Range.(Range.java:358) - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34792) [Bug] Incremental source never switches to streaming mode with disabled checkpointing and parallelism > 1 - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34800) [Bug] Mysql Startup with TIMESTAMP，Restore From Checkpoint Failed：One or more fetchers have encountered exception - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34795) expected to support flink-connector-db2-cd('scan.startup.mode'='specific_offsets') - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34803) Support cdc catalog - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34796) [Bug] flink cdc has lot of lamda class, it may leaked in flink standalone cluster after task start and stop many times - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34799) SQL server cannot read the correct table[Bug] - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34802) [Bug] Paimon CDC ingestion with mysql-cdc 2.4.1 cannot receive complete Debezium binlog - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34805) [Bug] About PostgresSql snapshot sql - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34797) [Bug] Debezium's database.server.name property should not be hard-coded - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34801) [Bug] An insufficient number of arguments were supplied for the procedure or function cdc.fn_cdc_get_all_changes_ - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34798) [Bug] flink cdc mysql, use datastream to synchronize multiple tables, read full amount of data in a loop - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34804) [Bug] flink cdc missing step to close mysql connection - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34810) [mysql] Add a module to periodically check ip on DNS (for DB Switching) - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34817) [Bug] Can't map utf8mb4 given for characterSetResults to a supported MySQL encoding - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34813) [Bug] Using tidb-cdc to connect to the data source cpu usage is always high - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34809) [mysql] Add notifications to Slack when the Snapshot phase ends or Binlog stream phase begins - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34811) [Bug] [sqlserver cdc] the field "snapshot" is always "false" - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34808) [Bug] Mysql cdc connector connection pool - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34815) [Bug] Sqlserver transaction hung when get change data. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34816) Allow custom Configurations for ConnectionPool - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34814) [Bug] java.lang.NoClassDefFoundError: Could not initialize class org.apache.kafka.connect.json.JsonConverterConfig - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34812) [Bug] During the snapshot phase, projection is not being performed according to the user defined schema. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34806) [Feature][Postgres] Support automatically identify newly added tables - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34818) Add external listeners to obtain split information - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34807) [Feature][mysql] Mysql-cdc source adapts mariadb. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34824) Mysql-connector cdc sourcerecord not have data type information,bug dez record have - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34819) oracle 19c PDB mode SplitFetcher thread 0 received unexpected exception while polling the records - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34820) [postgres] Remove unnecessary schema fresh to improve performance. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34823) [Bug] flink-postgresql-cdc buzy 100% - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34822) [Bug] oracle clob - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34821) [improve] Alter scan.incremental.close-idle-reader.enabled Default is true - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34831) [FLINK-CDC-BASE] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34827) [flink-cdc-pipeline-connectors] Add Implementation of DataSink in Kafka - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34832) [Bug] BinlogOffset's comparative method may be cause incremental snapshot scan data lose - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34829) When will opengauss or gaussdb be supported? - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34828) sql server Limited date synchronization - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34825) [flink-cdc-pipeline-connectors] Add Implementation of DataSource in MongoDB - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34833) [Bug][sqlserver] SqlServer incremental source cannot support exactly-once - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34826) flink-connector-mysql-cdc-2.4.2 when a multi-column primary key index starts with a varchar column, a snapshot chunk can potentially return a large number of rows and cause jvm to OOM. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34830) [3.1][cdc-composer] verify the options of Context for Factory. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34836) [3.1][pipeline-connectors] Add Implementation of DataSink in Paimon. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:03 UTC, 0 replies.
- [jira] [Created] (FLINK-34837) [3.1][cdc-common] Add metric for DataChangeEvent - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:03 UTC, 0 replies.
- [jira] [Created] (FLINK-34834) [cdc-pipeline] Add 'flink-confing' config for pipeline. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:03 UTC, 0 replies.
- [jira] [Created] (FLINK-34835) [cdc-common] Add default value of pipeline parallelism. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:03 UTC, 0 replies.
- [jira] [Created] (FLINK-34838) [3.1][cdc-e2e] Add end to end test for pipeline. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-34839) Flink CDC 3.1.0 Plan - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-34840) [3.1][pipeline-connectors] Add Implementation of DataSink in Iceberg. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34843) [Bug] BinlogSplitReader#pollSplitRecords return finishedSplit when exception occurs - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34846) [Bug][cdc-connectors][cdc-base] Transaction log of high_watermark read twice - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34851) [Feature][Pipeline] Flink CDC pipeline supports transform - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34842) [cdc-connector][db2] Db2 support incremental source - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34848) refactor: some class in flink-connector-mysql-cdc do not inherit from the base class in flink-cdc-base - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34849) Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34845) [3.1][cdc-composer] Support routing sharding tables with the same primary key into one. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34850) [test] Support to execute the (mysql) test cases with custom database deployment - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34847) MySQL database using the compress function, can provide analytic function - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34841) [3.1][pipeline-connectors] Add jdbc pipeline sink - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34844) [3.1][pipeline-connectors] Add pipeline Sink for Pulsar. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34854) [Feature] Optimizing the last chunk with a large amount of data to avoid memory overflow. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34859) [Bug] Oracle cdc in table api does no support server-time-zone option - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34853) [Feature] submit Flink CDC pipeline job to k8s cluster. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34861) [Bug] Inconsistent Kafka shading among cdc connectors - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34858) Support modifying partition keys and primary keys of Schema. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34862) [Bug] oracle-cdc ORA-01371: Complete LogMiner dictionary not found - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34852) [Feature][Pipeline] Flink-CDC-Pipeline support database mapper and table add unified prefix or suffix - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34863) Need report metric or other ways to indicate whether the current is Incremental Snapshot Reading or binlog reading - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34856) [Bug] timeout when Invocating Remote RPC. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34857) [Bug] Can't restore from checkpoint because assignedSplits does not equal to splitFinishedOffsets - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34860) [Bug] Jackson version conflicts among MySQL/TiDB/MongoDB connectors - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34855) [Improve] When using miniCluster, don't check 'FLINK_HOME'. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34871) Oracle add data has error - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34865) [enhancement] [StarRocks] When synchronizing tables using Flink CDC 3.x, is it possible to include the comments of the source table's fields when creating the target table? - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34875) [Feature] CDC Action supports update and delete record (logical deletion) - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34872) [Bug] Mysql is synchronized to doris, and an error is reported when adding or deleting data after dropping column. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34864) [enhancement] [ cdc-connector] [ignore no primary key table] When using regular expressions to synchronize the entire database with Flink CDC, skip tables that do not have a primary key. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34870) [Bug] MongoCDC checkpoint error - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34867) [Bug] [StarRocks] [cdc master branch] Unsupported CDC data type BYTES/VARBINARY - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34866) [Bug] Meet NoClassDefFoundError when add new table in mysql cdc source - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34869) [Bug][mysql] Remove all previous table and add new added table will throw Exception. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34868) [Bug] oracle-cdc cannot read oracle multitenant pdb binlog: ORA-00942: table or view does not exist (LOG_MINING_FLUSH) - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34873) [Bug] After starting Streaming ELT from MySQL to StarRocks using Flink CDC 3.0, the newly created tables are not being synchronized. - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34874) [MongoDB] Support initial.snapshotting.pipeline related configs in table api - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34883) Error on Postgres-CDC using incremental snapshot with UUID column as PK - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34884) [Bug]MySqlSource An error occurred when adding a table to the table.include.list attribute - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34886) Support Sybase database - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34879) [Feature][Pipeline] Flink CDC pipeline transform supports the strategy of schema evolution - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34876) [Feature][Pipeline] Flink CDC pipeline transform supports UDF - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34881) [Feature] Flink CDC Oracle support tables without primary keys and scan newly added tables - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34882) mysql cdc to doris: TIME type converting fail - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34877) [Feature][Pipeline] Flink CDC pipeline transform supports type conversion - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34880) [Feature][Pipeline] SchemeRegistry saves the routing rules used to restore the TransformDataOperator - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34885) mysql to sr pipeline， float value bug - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34888) How to do MySQL to MySQL pipeline - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34887) Data lost after rename table - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34889) Flink CDC may occur binlog can't be find when dynamic added table repeatedly - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34890) io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource :.java.sql.SQLException: ORA-01291: missing log file - posted by "Flink CDC Issue Import (Jira)" <ji...@apache.org> on 2024/03/20 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34891) RemoteStorageScannerTest causes exit 239 - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/20 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34892) Nightly AWS connectors build fails on running python tests - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/03/20 10:05:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX Apicurio-avro format - posted by David Radley <da...@uk.ibm.com> on 2024/03/20 10:09:08 UTC, 5 replies.
- [jira] [Created] (FLINK-34893) Bump Checkstyle to 9+ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/20 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34894) Migrate JoinDependentConditionDerivationRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/20 12:17:00 UTC, 0 replies.
- [VOTE] FLIP-433: State Access on DataStream API V2 - posted by weijie guo <gu...@gmail.com> on 2024/03/20 12:17:47 UTC, 12 replies.
- [jira] [Created] (FLINK-34895) Migrate FlinkRewriteSubQueryRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/20 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34896) Mi - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/20 13:13:00 UTC, 0 replies.
- [ANNOUNCE] Donation Flink CDC into Apache Flink has Completed - posted by Leonard Xu <xb...@gmail.com> on 2024/03/20 13:34:04 UTC, 28 replies.
- [VOTE] FLIP-439: Externalize Kudu Connector from Bahir - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/03/20 14:03:32 UTC, 12 replies.
- [jira] [Created] (FLINK-34897) JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip needs to be enabled again - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/20 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34898) Cannot create named STRUCT with a single field - posted by "Chloe He (Jira)" <ji...@apache.org> on 2024/03/21 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34899) Remove all classes that skip the japicmp check for flink-core-api - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/03/21 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34900) Check compatibility for classes in flink-core-api that skip japicmp - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/03/21 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34901) Improve the performance of the update Postgres database - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/03/21 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/03/21 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables - posted by "shiyuyang (Jira)" <ji...@apache.org> on 2024/03/21 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster. - posted by "ZhengYu Chen (Jira)" <ji...@apache.org> on 2024/03/21 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34905) The default length of CHAR/BINARY data type of Add column DDL - posted by "Qishang Zhong (Jira)" <ji...@apache.org> on 2024/03/21 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34906) Don't start autoscaling when some tasks are not running - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/21 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34907) jobRunningTs should be the timestamp that all tasks are running - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/21 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34908) mysql pipeline to doris and starrocks will lost precision for timestamp - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2024/03/21 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34909) OceanBase事务ID需求 - posted by "xiaotouming (Jira)" <ji...@apache.org> on 2024/03/21 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34910) Can not plan window join without projections - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/03/21 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34911) ChangelogRecoveryRescaleITCase failed fatally with 127 exit code - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/21 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34912) change shade pattern from com.ververica.cdc.connectors.shaded to org.apache.flink.cdc.connectors.shaded - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/03/22 08:01:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-402: Extend ZooKeeper Curator configurations - posted by Alex Nitavsky <al...@gmail.com> on 2024/03/22 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34913) ConcurrentModificationException SubTaskInitializationMetricsBuilder.addDurationMetric - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/03/22 08:15:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-436: Introduce Catalog-related Syntax - posted by Yubin Li <ly...@gmail.com> on 2024/03/22 10:14:21 UTC, 0 replies.
- [jira] [Created] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/03/22 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34915) Introduce `DESCRIBE CATALOG` syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/03/22 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34916) Support `ALTER CATALOG` syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/03/22 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34917) Support enhanced `CREATE CATALOG` syntax - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/03/22 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34918) Introduce the support of catalog for comments - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/03/22 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/22 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34920) ZooKeeperLeaderRetrievalConnectionHandlingTest - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/22 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34921) SystemProcessingTimeServiceTest fails due to missing output - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/22 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34922) Exception History should support multiple Global failures - posted by "Panagiotis Garefalakis (Jira)" <ji...@apache.org> on 2024/03/22 19:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34923) Behavioral discrepancy between `TableEnvironment.execute_sql()` and `TableEnvironment.sql_query()` - posted by "Chloe He (Jira)" <ji...@apache.org> on 2024/03/23 00:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34924) Support partition pushdown for join queries - posted by "Jeyhun Karimov (Jira)" <ji...@apache.org> on 2024/03/23 23:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34925) flinkCDC 抽取SQLSERVER 报错 - posted by "宇宙先生 (Jira)" <ji...@apache.org> on 2024/03/24 10:25:00 UTC, 0 replies.
- [DISCUSS] Migrate Kinesis Table API source to KDS client - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/03/24 15:18:31 UTC, 2 replies.
- [jira] [Created] (FLINK-34926) Adaptive auto parallelism doesn't work for a query - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/03/24 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34927) Translate flink-kubernetes-operator documentation - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/03/25 02:45:00 UTC, 0 replies.
- [DISCUSS] Flink Website Menu Adjustment - posted by gongzhongqiang <go...@apache.org> on 2024/03/25 07:48:00 UTC, 13 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.8.0 released - posted by Maximilian Michels <mx...@apache.org> on 2024/03/25 10:35:31 UTC, 3 replies.
- [RESULT][VOTE] FLIP-439: Externalize Kudu Connector from Bahir - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/03/25 12:12:44 UTC, 0 replies.
- [jira] [Created] (FLINK-34928) FLIP-439: Externalize Kudu Connector from Bahir - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/03/25 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34929) Create "flink-connector-kudu" repository - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/03/25 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34930) Move existing Kudu connector code from Bahir repo to dedicated repo - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/03/25 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34931) Update Kudu connector DataStream Source/Sink implementation - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/03/25 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/03/25 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34933) JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored isn't implemented properly - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/25 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34934) Translation Flink-Kubernetes-Operator document framework construction - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/03/26 02:33:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-433: State Access on DataStream API V2 - posted by weijie guo <gu...@gmail.com> on 2024/03/26 02:51:28 UTC, 0 replies.
- [jira] [Created] (FLINK-34935) TIMESTAMP_LTZ type Unsupported when using JdbcCatalog to read from Postgres - posted by "Du Yuzhou (Jira)" <ji...@apache.org> on 2024/03/26 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34936) Register shared state files to FileMergingSnapshotManager - posted by "Jinzhong Li (Jira)" <ji...@apache.org> on 2024/03/26 06:18:00 UTC, 0 replies.
- Bug report for reading Hive table as streaming source. - posted by Xiaolong Wang <xi...@smartnews.com.INVALID> on 2024/03/26 09:00:16 UTC, 2 replies.
- [jira] [Created] (FLINK-34937) Apache Infra GHA policy update - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/26 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34938) Incorrect behaviour for comparison functions - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/03/26 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34939) Harden TestingLeaderElection - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/26 10:51:00 UTC, 0 replies.
- [DISCUSS] FLIP-XXX: Introduce Flink SQL variables - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/03/26 10:58:30 UTC, 3 replies.
- [jira] [Created] (FLINK-34940) LeaderContender implementations handle invalid state - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/26 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34941) Cannot convert org.apache.flink.streaming.api.CheckpointingMode to org.apache.flink.core.execution.CheckpointingMode - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/26 21:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34942) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/26 23:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34943) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/27 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/03/27 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34945) Support recover shuffle descriptor and partition metrics from tiered storage - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/03/27 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34946) Flink Website Menu Adjustment - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/27 06:17:00 UTC, 0 replies.
- [DISCUSS] FLIP-441: Show the JobType and remove Execution Mode on Flink WebUI - posted by Rui Fan <19...@gmail.com> on 2024/03/27 06:23:14 UTC, 6 replies.
- [jira] [Created] (FLINK-34947) Do not scale down JM in Orphan deletion propagation and reduce timeout - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/03/27 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34948) CDC RowType can not convert to flink type - posted by "Qishang Zhong (Jira)" <ji...@apache.org> on 2024/03/27 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34949) Suggestion notify / skip DDL at data inegration famework v3.X - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2024/03/27 08:30:00 UTC, 0 replies.
- Community Over Code NA 2024 Travel Assistance Applications now open! - posted by Gavin McDonald <gm...@apache.org> on 2024/03/27 08:56:09 UTC, 0 replies.
- [jira] [Created] (FLINK-34950) Disable spotless on Java 21 for connector-shared-utils - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/27 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34951) Flink-ci-mirror stopped running for commits after 22nd of March - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/03/27 09:31:00 UTC, 0 replies.
- [VOTE] FLIP-424: Asynchronous State APIs - posted by Zakelly Lan <za...@gmail.com> on 2024/03/27 10:23:23 UTC, 10 replies.
- [VOTE] FLIP-425: Asynchronous Execution Model - posted by Yanfei Lei <fr...@gmail.com> on 2024/03/27 10:28:02 UTC, 10 replies.
- [VOTE] FLIP-427: Disaggregated state Store - posted by Hangxiang Yu <ma...@gmail.com> on 2024/03/27 10:34:54 UTC, 7 replies.
- [VOTE] FLIP-426: Grouping Remote State Access - posted by Jinzhong Li <li...@gmail.com> on 2024/03/27 10:56:35 UTC, 7 replies.
- [jira] [Created] (FLINK-34952) Flink CDC pipeline supports SourceFunction - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/03/27 11:07:00 UTC, 0 replies.
- [VOTE] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State - posted by Jinzhong Li <li...@gmail.com> on 2024/03/27 11:31:20 UTC, 6 replies.
- [jira] [Created] (FLINK-34953) Add github ci for flink-web to auto commit build files - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/27 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2024/03/27 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34955) Upgrade commons-compress to 1.26.0 - posted by "Shilun Fan (Jira)" <ji...@apache.org> on 2024/03/28 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34956) The config type is wrong for Duration - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/28 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34957) JDBC Autoscaler event handler throws Column 'message' cannot be null - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/03/28 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/03/28 05:45:00 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project - posted by Yu Li <ca...@gmail.com> on 2024/03/28 07:55:21 UTC, 18 replies.
- [jira] [Created] (FLINK-34959) Update old flink-cdc-connectors artifactId - posted by "xleoken (Jira)" <ji...@apache.org> on 2024/03/28 09:11:00 UTC, 0 replies.
- [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP) - posted by Yuan Mei <yu...@gmail.com> on 2024/03/28 10:41:48 UTC, 6 replies.
- [jira] [Created] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs - posted by "Kunal Rohitas (Jira)" <ji...@apache.org> on 2024/03/28 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34961) GitHub Actions statistcs can be monitored per workflow name - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/03/28 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata - posted by "Yubiao Feng (Jira)" <ji...@apache.org> on 2024/03/28 17:08:00 UTC, 0 replies.
- Iceberg table maintenance - posted by Péter Váry <pe...@gmail.com> on 2024/03/28 17:59:49 UTC, 2 replies.
- [jira] [Created] (FLINK-34963) Compilation error in ProcessFunctionTestHarnesses - posted by "Ryan Skraba (Jira)" <ji...@apache.org> on 2024/03/29 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34964) ScheduledTask leak in registering the processing timer - posted by "zoucao (Jira)" <ji...@apache.org> on 2024/03/29 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34965) optimize code of ServiceType - posted by "bai sui (Jira)" <ji...@apache.org> on 2024/03/29 09:03:00 UTC, 0 replies.
- [VOTE] FLIP-437: Support ML Models in Flink SQL - posted by Hao Li <hl...@confluent.io.INVALID> on 2024/03/29 16:30:24 UTC, 0 replies.
- [DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/03/29 22:45:12 UTC, 0 replies.
- [jira] [Created] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/03/30 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34967) Update Website copyright footer to 2024 - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/03/30 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34968) Update flink-web copyright to 2024 - posted by "Yu Chen (Jira)" <ji...@apache.org> on 2024/03/30 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19 - posted by "skymilong (Jira)" <ji...@apache.org> on 2024/03/30 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34970) Translate architecture documents into Chinese - posted by "Caican Cai (Jira)" <ji...@apache.org> on 2024/03/31 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-34971) Add the function of History Server cleaning job archives regularly - posted by "dengxaing (Jira)" <ji...@apache.org> on 2024/03/31 11:26:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-425: Asynchronous Execution Model - posted by Yanfei Lei <fr...@gmail.com> on 2024/03/31 13:10:15 UTC, 0 replies.
- [jira] [Created] (FLINK-34972) MigrationTestsSnapshotGenerator does not work properly for all subclasses of SnapshotMigrationTestBase - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/03/31 15:57:00 UTC, 0 replies.