Qingsheng Ren comments

Results 117 comments of


                                            Qingsheng Ren

[FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle

A successful run: https://renqs.visualstudio.com/Apache%20Flink/_build/results?buildId=417&view=results

[BP-1.16][FLINK-28890][table] Fix semantic of latestLoadTime in caching lookup function

The CI failed because of an unrelated issue FLINK-29315. Merging to release-1.16

[FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCase + reset resource counter before each test

The CI failed because of an unrelated issue FLINK-29315. Merging to master

[FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCas…

The CI failed because of an unrelated issue FLINK-29315. Merging to release-1.16

ORA-00600: internal error code, arguments: [krvrdccs10], [], [], [], [], [], [], [], [], [], [], []

@hehetown Looks like an issue inside `LogMinerStreamingChangeEventSource` from Debezium Oracle connector. Could you check if there's any information about this exception in Debezium community?

[FLINK-28475] [Connector/kafka] stopping offset can be 0

@leozhangsr Looks like the commit message is not consistent with the one on master branch and not quite descriptive. Could you update the commit message? You can just copy &...

[FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

Thanks for the PR @sap1ens . As this is adding a new public API for Kafka sink, I think at least a discussion is required in the mailing list and...

监听oracle erp的归档日志，导致日志爆炸性增涨

@szgyh I'm not quite familiar with Oracle but could you try to config some log cleanup strategies to prune useless log periodically?

flink-sql-connector-oracle-cdc-2.2.0 report ORA-01292

@luoyuxia Could you take a look on this issue? Thanks

[vitess] Add vitess cdc connector

Hey @s-gelazevicius, thanks a lot for the awesome work on this Vitess connector! As we are approaching the feature freeze of Flink CDC version 2.4.0, we are going to make...