From cae0dbef7ea18f0b070f1782a1dca4010decf964 Mon Sep 17 00:00:00 2001 From: Peng Huo Date: Wed, 8 Nov 2023 22:03:06 -0800 Subject: [PATCH] update default refresh policy to wait_for Signed-off-by: Peng Huo --- .../org/apache/spark/sql/flint/config/FlintSparkConf.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flint-spark-integration/src/main/scala/org/apache/spark/sql/flint/config/FlintSparkConf.scala b/flint-spark-integration/src/main/scala/org/apache/spark/sql/flint/config/FlintSparkConf.scala index b7b5a1f76..3edeaa01a 100644 --- a/flint-spark-integration/src/main/scala/org/apache/spark/sql/flint/config/FlintSparkConf.scala +++ b/flint-spark-integration/src/main/scala/org/apache/spark/sql/flint/config/FlintSparkConf.scala @@ -99,7 +99,7 @@ object FlintSparkConf { val REFRESH_POLICY = FlintConfig("spark.datasource.flint.write.refresh_policy") .datasourceOption() .doc("refresh_policy, possible value are NONE(false), IMMEDIATE(true), WAIT_UNTIL(wait_for)") - .createWithDefault("false") + .createWithDefault(FlintOptions.DEFAULT_REFRESH_POLICY) val SCROLL_SIZE = FlintConfig("spark.datasource.flint.read.scroll_size") .datasourceOption()