Thorne created FLINK-36165:
--
Summary: Support obtaining snapshot data of the scope
Key: FLINK-36165
URL: https://issues.apache.org/jira/browse/FLINK-36165
Project: Flink
Issue Type: Improvement
tchivs created FLINK-36164:
--
Summary: JdbcIncrementalSource CheckPoint Timeout Due to
Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned
PostgreSQL Table
Key: FLINK-36164
URL: https://issues.apach
Hongshun Wang created FLINK-36163:
-
Summary: Kafka cdc pipeline source supports protobuf format.
Key: FLINK-36163
URL: https://issues.apache.org/jira/browse/FLINK-36163
Project: Flink
Issue T
Hi everyone,
I am working on the Iceberg Connector's Table Maintenance function [1], and
we plan to utilize the SinkV2 SupportsPostCommitTopology (formerly known as
WithPostCommitTopology) to start the compaction after several commits.
With Steven Zhen Wu were debating [2] the expectations about t
Gyula Fora created FLINK-36162:
--
Summary: Remove flinkStateSnapshotReference and namespace from
FlinkStateSnapshot jobReference
Key: FLINK-36162
URL: https://issues.apache.org/jira/browse/FLINK-36162
Pro
Wolff Bock von Wuelfingen created FLINK-36161:
-
Summary: Integration Test Example uses deprecated SinkFunction
Key: FLINK-36161
URL: https://issues.apache.org/jira/browse/FLINK-36161
Projec
zhuanshenbsj1 created FLINK-36160:
-
Summary: Support hive advanced configuration
Key: FLINK-36160
URL: https://issues.apache.org/jira/browse/FLINK-36160
Project: Flink
Issue Type: Improvement
xingbe created FLINK-36159:
--
Summary: FLIP-470: Support Adaptive Broadcast Join
Key: FLINK-36159
URL: https://issues.apache.org/jira/browse/FLINK-36159
Project: Flink
Issue Type: New Feature
