Skip to content

Commit 3afb048

Browse files
authored
Revert "Fix schema mapping for dates"
1 parent 2d68623 commit 3afb048

File tree

3 files changed

+2
-76
lines changed

3 files changed

+2
-76
lines changed

src/Storages/ObjectStorage/DataLakes/Iceberg/SchemaProcessor.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ DataTypePtr IcebergSchemaProcessor::getSimpleType(const String & type_name)
234234
if (type_name == f_double)
235235
return std::make_shared<DataTypeFloat64>();
236236
if (type_name == f_date)
237-
return std::make_shared<DataTypeDate32>();
237+
return std::make_shared<DataTypeDate>();
238238
if (type_name == f_time)
239239
return std::make_shared<DataTypeInt64>();
240240
if (type_name == f_timestamp)

tests/integration/test_storage_iceberg_with_spark/test_dates.py

Lines changed: 0 additions & 74 deletions
This file was deleted.

tests/integration/test_storage_iceberg_with_spark/test_schema_inference.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ def test_schema_inference(started_cluster_iceberg_with_spark, format_version, st
6161
["decimalC1", "Nullable(Decimal(10, 3))"],
6262
["decimalC2", "Nullable(Decimal(20, 10))"],
6363
["decimalC3", "Nullable(Decimal(38, 30))"],
64-
["dateC", "Nullable(Date32)"],
64+
["dateC", "Nullable(Date)"],
6565
["timestampC", "Nullable(DateTime64(6, 'UTC'))"],
6666
["stringC", "Nullable(String)"],
6767
["binaryC", "Nullable(String)"],

0 commit comments

Comments
 (0)