Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-30817

ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown

    XMLWordPrintableJSON

Details

    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

          Web Link GitHub Pull Request #21878

          Activity

            People

              Unassigned Unassigned
              csq Shuiqiang Chen
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: