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 <shaofeng...@apache.org> Authored: Tue Feb 14 18:09:46 2017 +0800 Committer: shaofengshi <shaofeng...@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
