github-actions[bot] commented on PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2552499777
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3471: [Kafka]Kafka sink
numRecordsOutByIncremental metrics
URL: https://github.com/apache/flink-cdc/pull/3471
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
github-actions[bot] commented on PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2484425245
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2359649772
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
ChengJie1053 commented on PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2232291457
> I have two points to be discussed.
>
> 1. Does 'numRecordsOutByIncremental' refer to the incremental phase here?
We don't have a way to determine whether we have reached th
lvyanquan commented on PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#issuecomment-2232251987
I have two points to be discussed.
1. Does 'numRecordsOutByIncremental' refer to the incremental phase here? We
don't have a way to determine whether we have reached this phase in t
ChengJie1053 commented on code in PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#discussion_r1677354475
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaSinkWriteMetrics.java
yuxiqian commented on code in PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#discussion_r1677349369
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaSinkWriteMetrics.java:
##
ChengJie1053 opened a new pull request, #3471:
URL: https://github.com/apache/flink-cdc/pull/3471
numRecordsOutByIncremental metrics collects incremental statistics
numRecordsOutByIncremental has three metrics, respectively is
numRecordsOutByIncrementalInsert, numRecordsOutByIncrement
