[
https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409475#comment-17409475
]
Matthias edited comment on FLINK-23850 at 9/3/21, 12:51 PM:
------------------------------------------------------------
The test issue mentioned above was resolved by enabling checkpoints after a
task finished
({{config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH,
true);}},
[FLIP-147|https://cwiki.apache.org/confluence/display/FLINK/FLIP-147%3A+Support+Checkpoints+After+Tasks+Finished]).
The simple job was executed through one task only. 5 tasks were in state
{{FINISHED}}. The parallelism of the job was set to 6. Either reducing the
parallelism or enabling the already mentioned flag would result in data being
processed. (y)
was (Author: mapohl):
The test issue mentioned above was resolved by enabling checkpoints after a
task finished
({{config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH,
true);}},
[FLIP-147|https://cwiki.apache.org/confluence/display/FLINK/FLIP-147%3A+Support+Checkpoints+After+Tasks+Finished]).
The simple job was executed through one task only. 5 tasks were in stated
{{FINISHED}}. The parallelism of the job was set to 6. Either reducing the
parallelism or enabling the already mentioned flag would result in data being
processed. (y)
> Test Kafka table connector with new runtime provider
> ----------------------------------------------------
>
> Key: FLINK-23850
> URL: https://issues.apache.org/jira/browse/FLINK-23850
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Kafka
> Affects Versions: 1.14.0
> Reporter: Qingsheng Ren
> Assignee: Matthias
> Priority: Blocker
> Labels: release-testing
> Fix For: 1.14.0
>
>
> The runtime provider of Kafka table connector has been replaced with new
> KafkaSource and KafkaSink. The table connector requires to be tested to make
> sure nothing is surprised to Table/SQL API users.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
