Details
-
Bug
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
1.16.0, 1.17.0
-
None
Description
When applying partitions in TestValuesScanTableSourceWithoutProjectionPushDown with no partition provided, the following code will cause ClassCastException
remainingPartitions = (List<Map<String, String>>) Collections.emptyMap(); this.data.put(Collections.emptyMap(), Collections.emptyList());
java.lang.ClassCastException: java.util.Collections$EmptyMap cannot be cast to java.util.List
at org.apache.flink.table.planner.factories.TestValuesTableFactory$TestValuesScanTableSourceWithoutProjectionPushDown.applyPartitions(TestValuesTableFactory.java:1222)
at org.apache.flink.table.planner.plan.abilities.source.PartitionPushDownSpec.apply(PartitionPushDownSpec.java:57)
at org.apache.flink.table.planner.plan.rules.logical.PushPartitionIntoTableSourceScanRule.onMatch(PushPartitionIntoTableSourceScanRule.java:183)
at org.apache.calcite.plan.AbstractRelOptPlanner.fireRule(AbstractRelOptPlanner.java:343)
Attachments
Issue Links
- links to