[
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:50 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 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)
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 whereas the parallelism 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)
