Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
None
-
None
-
3
Description
Hudi has the new {}HIVE_DEFAULT_PARTITION{} as the fallback one.
Presto/Trino seem to covert it to `\N`. https://github.com/codope/trino/blob/f7c969c1cc6a10f601ca522a7161384a7bf56996/plugin/trino-hive/src/main/java/io/trino/plugin/hive/HivePartitionKey.java#L44
It works with this fix
git diff diff --git a/plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiPageSourceProvider.java b/plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiPageSourceProvider.java index 1c72175860..d10dbbaac7 100644 --- a/plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiPageSourceProvider.java +++ b/plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiPageSourceProvider.java @@ -159,7 +159,7 @@ public class HudiPageSourceProvider String partitionValue, TypeSignature partitionDataType) { - if (isNull(partitionValue)) { + if (isNull(partitionValue) || partitionValue.equals("\\N")) { return Optional.empty(); }
Attachments
Issue Links
- links to