You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/08/06 10:32:08 UTC

[kylin] branch engine-flink updated: KYLIN-4124 Fix bug in map partition function en cuboid children is empty or null

This is an automated email from the ASF dual-hosted git repository.

nic pushed a commit to branch engine-flink
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/engine-flink by this push:
     new de5eae0  KYLIN-4124 Fix bug in map partition function en cuboid children is empty or null
de5eae0 is described below

commit de5eae05f3a0f4ff8f7f4c905db020f777b47c9a
Author: yanghua <ya...@gmail.com>
AuthorDate: Tue Aug 6 17:13:02 2019 +0800

    KYLIN-4124 Fix bug in map partition function en cuboid children is empty or null
---
 .../src/main/java/org/apache/kylin/engine/flink/FlinkCubingByLayer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkCubingByLayer.java b/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkCubingByLayer.java
index b39aa1e..0f1bfac 100644
--- a/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkCubingByLayer.java
+++ b/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkCubingByLayer.java
@@ -559,7 +559,7 @@ public class FlinkCubingByLayer extends AbstractApplication implements Serializa
 
                 // if still empty or null
                 if (myChildren == null || myChildren.size() == 0) {
-                    return;
+                    continue;
                 }
                 rowKeySplitter.split(key);
                 final Cuboid parentCuboid = Cuboid.findForMandatory(cubeDesc, cuboidId);