Skip to content

Commit

Permalink
[bugfix](iceberg)Fixed missing type of iceberg table for timetravel f…
Browse files Browse the repository at this point in the history
…or 2.1 (#36048)

bp:  #36047
  • Loading branch information
wuwenchi authored Jun 7, 2024
1 parent bd6b913 commit 240d893
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -590,6 +590,9 @@ public PlanFragment visitPhysicalFileScan(PhysicalFileScan fileScan, PlanTransla
}
} else if (table instanceof IcebergExternalTable) {
scanNode = new IcebergScanNode(context.nextPlanNodeId(), tupleDescriptor, false);
if (fileScan.getTableSnapshot().isPresent()) {
((IcebergScanNode) scanNode).setTableSnapshot(fileScan.getTableSnapshot().get());
}
} else if (table instanceof PaimonExternalTable) {
scanNode = new PaimonScanNode(context.nextPlanNodeId(), tupleDescriptor, false);
} else if (table instanceof MaxComputeExternalTable) {
Expand Down

0 comments on commit 240d893

Please sign in to comment.