diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CrossProductHandler.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CrossProductHandler.java index aef7247..1a6a39a 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CrossProductHandler.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CrossProductHandler.java @@ -95,8 +95,10 @@ public PhysicalContext resolve(PhysicalContext pctx) throws SemanticException { && conf.get(CartesianProductVertexManager.TEZ_CARTESIAN_PRODUCT_MAX_PARALLELISM) == null) { LlapClusterStateForCompile llapInfo = LlapClusterStateForCompile.getClusterInfo(conf); llapInfo.initClusterInfo(); - conf.setInt(CartesianProductVertexManager.TEZ_CARTESIAN_PRODUCT_MAX_PARALLELISM, - llapInfo.getKnownExecutorCount()); + if (llapInfo.hasClusterInfo()) { + conf.setInt(CartesianProductVertexManager.TEZ_CARTESIAN_PRODUCT_MAX_PARALLELISM, + llapInfo.getKnownExecutorCount()); + } } TaskGraphWalker ogw = new TaskGraphWalker(this);