Hi,
In short, [1] means whether the job will trigger checkpoints, and [2] means
which operators will take action when checkpoints are triggered.
If use ExampleCountSource, flink-streaming-java should be a dependency in
pom.xml and classes such as ListState, ListStateDescriptor,
FunctionInitial
2021 at 8:25 AM Smile@LETTers wrote:
Hi Matthias,
Sorry for my miss leading. I mean kafka-schema-serializer rather than
kafka-avro-serializer.
io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe is in
kafka-schema-serializer and kafka-schema-serializer should be a dependency of
kafka-avro-
he dependency you're talking about is already part of
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml. It also has
the correct scope set both in master and release-1.12.
Best,
Matthias
On Fri, Jan 22, 2021 at 10:04 AM Smile@LETTers wrote:
Yes, I've tried from both
uild is failing when you build Flink from the root
directory (not calling maven from within a maven module?)
On Tue, Jan 19, 2021 at 11:19 AM Smile@LETTers wrote:
Hi,
I got an error when tried to compile & package Flink (version 1.12 & current
master).
It can be reproduced by run &
Hi,
I got an error when tried to compile & package Flink (version 1.12 & current
master).
It can be reproduced by run 'mvn clean test' under
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka.
It seems that a necessary dependency for test scope was missing and some
classes can not be
