This is an automated email from the ASF dual-hosted git repository.
zjffdu pushed a change to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/zeppelin.git.
from c5c8c87 [hotfix] Fix publish script
new 8214b97 [ZEPPELIN-4688]. Support set statement in flink sql
new 464027a [ZEPPELIN-4686] Update commons-lang to commons-lang3
new 2a0141d [ZEPPELIN-4687]. Allow to run multiple sql as one flink job
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
cassandra/pom.xml | 2 -
elasticsearch/pom.xml | 4 +-
.../ElasticsearchInterpreterTest.java | 14 +-
file/pom.xml | 4 +-
.../apache/zeppelin/file/HDFSFileInterpreter.java | 2 +-
flink/pom.xml | 4 +
.../apache/zeppelin/flink/FlinkSqlInterrpeter.java | 118 +++++++++++++++--
.../zeppelin/flink/FlinkStreamSqlInterpreter.java | 2 +-
.../java/org/apache/zeppelin/flink/JobManager.java | 2 +-
.../zeppelin/flink/sql/AppendStreamSqlJob.java | 4 +-
.../zeppelin/flink/sql/SingleRowStreamSqlJob.java | 5 +-
.../zeppelin/flink/sql/UpdateStreamSqlJob.java | 6 +-
.../zeppelin/flink/FlinkScalaInterpreter.scala | 2 +-
.../flink/FlinkBatchSqlInterpreterTest.java | 141 +++++++++++++++++++++
.../flink/FlinkStreamSqlInterpreterTest.java | 44 +++++++
.../apache/zeppelin/geode/GeodeOqlInterpreter.java | 2 +-
jdbc/pom.xml | 2 -
.../org/apache/zeppelin/jdbc/SqlCompleterTest.java | 2 +-
ksql/pom.xml | 4 +-
.../org/apache/zeppelin/ksql/KSQLInterpreter.java | 2 +-
.../org/apache/zeppelin/ksql/KSQLRestService.java | 2 +-
livy/pom.xml | 4 +-
.../apache/zeppelin/livy/BaseLivyInterpreter.java | 6 +-
.../zeppelin/livy/LivySharedInterpreter.java | 2 +-
.../zeppelin/livy/LivySparkSQLInterpreter.java | 6 +-
markdown/pom.xml | 2 -
.../zeppelin/mongodb/MongoDbInterpreter.java | 2 +-
.../zeppelin/mongodb/MongoDbInterpreterTest.java | 2 +-
neo4j/pom.xml | 4 +-
.../graph/neo4j/Neo4jConnectionManager.java | 2 +-
.../graph/neo4j/Neo4jCypherInterpreter.java | 2 +-
.../apache/zeppelin/pig/BasePigInterpreter.java | 2 +-
.../org/apache/zeppelin/pig/PigInterpreter.java | 2 +-
.../apache/zeppelin/pig/PigQueryInterpreter.java | 4 +-
.../java/org/apache/zeppelin/pig/PigUtils.java | 2 +-
pom.xml | 7 +
python/pom.xml | 4 +-
.../apache/zeppelin/python/IPythonInterpreter.java | 2 +-
.../zeppelin/python/PythonCondaInterpreter.java | 2 +-
.../apache/zeppelin/python/PythonInterpreter.java | 2 +-
rlang/pom.xml | 4 +-
.../java/org/apache/zeppelin/r/IRInterpreter.java | 2 +-
.../org/apache/zeppelin/r/ShinyInterpreter.java | 2 +-
sap/pom.xml | 4 +-
.../apache/zeppelin/sap/UniverseInterpreter.java | 2 +-
.../zeppelin/sap/universe/UniverseClient.java | 4 +-
.../zeppelin/sap/universe/UniverseCompleter.java | 2 +-
.../sap/universe/UniverseNodeInfoCompleter.java | 2 +-
.../zeppelin/sap/universe/UniverseQuery.java | 2 +-
.../apache/zeppelin/sap/universe/UniverseUtil.java | 2 +-
.../sap/universe/UniverseCompleterTest.java | 2 +-
scio/pom.xml | 4 +-
shell/pom.xml | 6 +-
.../shell/terminal/service/TerminalService.java | 2 +-
spark/interpreter/pom.xml | 4 +-
.../apache/zeppelin/spark/PySparkInterpreter.java | 2 +-
.../apache/zeppelin/spark/SparkInterpreter.java | 2 +-
.../apache/zeppelin/spark/SparkSqlInterpreter.java | 2 +-
.../zeppelin/submarine/SubmarineInterpreter.java | 2 +-
.../zeppelin/submarine/commons/SubmarineUI.java | 2 +-
.../zeppelin/submarine/commons/SubmarineUtils.java | 2 +-
.../zeppelin/submarine/hadoop/HdfsClient.java | 4 +-
.../zeppelin/submarine/hadoop/YarnClient.java | 2 +-
.../zeppelin/submarine/job/SubmarineJob.java | 2 +-
.../submarine/job/thread/JobRunThread.java | 2 +-
.../submarine/job/thread/TensorboardRunThread.java | 2 +-
zeppelin-integration/pom.xml | 1 -
.../integration/InterpreterModeActionsIT.java | 2 +-
.../zeppelin/integration/ParagraphActionsIT.java | 2 +-
.../zeppelin/integration/PersonalizeActionsIT.java | 2 +-
zeppelin-interpreter/pom.xml | 7 -
.../apache/zeppelin/cluster/ClusterManager.java | 2 +-
.../zeppelin/cluster/ClusterManagerServer.java | 2 +-
.../apache/zeppelin/cluster/meta/ClusterMeta.java | 2 +-
.../zeppelin/conf/ZeppelinConfiguration.java | 2 +-
.../main/java/org/apache/zeppelin/dep/Booter.java | 2 +-
.../apache/zeppelin/dep/DependencyResolver.java | 2 +-
.../java/org/apache/zeppelin/dep/Repository.java | 2 +-
.../java/org/apache/zeppelin/display/Input.java | 2 +-
.../apache/zeppelin/interpreter/Interpreter.java | 4 +-
.../zeppelin/interpreter/InterpreterOutput.java | 2 +-
.../remote/RemoteInterpreterServer.java | 2 +-
.../interpreter/remote/RemoteInterpreterUtils.java | 2 +-
.../zeppelin/interpreter/util/ProcessLauncher.java | 4 +-
.../java/org/apache/zeppelin/scheduler/Job.java | 6 +-
.../apache/zeppelin/user/AuthenticationInfo.java | 2 +-
.../main/java/org/apache/zeppelin/util/Util.java | 2 +-
zeppelin-jupyter-interpreter/pom.xml | 4 +-
.../zeppelin/jupyter/JupyterKernelClient.java | 2 +-
.../zeppelin/jupyter/JupyterKernelInterpreter.java | 4 +-
.../zeppelin/realm/ActiveDirectoryGroupRealm.java | 2 +-
.../java/org/apache/zeppelin/realm/LdapRealm.java | 4 +-
.../org/apache/zeppelin/rest/AdminRestApi.java | 2 +-
.../org/apache/zeppelin/rest/HeliumRestApi.java | 2 +-
.../apache/zeppelin/rest/InterpreterRestApi.java | 2 +-
.../apache/zeppelin/rest/NotebookRepoRestApi.java | 2 +-
.../rest/message/NotebookRepoSettingsRequest.java | 2 +-
.../org/apache/zeppelin/server/ZeppelinServer.java | 2 +-
.../apache/zeppelin/service/NotebookService.java | 2 +-
.../apache/zeppelin/socket/ConnectionManager.java | 2 +-
.../org/apache/zeppelin/socket/NotebookServer.java | 2 +-
.../org/apache/zeppelin/socket/NotebookSocket.java | 2 +-
.../configuration/RequestHeaderSizeTest.java | 2 +-
.../zeppelin/rest/NotebookRepoRestApiTest.java | 2 +-
.../zeppelin/service/NotebookServiceTest.java | 2 +-
zeppelin-zengine/pom.xml | 2 -
.../zeppelin/helium/HeliumBundleFactory.java | 2 +-
.../zeppelin/helium/HeliumOnlineRegistry.java | 2 +-
.../zeppelin/interpreter/ConfInterpreter.java | 2 +-
.../zeppelin/interpreter/InterpreterFactory.java | 2 +-
.../zeppelin/interpreter/InterpreterSetting.java | 2 +-
.../interpreter/InterpreterSettingManager.java | 4 +-
.../interpreter/SessionConfInterpreter.java | 2 +-
.../launcher/StandardInterpreterLauncher.java | 2 +-
.../recovery/FileSystemRecoveryStorage.java | 2 +-
.../remote/RemoteInterpreterManagedProcess.java | 2 +-
.../zeppelin/notebook/AuthorizationService.java | 2 +-
.../zeppelin/notebook/FileSystemStorage.java | 2 +-
.../java/org/apache/zeppelin/notebook/Note.java | 2 +-
.../org/apache/zeppelin/notebook/Paragraph.java | 6 +-
.../zeppelin/notebook/ParagraphTextParser.java | 2 +-
.../notebook/repo/NotebookRepoWithSettings.java | 2 +-
.../repo/NotebookRepoWithVersionControl.java | 2 +-
.../repo/OldNotebookRepoWithVersionControl.java | 2 +-
.../zeppelin/notebook/repo/OldVFSNotebookRepo.java | 2 +-
.../zeppelin/notebook/repo/VFSNotebookRepo.java | 2 +-
.../zeppelinhub/model/UserSessionContainer.java | 2 +-
.../repo/zeppelinhub/model/UserTokenContainer.java | 2 +-
.../repo/zeppelinhub/rest/HttpProxyClient.java | 2 +-
.../rest/ZeppelinhubRestApiHandler.java | 2 +-
.../zeppelinhub/websocket/ZeppelinhubClient.java | 2 +-
.../websocket/listener/WatcherWebsocket.java | 2 +-
.../websocket/protocol/ZeppelinhubMessage.java | 2 +-
.../websocket/session/ZeppelinhubSession.java | 2 +-
.../websocket/utils/ZeppelinhubUtils.java | 2 +-
.../interpreter/remote/RemoteInterpreterTest.java | 2 +-
.../notebook/repo/GitNotebookRepoTest.java | 2 +-
137 files changed, 472 insertions(+), 189 deletions(-)
