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(
