This is an automated email from the ASF dual-hosted git repository.
zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push:
new f9fb395 [ZEPPELIN-5477] Change the wrong class name
f9fb395 is described below
commit f9fb395942b958d473c3f14068c7840f1cdc2e23
Author: nicolasgong <ni...@gmail.com>
AuthorDate: Thu Aug 5 09:19:42 2021 +0800
[ZEPPELIN-5477] Change the wrong class name
### What is this PR for?
FlinkSqlInterrpeter the class name is misspelled.Should be changed to FlinkSqlInterpreter.
### What type of PR is it?
[Improvement]
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-5477
Author: nicolasgong <ni...@gmail.com>
Closes #4196 from NicolasGong/bug-repair-0.1 and squashes the following commits:
bec79cc127 [nicolasgong] Change the wrong class name
---
.../java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java | 2 +-
.../flink/{FlinkSqlInterrpeter.java => FlinkSqlInterpreter.java} | 7 +++----
.../java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java | 2 +-
.../org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java | 2 +-
.../org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java | 3 +--
.../test/java/org/apache/zeppelin/flink/SqlInterpreterTest.java | 4 ++--
6 files changed, 9 insertions(+), 11 deletions(-)
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 90fae60..d10a9ea 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 org.apache.zeppelin.scheduler.SchedulerFactory;
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 cc1cad6..3fa27f7 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.StringUtils;
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.Properties;
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<String, ConfigOption> 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 60c5c5a..23aadf2 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 org.apache.zeppelin.scheduler.SchedulerFactory;
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 ce627c1..e09bd1b 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 @@ import static org.junit.Assert.assertEquals;
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 98604cd..4b3ebf9 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.apache.zeppelin.interpreter.InterpreterResultMessage;
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 @@ import static org.junit.Assert.assertEquals;
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 fe24077..e71ff93 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 abstract class SqlInterpreterTest {
}
}
- protected abstract FlinkSqlInterrpeter createFlinkSqlInterpreter(Properties properties);
+ protected abstract FlinkSqlInterpreter createFlinkSqlInterpreter(Properties properties);
@Test
public void testDatabases() throws InterpreterException, IOException {