fapaul commented on a change in pull request #17870:
URL: https://github.com/apache/flink/pull/17870#discussion_r756637224
##########
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java
##########
@@ -18,10 +18,11 @@
package org.apache.flink.streaming.connectors.kafka.table;
+import java.io.Serializable;
import java.util.Objects;
/** Sink buffer flush configuration. */
-public class SinkBufferFlushMode {
+public class SinkBufferFlushMode implements Serializable {
Review comment:
Objects of this class are passed to the `ReducingUpsertSink` which is
instantiated by the jobmanager and needs to be serialized before it is sent to
the taskmanagers to create the writer instances.
In general, classes that are passed to the sink should be serializable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
