File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/internal Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1217,8 +1217,8 @@ class SQLConf extends Serializable with Logging {
12171217 ParquetOutputTimestampType .TIMESTAMP_MILLIS
12181218 } else if (! isOutputTimestampTypeSet && isParquetTimestampAsINT96) {
12191219 // If PARQUET_OUTPUT_TIMESTAMP_TYPE is not set and PARQUET_TIMESTAMP_AS_INT96 is set,
1220- // respect PARQUET_TIMESTAMP_AS_INT96 and use TIMESTAMP_MILLIS .
1221- ParquetOutputTimestampType .TIMESTAMP_MILLIS
1220+ // respect PARQUET_TIMESTAMP_AS_INT96 and use INT96 .
1221+ ParquetOutputTimestampType .INT96
12221222 } else {
12231223 // Otherwise, PARQUET_OUTPUT_TIMESTAMP_TYPE has higher priority.
12241224 ParquetOutputTimestampType .withName(getConf(PARQUET_OUTPUT_TIMESTAMP_TYPE ))
You can’t perform that action at this time.
0 commit comments