You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/02/16 00:52:57 UTC

[09/17] kylin git commit: KYLIN-2429 Variable initialized should be declared volatile

KYLIN-2429 Variable initialized should be declared volatile


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/11617a9e
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/11617a9e
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/11617a9e

Branch: refs/heads/master-hbase0.98
Commit: 11617a9ecd5161290612deda46eff6937f109ace
Parents: 29bff86
Author: shaofengshi <sh...@apache.org>
Authored: Tue Feb 14 18:09:46 2017 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Tue Feb 14 18:09:46 2017 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/engine/spark/SparkCubingByLayer.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/11617a9e/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java
----------------------------------------------------------------------
diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java
index 317d2bd..c7422ed 100644
--- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java
+++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/SparkCubingByLayer.java
@@ -190,7 +190,7 @@ public class SparkCubingByLayer extends AbstractApplication implements Serializa
 
         // encode with dimension encoding, transform to <ByteArray, Object[]> RDD
         final JavaPairRDD<ByteArray, Object[]> encodedBaseRDD = intermediateTable.javaRDD().mapToPair(new PairFunction<Row, ByteArray, Object[]>() {
-            transient boolean initialized = false;
+            volatile transient boolean initialized = false;
             BaseCuboidBuilder baseCuboidBuilder = null;
 
             @Override