diff --git a/api/src/main/java/org/apache/iceberg/types/Conversions.java b/api/src/main/java/org/apache/iceberg/types/Conversions.java index 421333f9f5..827f311ec1 100644 --- a/api/src/main/java/org/apache/iceberg/types/Conversions.java +++ b/api/src/main/java/org/apache/iceberg/types/Conversions.java @@ -34,6 +34,7 @@ import org.apache.iceberg.expressions.Literal; import org.apache.iceberg.util.UUIDUtil; + public class Conversions { private Conversions() { @@ -72,7 +73,8 @@ public static Object fromPartitionString(Type type, String asString) { case DATE: return Literal.of(asString).to(Types.DateType.get()).value(); case TIMESTAMP: - return Literal.of(asString).to(Types.TimestampType.withoutZone()).value(); + final String isoFormatTs = asString.replaceFirst(" ", "T"); + return Literal.of(isoFormatTs).to(Types.TimestampType.withoutZone()).value(); default: throw new UnsupportedOperationException( "Unsupported type for fromPartitionString: " + type);