carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jack...@apache.org
Subject [carbondata] branch master updated: [HOTFIX] fix compile errors
Date Tue, 03 Dec 2019 02:59:56 GMT
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 <441586683@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(


Mime
View raw message