[jira] [Created] (FLINK-35715) Mysql Source support schema cache to deserialize record

Hongshun Wang created FLINK-35715: - Summary: Mysql Source support schema cache to deserialize record Key: FLINK-35715 URL: https://issues.apache.org/jira/browse/FLINK-35715 Project: Flink

[jira] [Created] (FLINK-35693) Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

Hongshun Wang created FLINK-35693: - Summary: Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions Key: FLINK-35693 URL:

[jira] [Created] (FLINK-35567) CDC BinaryWriter cast NullableSerializerWrapper error

Hongshun Wang created FLINK-35567: - Summary: CDC BinaryWriter cast NullableSerializerWrapper error Key: FLINK-35567 URL: https://issues.apache.org/jira/browse/FLINK-35567 Project: Flink

[jira] [Created] (FLINK-35524) Clear connections pools when reader exist.

Hongshun Wang created FLINK-35524: - Summary: Clear connections pools when reader exist. Key: FLINK-35524 URL: https://issues.apache.org/jira/browse/FLINK-35524 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35387) PG CDC source support heart beat

Hongshun Wang created FLINK-35387: - Summary: PG CDC source support heart beat Key: FLINK-35387 URL: https://issues.apache.org/jira/browse/FLINK-35387 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19

Hongshun Wang created FLINK-35385: - Summary: upgrader flink dependency version to 1.19 Key: FLINK-35385 URL: https://issues.apache.org/jira/browse/FLINK-35385 Project: Flink Issue Type:

[jira] [Created] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect

Hongshun Wang created FLINK-35349: - Summary: Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect Key: FLINK-35349 URL: https://issues.apache.org/jira/browse/FLINK-35349

[jira] [Created] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter

Hongshun Wang created FLINK-35344: - Summary: Move same code from multiple subclasses to JdbcSourceChunkSplitter Key: FLINK-35344 URL: https://issues.apache.org/jira/browse/FLINK-35344 Project: Flink

[jira] [Created] (FLINK-35327) SQL Explain show push down condition

Hongshun Wang created FLINK-35327: - Summary: SQL Explain show push down condition Key: FLINK-35327 URL: https://issues.apache.org/jira/browse/FLINK-35327 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once

Hongshun Wang created FLINK-35281: - Summary: FlinkEnvironmentUtils#addJar add each jar only once Key: FLINK-35281 URL: https://issues.apache.org/jira/browse/FLINK-35281 Project: Flink Issue

[jira] [Created] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString

Hongshun Wang created FLINK-35234: - Summary: Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString Key: FLINK-35234 URL:

[jira] [Created] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

Hongshun Wang created FLINK-35149: - Summary: Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink Key: FLINK-35149 URL: https://issues.apache.org/jira/browse/FLINK-35149

[jira] [Created] (FLINK-35143) Expose newly added tables capture in mysql pipeline connector

Hongshun Wang created FLINK-35143: - Summary: Expose newly added tables capture in mysql pipeline connector Key: FLINK-35143 URL: https://issues.apache.org/jira/browse/FLINK-35143 Project: Flink

[jira] [Created] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles.

Hongshun Wang created FLINK-35129: - Summary: Postgres source commits the offset after every multiple checkpoint cycles. Key: FLINK-35129 URL: https://issues.apache.org/jira/browse/FLINK-35129

[jira] [Created] (FLINK-35128) Re-calculate the starting binlog offset after the new table added

Hongshun Wang created FLINK-35128: - Summary: Re-calculate the starting binlog offset after the new table added Key: FLINK-35128 URL: https://issues.apache.org/jira/browse/FLINK-35128 Project: Flink

[jira] [Created] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions

Hongshun Wang created FLINK-35121: - Summary: CDC pipeline connector should verify requiredOptions and optionalOptions Key: FLINK-35121 URL: https://issues.apache.org/jira/browse/FLINK-35121 Project:

[jira] [Created] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.

Hongshun Wang created FLINK-35093: - Summary: Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot. Key: FLINK-35093 URL:

[jira] [Created] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector

Hongshun Wang created FLINK-35071: - Summary: Remove dependency on flink-shaded from cdc source connector Key: FLINK-35071 URL: https://issues.apache.org/jira/browse/FLINK-35071 Project: Flink

[jira] [Created] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

Hongshun Wang created FLINK-35067: - Summary: Support metadata 'op_type' virtual column for Postgres CDC Connector. Key: FLINK-35067 URL: https://issues.apache.org/jira/browse/FLINK-35067 Project:

[jira] [Created] (FLINK-34952) Flink CDC pipeline supports SourceFunction

Hongshun Wang created FLINK-34952: - Summary: Flink CDC pipeline supports SourceFunction Key: FLINK-34952 URL: https://issues.apache.org/jira/browse/FLINK-34952 Project: Flink Issue Type:

[jira] [Created] (FLINK-34724) Fix broken web link in document of legacy Flink CDC Sources

Hongshun Wang created FLINK-34724: - Summary: Fix broken web link in document of legacy Flink CDC Sources Key: FLINK-34724 URL: https://issues.apache.org/jira/browse/FLINK-34724 Project: Flink

[jira] [Created] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support.

Hongshun Wang created FLINK-34690: - Summary: If data from upstream is decimal and primary key , starrocks sink will not support. Key: FLINK-34690 URL: https://issues.apache.org/jira/browse/FLINK-34690

[jira] [Created] (FLINK-34688) CDC framework split snapshot chunks asynchronously

Hongshun Wang created FLINK-34688: - Summary: CDC framework split snapshot chunks asynchronously Key: FLINK-34688 URL: https://issues.apache.org/jira/browse/FLINK-34688 Project: Flink Issue

[jira] [Created] (FLINK-34666) Keep assigned splits in order to fix wrong meta group calculation

Hongshun Wang created FLINK-34666: - Summary: Keep assigned splits in order to fix wrong meta group calculation Key: FLINK-34666 URL: https://issues.apache.org/jira/browse/FLINK-34666 Project: Flink

[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

Hongshun Wang created FLINK-34634: - Summary: 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 Key: FLINK-34634

[jira] [Created] (FLINK-34196) FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.

Hongshun Wang created FLINK-34196: - Summary: FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving. Key: FLINK-34196 URL: https://issues.apache.org/jira/browse/FLINK-34196 Project: Flink

[jira] [Created] (FLINK-34129) correct writing: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

Hongshun Wang created FLINK-34129: - Summary: correct writing: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired Key: FLINK-34129 URL:

[jira] [Created] (FLINK-33465) Make SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving.

Hongshun Wang created FLINK-33465: - Summary: Make SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving. Key: FLINK-33465 URL: https://issues.apache.org/jira/browse/FLINK-33465

[jira] [Created] (FLINK-32668) fix up watchdog timeout bug in common.sh(e2e test) ?

Hongshun Wang created FLINK-32668: - Summary: fix up watchdog timeout bug in common.sh(e2e test) ? Key: FLINK-32668 URL: https://issues.apache.org/jira/browse/FLINK-32668 Project: Flink Issue

[jira] [Created] (FLINK-32591) Update document of Kafka Source: Enable Dynamic Partition Discovery by Default in Kafka Source

Hongshun Wang created FLINK-32591: - Summary: Update document of Kafka Source: Enable Dynamic Partition Discovery by Default in Kafka Source Key: FLINK-32591 URL: https://issues.apache.org/jira/browse/FLINK-32591

[jira] [Created] (FLINK-32021) Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.

Hongshun Wang created FLINK-32021: - Summary: Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer. Key: FLINK-32021 URL: https://issues.apache.org/jira/browse/FLINK-32021

[jira] [Created] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

Hongshun Wang created FLINK-32020: - Summary: Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288 Key: FLINK-32020 URL: https://issues.apache.org/jira/browse/FLINK-32020

[jira] [Created] (FLINK-32019) EARLIEST offset strategy for partitions discoveried later based on FLIP-288

Hongshun Wang created FLINK-32019: - Summary: EARLIEST offset strategy for partitions discoveried later based on FLIP-288 Key: FLINK-32019 URL: https://issues.apache.org/jira/browse/FLINK-32019

[jira] [Created] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

Hongshun Wang created FLINK-31953: - Summary: FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source Key: FLINK-31953 URL: https://issues.apache.org/jira/browse/FLINK-31953 Project:

[jira] [Created] (FLINK-31378) Documentation fails to build due to lack of package

Hongshun Wang created FLINK-31378: - Summary: Documentation fails to build due to lack of package Key: FLINK-31378 URL: https://issues.apache.org/jira/browse/FLINK-31378 Project: Flink Issue

[jira] [Created] (FLINK-31208) KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

Hongshun Wang created FLINK-31208: - Summary: KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) Key: FLINK-31208 URL: https://issues.apache.org/jira/browse/FLINK-31208 Project: