leCheckpointFailureNumber(tolerableDeclinedCheckpointNumber);
Best
Yun Tang
From: jose farfan
Sent: Wednesday, January 15, 2020 23:21
To: ouywl
Cc: user ; user...@flink.apache.org
Subject: Re: When I use flink 1.9.1 and produce data to Kafka 1.1.1, The
streamTask checkpoint err
Hi
I have the same issue.
BR
Jose
On Thu, 9 Jan 2020 at 10:28, ouywl wrote:
> Hi all:
> When I use flink 1.9.1 and produce data to Kafka 1.1.1. the error was
> happen as* log-1,code is::*
>
> input.addSink(
> new FlinkKafkaProducer(
> parameterTool.getRequired("bootstra
Hi all: When I use flink 1.9.1 and produce data to Kafka 1.1.1. the error was happen as log-1,code is::input.addSink(new FlinkKafkaProducer(parameterTool.getRequired("bootstrap.servers"),parameterTool.getRequired("output-topic"),
