JunRuiLee commented on code in PR #24129:
URL: https://github.com/apache/flink/pull/24129#discussion_r1457214689
##########
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##########
@@ -666,6 +666,18 @@ public boolean isForceKryoEnabled() {
return configuration.get(PipelineOptions.FORCE_KRYO);
}
+ public void enableForceAvroKryo() {
+ setForceAvroKryo(true);
+ }
+
+ private void setForceAvroKryo(boolean forceAvroKryo) {
+ configuration.set(PipelineOptions.FORCE_KRYO_AVRO, forceAvroKryo);
+ }
+
+ public Optional<Boolean> isForceAvroKryoEnable() {
+ return configuration.getOptional(PipelineOptions.FORCE_KRYO_AVRO);
+ }
+
Review Comment:
I am curious why there are three public methods introduced that were not
included in FLIP-398.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
