mas-chen commented on code in PR #9173:
URL: https://github.com/apache/iceberg/pull/9173#discussion_r1409747023
##########
flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java:
##########
@@ -120,26 +122,30 @@ private String planningThreadName() {
// a public API like the protected method "OperatorCoordinator.Context
getCoordinatorContext()"
// from SourceCoordinatorContext implementation. For now, <table
name>-<random UUID> is used as
// the unique thread pool name.
- return lazyTable().name() + "-" + UUID.randomUUID();
+ return tableName() + "-" + UUID.randomUUID();
}
- private List<IcebergSourceSplit> planSplitsForBatch(String threadName) {
+ private List<IcebergSourceSplit> planSplitsForBatch(
+ TableLoader plannerTableLoader, String threadName) {
ExecutorService workerPool =
ThreadPools.newWorkerPool(threadName, scanContext.planParallelism());
- try {
+ plannerTableLoader.open();
Review Comment:
I forgot to rename this variable earlier
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
