fix wrong config

apache · May 1, 2024 · c457600 · c457600
1 parent 9ac72ef
commit c457600
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/common/src/main/java/org/apache/comet/parquet/Utils.java b/common/src/main/java/org/apache/comet/parquet/Utils.java
@@ -32,7 +32,8 @@ public static ColumnReader getColumnReader(
       DataType type, ColumnDescriptor descriptor, int batchSize, SQLConf conf) {
     boolean useDecimal128 = (Boolean) CometConf.COMET_USE_DECIMAL_128().get(conf);
     boolean useLazyMaterialization = (Boolean) CometConf.COMET_USE_LAZY_MATERIALIZATION().get(conf);
-    boolean useLegacyDateTimestamp = (Boolean) CometConf.COMET_USE_DECIMAL_128().get(conf);
+    boolean useLegacyDateTimestamp =
+        (Boolean) CometConf.COMET_EXCEPTION_ON_LEGACY_DATE_TIMESTAMP().get(conf);
     return getColumnReader(
         type, descriptor, batchSize, useDecimal128, useLazyMaterialization, useLegacyDateTimestamp);
   }