在单机版模式下 LocalFileSplitManager coordinator 与 worker在同一台机器,如果filtercoordinator的话,会造成没有存活node,没发触发事件查询 List<ConnectorSplit> splits = nodeManager.getNodes(ACTIVE).stream() // .filter(node -> !nodeManager.getCoordinators().contains(node)) .map(node -> new LocalFileSplit(node.getHostAndPort(), tableHandle.getSchemaTableName(), effectivePredicate)) .collect(Collectors.toList());