[HOTFIX] fix compile errors
Fix carbondaata-flink and datamap example compile errors
This closes #3494
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 @@
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 @@
// 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 @@
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(
