Re: CDC from Oracle database reading directly logs - integration with OpenLogReplicator

Hey Adam, all, Just came across this thread, still remembering the good conversations we had around this while I was working on Debezium full-time :) Personally, I still believe the best way forward with this would be to add support to the Debezium connector for Oracle so it can ingest changes fr

Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID

Hey Joao, Thanks for this FLIP! One question on the proposed interface changes: is it expected that the configuration is *mutated* via the InitContext passed to Sink::createWriter()? If that's not the case, how about establishing a read-only contract representing the current configuration and pass

Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (non-binding) Best, --Gunnar Am Mo., 15. Jan. 2024 um 18:24 Uhr schrieb Fabian Hueske : > +1 (binding) > > Cheers, Fabian > > > Timo Walther schrieb am Mo., 15. Jan. 2024, 16:00: > > > +1 (binding) > > > > Cheers, > > Timo > > > > > > On 09.01.24 10:58, xiangyu feng wrote: > > > +1 (non-bi

[jira] [Created] (FLINK-32307) Incorrect docs for default behavior of "scan.startup.mode" option

Gunnar Morling created FLINK-32307: -- Summary: Incorrect docs for default behavior of "scan.startup.mode" option Key: FLINK-32307 URL: https://issues.apache.org/jira/browse/FLINK-32307 Proj

[jira] [Created] (FLINK-30443) Expand list of sensitive keys

Gunnar Morling created FLINK-30443: -- Summary: Expand list of sensitive keys Key: FLINK-30443 URL: https://issues.apache.org/jira/browse/FLINK-30443 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30454) Inconsistent class hierarchy in TaskIOMetricGroup

Gunnar Morling created FLINK-30454: -- Summary: Inconsistent class hierarchy in TaskIOMetricGroup Key: FLINK-30454 URL: https://issues.apache.org/jira/browse/FLINK-30454 Project: Flink Issue

[jira] [Created] (FLINK-30455) Avoid "cleaning" of java.lang.String in ClosureCleaner

Gunnar Morling created FLINK-30455: -- Summary: Avoid "cleaning" of java.lang.String in ClosureCleaner Key: FLINK-30455 URL: https://issues.apache.org/jira/browse/FLINK-30455 Proj

[jira] [Created] (FLINK-30478) Don't depend on IPAddressUtil

Gunnar Morling created FLINK-30478: -- Summary: Don't depend on IPAddressUtil Key: FLINK-30478 URL: https://issues.apache.org/jira/browse/FLINK-30478 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-30636) Typo fix: "to to" -> "to"

Gunnar Morling created FLINK-30636: -- Summary: Typo fix: "to to" -> "to" Key: FLINK-30636 URL: https://issues.apache.org/jira/browse/FLINK-30636 Project: Flink Iss

[jira] [Created] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector

Gunnar Morling created FLINK-37691: -- Summary: Can't consume changelog stream with upsert-kafka connector Key: FLINK-37691 URL: https://issues.apache.org/jira/browse/FLINK-37691 Project: