From bec79cc127216e263a037bca1aa9430da340f474 Mon Sep 17 00:00:00 2001 From: nicolasgong Date: Thu, 5 Aug 2021 09:19:42 +0800 Subject: [PATCH] Change the wrong class name --- .../apache/zeppelin/flink/FlinkBatchSqlInterpreter.java | 2 +- .../{FlinkSqlInterrpeter.java => FlinkSqlInterpreter.java} | 7 +++---- .../apache/zeppelin/flink/FlinkStreamSqlInterpreter.java | 2 +- .../zeppelin/flink/FlinkBatchSqlInterpreterTest.java | 2 +- .../zeppelin/flink/FlinkStreamSqlInterpreterTest.java | 3 +-- .../java/org/apache/zeppelin/flink/SqlInterpreterTest.java | 4 ++-- 6 files changed, 9 insertions(+), 11 deletions(-) rename flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/{FlinkSqlInterrpeter.java => FlinkSqlInterpreter.java} (99%) diff --git a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java index 90fae602fd3..d10a9eacf34 100644 --- a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java +++ b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java @@ -27,7 +27,7 @@ import java.io.IOException; import java.util.Properties; -public class FlinkBatchSqlInterpreter extends FlinkSqlInterrpeter { +public class FlinkBatchSqlInterpreter extends FlinkSqlInterpreter { private ZeppelinContext z; diff --git a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterrpeter.java b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java similarity index 99% rename from flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterrpeter.java rename to flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java index cc1cad6bb4e..3fa27f798a1 100644 --- a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterrpeter.java +++ b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java @@ -24,7 +24,6 @@ import org.apache.commons.lang3.exception.ExceptionUtils; import org.apache.flink.api.common.JobExecutionResult; import org.apache.flink.configuration.ConfigOption; -import org.apache.flink.configuration.Configuration; import org.apache.flink.core.execution.JobClient; import org.apache.flink.core.execution.JobListener; import org.apache.flink.table.api.TableEnvironment; @@ -51,9 +50,9 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; import java.util.stream.Collectors; -public abstract class FlinkSqlInterrpeter extends AbstractInterpreter { +public abstract class FlinkSqlInterpreter extends AbstractInterpreter { - protected static final Logger LOGGER = LoggerFactory.getLogger(FlinkSqlInterrpeter.class); + protected static final Logger LOGGER = LoggerFactory.getLogger(FlinkSqlInterpreter.class); protected FlinkInterpreter flinkInterpreter; protected TableEnvironment tbenv; @@ -65,7 +64,7 @@ public abstract class FlinkSqlInterrpeter extends AbstractInterpreter { // https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html private Map tableConfigOptions; - public FlinkSqlInterrpeter(Properties properties) { + public FlinkSqlInterpreter(Properties properties) { super(properties); } diff --git a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java index 60c5c5a4dc8..23aadf24180 100644 --- a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java +++ b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java @@ -30,7 +30,7 @@ import java.io.IOException; import java.util.Properties; -public class FlinkStreamSqlInterpreter extends FlinkSqlInterrpeter { +public class FlinkStreamSqlInterpreter extends FlinkSqlInterpreter { public FlinkStreamSqlInterpreter(Properties properties) { super(properties); diff --git a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java index ce627c13047..e09bd1b3536 100644 --- a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java +++ b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java @@ -40,7 +40,7 @@ public class FlinkBatchSqlInterpreterTest extends SqlInterpreterTest { @Override - protected FlinkSqlInterrpeter createFlinkSqlInterpreter(Properties properties) { + protected FlinkSqlInterpreter createFlinkSqlInterpreter(Properties properties) { return new FlinkBatchSqlInterpreter(properties); } diff --git a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java index 98604cd9dcf..4b3ebf9fa04 100644 --- a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java +++ b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java @@ -27,7 +27,6 @@ import org.junit.Test; import java.io.File; -import java.io.FilenameFilter; import java.io.IOException; import java.nio.file.Files; import java.util.List; @@ -40,7 +39,7 @@ public class FlinkStreamSqlInterpreterTest extends SqlInterpreterTest { @Override - protected FlinkSqlInterrpeter createFlinkSqlInterpreter(Properties properties) { + protected FlinkSqlInterpreter createFlinkSqlInterpreter(Properties properties) { return new FlinkStreamSqlInterpreter(properties); } diff --git a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java index fe24077aed6..e71ff9364f8 100644 --- a/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java +++ b/flink/flink-scala-parent/src/test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java @@ -77,7 +77,7 @@ public abstract class SqlInterpreterTest { protected FlinkInterpreter flinkInterpreter; protected IPyFlinkInterpreter iPyFlinkInterpreter; protected PyFlinkInterpreter pyFlinkInterpreter; - protected FlinkSqlInterrpeter sqlInterpreter; + protected FlinkSqlInterpreter sqlInterpreter; private AngularObjectRegistry angularObjectRegistry; @@ -150,7 +150,7 @@ public void tearDown() throws InterpreterException { } } - protected abstract FlinkSqlInterrpeter createFlinkSqlInterpreter(Properties properties); + protected abstract FlinkSqlInterpreter createFlinkSqlInterpreter(Properties properties); @Test public void testDatabases() throws InterpreterException, IOException {