Fix package name

apache · Oct 16, 2023 · 12a4e5f · 12a4e5f
1 parent 651f4dc
commit 12a4e5f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git a/flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java b/flink/flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java
@@ -58,7 +58,7 @@
 import org.apache.flink.types.Row;
 import org.apache.flink.types.RowKind;
 import org.apache.flink.util.FlinkException;
-import org.apache.zeppelin.flink.shims117.CollectStreamTableSink;
+import org.apache.zeppelin.flink.shims116.CollectStreamTableSink;
 import org.apache.zeppelin.interpreter.InterpreterContext;
 import org.apache.zeppelin.interpreter.InterpreterResult;
 import org.slf4j.Logger;

diff --git a/...link/shims117/CollectStreamTableSink.java → ...link/shims116/CollectStreamTableSink.java b/...link/shims117/CollectStreamTableSink.java → ...link/shims116/CollectStreamTableSink.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.zeppelin.flink.shims117;
+package org.apache.zeppelin.flink.shims116;
 
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.common.typeinfo.Types;

diff --git a/flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java b/flink/flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java
@@ -23,7 +23,6 @@
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.tuple.ImmutablePair;
 import org.apache.flink.api.common.RuntimeExecutionMode;
-import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.client.cli.CliFrontend;
@@ -53,7 +52,6 @@
 import org.apache.flink.table.functions.TableAggregateFunction;
 import org.apache.flink.table.functions.TableFunction;
 import org.apache.flink.table.module.ModuleManager;
-import org.apache.flink.table.planner.calcite.FlinkTypeFactory;
 import org.apache.flink.table.resource.ResourceManager;
 import org.apache.flink.table.sinks.TableSink;
 import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
@@ -78,7 +76,7 @@
 
 
 /**
- * Shims for flink 1.16
+ * Shims for flink 1.17
  */
 public class Flink117Shims extends FlinkShims {
 
@@ -252,12 +250,12 @@ public boolean rowEquals(Object row1, Object row2) {
 
   @Override
   public Object fromDataSet(Object btenv, Object ds) {
-    throw new RuntimeException("Conversion from DataSet is not supported in Flink 1.15");
+    throw new RuntimeException("Conversion from DataSet is not supported in Flink 1.17");
   }
 
   @Override
   public Object toDataSet(Object btenv, Object table) {
-    throw new RuntimeException("Conversion to DataSet is not supported in Flink 1.15");
+    throw new RuntimeException("Conversion to DataSet is not supported in Flink 1.17");
   }
 
   @Override