Repository: kylin Updated Branches: refs/heads/master 29bff8664 -> 11617a9ec
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 Commit: 11617a9ecd5161290612deda46eff6937f109ace Parents: 29bff86 Author: shaofengshi <[email protected]> Authored: Tue Feb 14 18:09:46 2017 +0800 Committer: shaofengshi <[email protected]> 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
