update default refresh policy to wait_for

Signed-off-by: Peng Huo <[email protected]>
opensearch-project · Nov 9, 2023 · cae0dbe · cae0dbe
1 parent d5e6738
commit cae0dbe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...t-spark-integration/src/main/scala/org/apache/spark/sql/flint/config/FlintSparkConf.scala b/...t-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()