This is an automated email from the ASF dual-hosted git repository. jackylk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push: new e403a14 [HOTFIX] fix compile errors e403a14 is described below commit e403a147310dd9c4ffc19d332f0d5339d05ba906 Author: Zhang Zhichao <441586...@qq.com> AuthorDate: Tue Dec 3 10:35:37 2019 +0800 [HOTFIX] fix compile errors Fix carbondaata-flink and datamap example compile errors This closes #3494 --- .../org/apache/carbondata/datamap/examples/MinMaxIndexDataMap.java | 2 +- .../apache/carbondata/datamap/examples/MinMaxIndexDataMapFactory.java | 2 +- integration/flink/pom.xml | 4 ++-- .../src/main/java/org/apache/carbon/core/metadata/StageManager.java | 3 +-- 4 files changed, 5 insertions(+), 6 deletions(-) diff --git a/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMap.java b/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMap.java index 02aa94b..54dfb1b 100644 --- a/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMap.java +++ b/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMap.java @@ -99,7 +99,7 @@ public class MinMaxIndexDataMap extends CoarseGrainDataMap { AtomicFileOperationFactory.getAtomicFileOperations(filePath); try { - if (!FileFactory.isFileExist(filePath) { + if (!FileFactory.isFileExist(filePath)) { return null; } dataInputStream = fileOperation.openForRead(); diff --git a/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMapFactory.java b/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMapFactory.java index 6cecc90..fbd79a3 100644 --- a/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMapFactory.java +++ b/datamap/examples/src/minmaxdatamap/main/java/org/apache/carbondata/datamap/examples/MinMaxIndexDataMapFactory.java @@ -62,7 +62,7 @@ public class MinMaxIndexDataMapFactory extends CoarseGrainDataMapFactory { // will be supported by this datamap. Furthermore, we can add cache-support for this datamap. // columns that will be indexed - List<CarbonColumn> allColumns = getCarbonTable().getCreateOrderColumn(identifier.getTableName()); + List<CarbonColumn> allColumns = getCarbonTable().getCreateOrderColumn(); // operations that will be supported on the indexed columns List<ExpressionType> optOperations = new ArrayList<>(); diff --git a/integration/flink/pom.xml b/integration/flink/pom.xml index 80746c0..73bf941 100644 --- a/integration/flink/pom.xml +++ b/integration/flink/pom.xml @@ -230,8 +230,8 @@ <plugin> <artifactId>maven-compiler-plugin</artifactId> <configuration> - <source>1.7</source> - <target>1.7</target> + <source>1.8</source> + <target>1.8</target> </configuration> </plugin> <plugin> diff --git a/integration/flink/src/main/java/org/apache/carbon/core/metadata/StageManager.java b/integration/flink/src/main/java/org/apache/carbon/core/metadata/StageManager.java index ad38260..8b6c2d7 100644 --- a/integration/flink/src/main/java/org/apache/carbon/core/metadata/StageManager.java +++ b/integration/flink/src/main/java/org/apache/carbon/core/metadata/StageManager.java @@ -80,8 +80,7 @@ public final class StageManager { private static void writeSuccessFile(final String successFilePath) throws IOException { final DataOutputStream segmentStatusSuccessOutputStream = - FileFactory.getDataOutputStream( - successFilePath, FileFactory.getFileType(successFilePath), + FileFactory.getDataOutputStream(successFilePath, CarbonCommonConstants.BYTEBUFFER_SIZE, 1024); try { IOUtils.copyBytes(