Hongshun Wang created FLINK-36844:
-
Summary: Postgres CDC document add mapping from postgres
timestamp_tz to flink timestamp ltz
Key: FLINK-36844
URL: https://issues.apache.org/jira/browse/FLINK-36844
Hongshun Wang created FLINK-36618:
-
Summary: Improve PostgresDialect.discoverDataCollections to reduce
the start time of Postgres CDC
Key: FLINK-36618
URL: https://issues.apache.org/jira/browse/FLINK-36618
Hongshun Wang created FLINK-36609:
-
Summary: Protobuf Format not support proto3
Key: FLINK-36609
URL: https://issues.apache.org/jira/browse/FLINK-36609
Project: Flink
Issue Type: Improvement
Hongshun Wang created FLINK-36174:
-
Summary: CDC yaml without pipeline will throw NullPointException
Key: FLINK-36174
URL: https://issues.apache.org/jira/browse/FLINK-36174
Project: Flink
Iss
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
Hongshun Wang created FLINK-36150:
-
Summary: tables.exclude is not valid if
scan.binlog.newly-added-table.enabled is true.
Key: FLINK-36150
URL: https://issues.apache.org/jira/browse/FLINK-36150
Proje
Hongshun Wang created FLINK-36094:
-
Summary: CDC SchemaRegistryRequestHandler should throw exception
which is not SchemaEvolveException
Key: FLINK-36094
URL: https://issues.apache.org/jira/browse/FLINK-36094
Hongshun Wang created FLINK-36076:
-
Summary: Hotfix: Set isSchemaChangeApplying as
isSchemaChangeApplying for thread safe.
Key: FLINK-36076
URL: https://issues.apache.org/jira/browse/FLINK-36076
Proje
Hongshun Wang created FLINK-36036:
-
Summary: CDC remove unused dependency jar from calcite-core
Key: FLINK-36036
URL: https://issues.apache.org/jira/browse/FLINK-36036
Project: Flink
Issue Ty
Hongshun Wang created FLINK-36023:
-
Summary: Flink K8S Native Application Mode add wrong jar url.
Key: FLINK-36023
URL: https://issues.apache.org/jira/browse/FLINK-36023
Project: Flink
Issue
Hongshun Wang created FLINK-36007:
-
Summary: cdc load and register factory in once search
Key: FLINK-36007
URL: https://issues.apache.org/jira/browse/FLINK-36007
Project: Flink
Issue Type: Im
Hongshun Wang created FLINK-35994:
-
Summary: CDC pipeline use SavepointRestoreSettings in flink config
flile as a fallback strategy.
Key: FLINK-35994
URL: https://issues.apache.org/jira/browse/FLINK-35994
Hongshun Wang created FLINK-35968:
-
Summary: Remove flink-cdc-runtime depedency from connectors
Key: FLINK-35968
URL: https://issues.apache.org/jira/browse/FLINK-35968
Project: Flink
Issue Ty
Hongshun Wang created FLINK-35859:
-
Summary: [flink-cdc] Fix: The assigner is not ready to offer
finished split information, this should not be called
Key: FLINK-35859
URL: https://issues.apache.org/jira/browse/FL
Hongshun Wang created FLINK-35849:
-
Summary: [flink-cdc] Use expose_snapshot to read snapshot of
postgres cdc connector.
Key: FLINK-35849
URL: https://issues.apache.org/jira/browse/FLINK-35849
Project
Hongshun Wang created FLINK-35760:
-
Summary: [docs] Add scan.newly-added-table.enabled to docs.
Key: FLINK-35760
URL: https://issues.apache.org/jira/browse/FLINK-35760
Project: Flink
Issue Ty
Hongshun Wang created FLINK-35759:
-
Summary: [docs] Add 'scan.incremental.snapshot.backfill.skip' to
docs.
Key: FLINK-35759
URL: https://issues.apache.org/jira/browse/FLINK-35759
Project: Flink
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
Iss
Hongshun Wang created FLINK-35693:
-
Summary: Change variable specificOffsetFile, specificOffsetPos and
startupTimestampMillis to Offset in StartupOptions
Key: FLINK-35693
URL: https://issues.apache.org/jira/browse
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
Issu
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
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
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: Impro
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
P
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
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
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 T
Hongshun Wang created FLINK-35234:
-
Summary: Fix NullPointerException of
org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Key: FLINK-35234
URL: https://issues.apache.org/jira/browse/FLI
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
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
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
Project:
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
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: F
Hongshun Wang created FLINK-35093:
-
Summary: Postgres source connector support SPECIFIC_OFFSETS start
up mode from an existed replication slot.
Key: FLINK-35093
URL: https://issues.apache.org/jira/browse/FLINK-350
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
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: Fl
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: Imp
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
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
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 Ty
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
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
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
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: https://issues.apache.org/jira/browse/F
Hongshun Wang created FLINK-33465:
-
Summary: Make SingleThreadFetcherManager and
FutureCompletingBlockingQueue as PublicEvolving.
Key: FLINK-33465
URL: https://issues.apache.org/jira/browse/FLINK-33465
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
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
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
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
Pro
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
Project
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: Fl
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 T
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: Fl
53 matches
Mail list logo
