zhangjun created FLINK-14077:
Summary: get java.util.ConcurrentModificationException when push
metrics to PushGateway
Key: FLINK-14077
URL: https://issues.apache.org/jira/browse/FLINK-14077
Project:
Thanks Jark for being the release manager and the great work! Also thanks to
everyone who has contributed to this release.
Regards,
Dian
> 在 2019年9月14日，上午3:24，Till Rohrmann 写道：
>
> Thanks Jark for being our release manager and thanks to everyone who has
> contributed.
>
> Cheers,
> Till
>
Jeffrey Martin created FLINK-14076:
--
Summary: 'ClassNotFoundException: KafkaException' on Flink v1.9 w/
checkpointing
Key: FLINK-14076
URL: https://issues.apache.org/jira/browse/FLINK-14076
Project:
Thanks Konstantin,
Refining this a little bit.. All the checkpoints for all the subtasks
upstream of the sink complete in seconds. Most of the subtasks of the sink
itself also complete in seconds other than these very few "slow" ones. So,
somehow we are taking at worst 29 minutes to clear the
Hi,
I was going through the Flink Sql client code and came through a
flow where we are loading flink-conf.yaml in the configuration object as
prerequisite for the SQL client to start. I can see that the configuration file
has properties pertaining to the Flink cluster. As far as
Hi Jamie,
I think, your interpretation is correct. It takes a long time until the
first barrier reaches the "slow" subtask and in case of the screenshot
another 3m 22s until the last barrier reaches the subtask. Regarding the
total amount of data: depending on the your checkpoint configuration
