This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/flink/flink-scala-parent/org.apache.ivy-ivy-2.5.1
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
discard dcd713966f Bump ivy from 2.4.0 to 2.5.1 in /flink/flink-scala-parent
add ac5c9b4c26 [ZEPPELIN-5763] NoClassDefFoundError in spark interpreter:
org/apache/commons/lang/StringUtils (#4501)
add aa4731e699 [ZEPPELIN-5845] Cluster polish (#4505)
add 053ca477f5 [ZEPPELIN-5842] Maven-Plugin management (#4503)
add e96880f5ec [ZEPPELIN-5612] Upgrade junit 4 to 5 (#4321)
add bc810c324a [ZEPPELIN-5849] MIGRATE JDBC MODULE TO JUNIT 5 (#4511)
add c8a529df8f [MINOR] Remove warnning (#4513)
add 5ac5d1a24e [ZEPPELIN-5847] Polish Maven tasks (#4509)
add 874075f4cf [MINOR] Polish maven plugins for root pom (#4512)
add 364c8554a6 Bump postgresql from 42.4.1 to 42.4.3 in /jdbc (#4517)
add 322b9a0d7d [MINOR] Remove `maven-eclipse-plugin` (#4518)
add c82f4e5f50 [MINOR] Use Maven CLI option instead of a logger
adjustment. (#4521)
add 031064ff8b [ZEPPELIN-5859] Upgrading alluxio client library to latest
stable release 2.9.0 (#4524)
add 2f4ff39122 [MINOR] Add github autolink to ZEPPELIN (#4528)
add 204b37d4a1 [MINOR] Fix tiny typo (#4530)
add 348013e068 [ZEPPELIN-5856] Bump bouncycastle 1.70 (#4522)
add 767791978a [Minor][ZEPPELIN-5859] Fixing the styling issue (#4534)
add 0bc83922f3 [ZEPPELIN-5863] Warn not to expose the docker daemon to
untrusted users (#4526)
add c1a138d84b [MINOR] Fix Appveyor error (#4520)
add fad3b016d0 [ZEPPELIN-5867][JDBC] Exclude hbase-server from hive-jdbc
(#4536)
add 09bd93877b [ZEPPELIN-5857] Bump gRPC and protobuf to support build on
macOS M1 chips (#4523)
add db2c8677e4 [ZEPPELIN-5869] Remove Incubating from Kyuubi reference
(#4540)
add deb7f3b1c4 [ZEPPELIN-5873] Update github actions (#4542)
add 9095d9b823 [MINOR] Specify branch names for Github action (#4529)
add 976a8565fb [MINOR] Support aarch for frontend plugin (#4541)
add aad8598117 [HOTFIX] Github Actions workaround (#4550)
add 89a1ff2941 Correct small typo (#4551)
add eafbb6b116 Bump json5 from 1.0.1 to 1.0.2 in /zeppelin-web-angular
(#4544)
add 4433c4d0ea Bump eventsource from 1.0.7 to 1.1.1 in
/zeppelin-web-angular (#4376)
add 55a6af9603 [MINOR] Fix wrong format for github actions of
'branches-ignore' (#4552)
add 7137e88056 [MINOR] document 'markdown' display system (#4549)
add 14650a769f [MINOR] Disable depeanabot branches for AppVeyor (#4555)
add dd03962793 [ZEPPELIN-5875] Fix flaky tests in `core-modules` (#4556)
add 1b8b42eed8 Bump global-modules-path and webpack-cli in /zeppelin-web
(#4554)
add fa2a132dec [ZEPPELIN-5874] polish flink code base (#4553)
add 0209d0d0d4 Remove conda cache suffix (#4557)
add 45b15fe971 [ZEPPELIN-5861] Correct shading Prefix (#4545)
add 521acca985 [ZEPPELIN-5844] Support flink 1.16 (#4506)
add af8280685b [ZEPPELIN-5855] Refactor docker plugin and remove powermock
(#4519)
add c48e35f27d [HOTFIX] Fix CI failure due to sqlalchemy api change (#4561)
add f30ea77acc Bump jettison from 1.4.0 to 1.5.2 (#4543)
add 11052f6fb4 [ZEPPELIN-5846] Remove support flink 1.12 (#4558)
add 67fb2add81 [MINOR] Use flink-113 as default profile (#4566)
add efc5fb8fb1 [ZEPPELIN-5884] fix: wrong path of test folder in Java
Interpreter (#4569)
add 25a36ddfce [ZEPPELIN-5881] Missing dependency when package
zeppelin-server module (#4570)
add aeb40a5907 [ZEPPELIN-5879] Migrate Zeppelin Plugins to JUnit5 (#4559)
add 5d102f5289 [ZEPPELIN-5885] Solve the concurrency problem caused by
multiple concurrent calls to note clone (#4563)
add 7d827a1ac8 Bump jettison from 1.5.2 to 1.5.4 (#4575)
add 36a3042f56 Bump jackson-databind from 2.12.6.1 to 2.12.7.1 in /neo4j
(#4576)
add 99848c9734 [ZEPPELIN-5891]Delete cloneNoteMeta method and replace it
with createNoteAuth. (#4578)
add ce1c3e57a4 [ZEPPELIN-5855] remove more powermock usages to support
junit5 (#4580)
add c68182d4bc [MINOR] Update doc for flink 1.16 (#4572)
add debfa7fcc2 [ZEPPELIN-5900] Fix RemoteSchedulerTest (#4582)
add d5eee9f160 [ZEPPELIN-5903] Improve LRU NoteCache - Add a cleanup
(#4590)
add 654c827973 [ZEPPELIN-5898] fix:download csv data error (#4593)
add be82be78cc [ZEPPELIN-5893] NPE in ParagraphResult when getting
progress from paragraphJson (#4579)
add eaa9200cf0 Use wildcard generic for job and remove generic for
JobListener (#4592)
add e6d61072a2 [ZEPPELIN-5851][JUnit 5 Migration] Module: zeppelin-zengine
(#4532)
add 22ae6cdcd1 [ZEPPELIN-5907][JUnit 5 Migration] Module
zeppelin-interpreter (#4595)
add 3f1727462e [ZEPPELIN-5908] JDBCSecurityImpl should relogin when
authType='kerberos' to void kerberos ticket expired (#4597)
add ef2e1f55d1 Update atomix to 3.0.0-rc5, which removes hamcrest as a
compilation dependency of zeppelin-interpreter (#4601)
add 3fd026616e [ZEPPELIN-5850] Migrate zeppelin-server to Junit5 (#4600)
add f2eb3378e4 [ZEPPELIN-5897] Remove launcher properties and only use
the current context properties (#4602)
add 858de898d2 Use Classloader class for flink creation (#4605)
add 07cddfd05e Integration tests with newer spark version (#4604)
add 7c28263ac3 [ZEPPELIN-5919] Compile scala only where scala code is
present (#4607)
add df5d827193 [ZEPPELIN-5920] Fix deprecation warnings (#4609)
add ce577ad757 [ZEPPELIN-5921] Fix sync with remote repository (#4610)
add 7ed5a05c35 [ZEPPELIN-5927]Solve the concurrency calls to
`saveNoteAuth`. (#4613)
add 016d8f4d8d [ZEPPELIN-5926] Remove map entries if Collection is empty
(#4612)
add b4d9531ea5 Bump ivy from 2.4.0 to 2.5.1 in /flink/flink-scala-parent
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (dcd713966f)
\
N -- N -- N
refs/heads/dependabot/maven/flink/flink-scala-parent/org.apache.ivy-ivy-2.5.1
(b4d9531ea5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.appveyor.yml | 29 +-
.asf.yaml | 3 +
.github/PULL_REQUEST_TEMPLATE | 2 +-
.github/workflows/core.yml | 162 ++---
.github/workflows/frontend.yml | 40 +-
.github/workflows/quick.yml | 45 +-
alluxio/pom.xml | 28 +-
.../zeppelin/alluxio/AlluxioInterpreter.java | 20 +-
.../zeppelin/alluxio/AlluxioInterpreterTest.java | 80 +--
docs/interpreter/flink.md | 3 +-
docs/interpreter/jdbc.md | 8 +-
docs/quickstart/docker.md | 11 +-
docs/quickstart/sql_with_zeppelin.md | 2 +-
docs/usage/display_system/basic.md | 6 +-
.../client/ElasticsearchClientTypeBuilderTest.java | 2 +-
file/pom.xml | 4 -
flink/README.md | 3 +-
.../zeppelin/flink/FlinkScala211Interpreter.scala | 2 +-
.../zeppelin/flink/FlinkScala212Interpreter.scala | 2 +-
flink/flink-scala-parent/pom.xml | 126 ++--
.../flink/ApplicationModeExecutionEnvironment.java | 1 -
.../apache/zeppelin/flink/FlinkInterpreter.java | 8 +-
.../apache/zeppelin/flink/FlinkSqlInterpreter.java | 2 +-
.../apache/zeppelin/flink/IPyFlinkInterpreter.java | 4 +-
.../java/org/apache/zeppelin/flink/JobManager.java | 34 +-
.../apache/zeppelin/flink/PyFlinkInterpreter.java | 2 +-
.../org/apache/zeppelin/flink/TableEnvFactory.java | 194 +-----
.../apache/zeppelin/flink/internal/JarHelper.java | 12 +-
.../flink/internal/ScalaShellEnvironment.java | 3 -
.../internal/ScalaShellStreamEnvironment.java | 10 +
.../zeppelin/flink/sql/AbstractStreamSqlJob.java | 16 +-
.../zeppelin/flink/sql/AppendStreamSqlJob.java | 7 +-
.../zeppelin/flink/sql/SingleRowStreamSqlJob.java | 10 +-
.../zeppelin/flink/sql/UpdateStreamSqlJob.java | 12 +-
.../zeppelin/flink/FlinkScalaInterpreter.scala | 29 +-
.../zeppelin/flink/internal/FlinkILoop.scala | 43 +-
.../flink/FlinkStreamSqlInterpreterTest.java | 10 +-
.../{init_stream.scala => init_stream.scala2} | 0
.../java/org/apache/zeppelin/flink/FlinkShims.java | 36 +-
.../zeppelin/flink/Flink112SqlInterpreter.java | 584 -----------------
.../zeppelin/flink/shims112/SqlCommandParser.java | 355 -----------
.../flink/shims112/Flink112ScalaShims.scala | 36 --
.../org/apache/zeppelin/flink/Flink113Shims.java | 59 +-
.../org/apache/zeppelin/flink/Flink114Shims.java | 59 +-
.../org/apache/zeppelin/flink/Flink115Shims.java | 60 +-
flink/{flink1.12-shims => flink1.16-shims}/pom.xml | 32 +-
.../org/apache/zeppelin/flink/Flink116Shims.java} | 202 ++++--
.../zeppelin/flink/Flink116SqlInterpreter.java} | 6 +-
.../java/org/apache/zeppelin/flink/PrintUtils.java | 0
.../zeppelin/flink/TimestampStringUtils.java | 0
.../flink/shims116}/CollectStreamTableSink.java | 2 +-
flink/pom.xml | 17 +-
.../apache/zeppelin/java/JavaInterpreterTest.java | 0
.../zeppelin/java/JavaInterpreterUtilsTest.java} | 60 +-
.../zeppelin/java/JavaInterpreterUtilsTest.java | 95 ---
jdbc/pom.xml | 6 +-
.../zeppelin/jdbc/security/JDBCSecurityImpl.java | 3 +-
.../jdbc/JDBCInterpreterInterpolationTest.java | 8 +-
.../apache/zeppelin/jdbc/JDBCInterpreterTest.java | 27 +-
.../org/apache/zeppelin/jdbc/SqlCompleterTest.java | 15 +-
.../apache/zeppelin/jdbc/hive/HiveUtilsTest.java | 7 +-
.../apache/zeppelin/kotlin/KotlinInterpreter.java | 6 +-
livy/README.md | 2 +-
.../zeppelin/markdown/FlexmarkParserTest.java | 2 +-
neo4j/pom.xml | 11 +-
pom.xml | 378 ++++-------
python/pom.xml | 3 +-
.../src/main/resources/python/zeppelin_context.py | 3 +-
.../zeppelin/python/BasePythonInterpreterTest.java | 19 +
.../zeppelin/python/IPythonInterpreterTest.java | 3 -
spark/interpreter/pom.xml | 46 +-
.../spark/AbstractSparkScalaInterpreter.java | 2 +-
.../apache/zeppelin/spark/PySparkInterpreter.java | 1 +
.../apache/zeppelin/spark/SparkInterpreter.java | 9 +-
.../org/apache/zeppelin/spark/SparkShimsTest.java | 26 +-
spark/pom.xml | 60 --
.../java/org/apache/zeppelin/spark/SparkShims.java | 5 +-
.../org/apache/zeppelin/spark/Spark2Shims.java | 2 +-
.../org/apache/zeppelin/spark/Spark3Shims.java | 2 +-
submarine/pom.xml | 4 +-
testing/env_python_3.8_with_R.yml | 1 +
...ink_114.yml => env_python_3_with_flink_116.yml} | 2 +-
zeppelin-client-examples/pom.xml | 10 +-
zeppelin-client/pom.xml | 10 +-
.../apache/zeppelin/client/ParagraphResult.java | 4 +-
zeppelin-common/pom.xml | 10 +-
zeppelin-display/pom.xml | 17 +-
zeppelin-distribution/src/bin_license/LICENSE | 27 +-
zeppelin-examples/pom.xml | 2 +-
zeppelin-examples/zeppelin-example-clock/pom.xml | 12 +-
.../zeppelin-example-horizontalbar/pom.xml | 12 +-
.../zeppelin-example-spell-echo/pom.xml | 10 +-
.../zeppelin-example-spell-flowchart/pom.xml | 10 +-
.../zeppelin-example-spell-markdown/pom.xml | 10 +-
.../zeppelin-example-spell-translator/pom.xml | 10 +-
zeppelin-integration/pom.xml | 17 +-
zeppelin-interpreter-integration/pom.xml | 16 +-
.../integration/FlinkIntegrationTest112.java | 40 --
.../integration/ZSessionIntegrationTest.java | 20 +-
.../integration/ZeppelinFlinkClusterTest112.java | 40 --
zeppelin-interpreter-parent/pom.xml | 13 +-
zeppelin-interpreter-shaded/pom.xml | 8 +-
zeppelin-interpreter/pom.xml | 38 +-
.../apache/zeppelin/cluster/ClusterManager.java | 16 +-
.../zeppelin/cluster/ClusterManagerServer.java | 11 +-
.../apache/zeppelin/cluster/ClusterMonitor.java | 4 +-
.../apache/zeppelin/cluster/meta/ClusterMeta.java | 49 +-
.../zeppelin/cluster/meta/ClusterMetaEntity.java | 7 +-
.../zeppelin/conf/ZeppelinConfiguration.java | 8 +-
.../InterpreterOutputChangeWatcher.java | 7 +-
.../interpreter/SingleRowInterpreterResult.java | 4 +-
.../interpreter/launcher/InterpreterClient.java | 10 +
.../interpreter/launcher/InterpreterLauncher.java | 18 +-
.../interpreter/remote/PooledRemoteClient.java | 4 +
.../remote/RemoteInterpreterServer.java | 4 +-
.../zeppelin/interpreter/util/ProcessLauncher.java | 6 +-
.../zeppelin/scheduler/AbstractScheduler.java | 46 +-
.../apache/zeppelin/scheduler/FIFOScheduler.java | 2 +-
.../java/org/apache/zeppelin/scheduler/Job.java | 18 +-
.../org/apache/zeppelin/scheduler/JobListener.java | 9 +-
.../zeppelin/scheduler/JobProgressPoller.java | 4 +-
.../zeppelin/scheduler/JobWithProgressPoller.java | 1 -
.../zeppelin/scheduler/ParallelScheduler.java | 2 +-
.../org/apache/zeppelin/scheduler/Scheduler.java | 8 +-
.../zeppelin/cluster/ClusterMultiNodeTest.java | 37 +-
.../zeppelin/cluster/ClusterSingleNodeTest.java | 46 +-
.../zeppelin/conf/ZeppelinConfigurationTest.java | 25 +-
.../java/org/apache/zeppelin/dep/BooterTest.java | 31 +-
.../zeppelin/dep/DependencyResolverTest.java | 57 +-
.../display/AngularObjectRegistryTest.java | 15 +-
.../apache/zeppelin/display/AngularObjectTest.java | 16 +-
.../java/org/apache/zeppelin/display/GUITest.java | 42 +-
.../org/apache/zeppelin/display/InputTest.java | 17 +-
.../zeppelin/helium/ApplicationLoaderTest.java | 26 +-
.../apache/zeppelin/helium/HeliumPackageTest.java | 22 +-
.../interpreter/InterpreterContextTest.java | 10 +-
.../interpreter/InterpreterHookRegistryTest.java | 26 +-
.../InterpreterOutputChangeWatcherTest.java | 63 +-
.../interpreter/InterpreterOutputTest.java | 41 +-
.../interpreter/InterpreterResultTest.java | 64 +-
.../zeppelin/interpreter/InterpreterTest.java | 12 +-
.../interpreter/LazyOpenInterpreterTest.java | 16 +-
.../SingleRowInterpreterResultTest.java | 15 +-
.../zeppelin/interpreter/ZeppCtxtVariableTest.java | 91 ++-
.../zeppelin/interpreter/ZeppelinContextTest.java | 15 +-
.../launcher/InterpreterLauncherTest.java | 4 +-
.../remote/RemoteInterpreterServerTest.java | 38 +-
.../remote/RemoteInterpreterUtilsTest.java | 8 +-
.../interpreter/util/ByteBufferUtilTest.java | 9 +-
.../zeppelin/interpreter/util/SqlSplitterTest.java | 24 +-
.../zeppelin/resource/LocalResourcePoolTest.java | 14 +-
.../apache/zeppelin/resource/ResourceSetTest.java | 10 +-
.../org/apache/zeppelin/resource/ResourceTest.java | 37 +-
.../zeppelin/scheduler/FIFOSchedulerTest.java | 24 +-
.../org/apache/zeppelin/scheduler/JobTest.java | 34 +-
.../zeppelin/scheduler/ParallelSchedulerTest.java | 13 +-
.../tabledata/InterpreterResultTableDataTest.java | 11 +-
.../zeppelin/tabledata/TableDataProxyTest.java | 18 +-
.../zeppelin/tabledata/TableDataUtilsTest.java | 12 +-
zeppelin-jupyter-interpreter-shaded/pom.xml | 28 +
zeppelin-jupyter-interpreter/pom.xml | 13 +-
zeppelin-jupyter/pom.xml | 11 +-
zeppelin-plugins/launcher/cluster/pom.xml | 2 +-
.../launcher/ClusterInterpreterCheckThread.java | 6 +-
.../launcher/ClusterInterpreterLauncher.java | 27 +-
.../launcher/ClusterInterpreterLauncherTest.java | 51 +-
.../interpreter/launcher/ClusterMockTest.java | 24 +-
zeppelin-plugins/launcher/docker/pom.xml | 10 +-
.../launcher/DockerInterpreterLauncher.java | 6 +-
.../launcher/DockerInterpreterProcess.java | 153 ++---
.../interpreter/launcher/utils/TarUtils.java | 47 +-
.../launcher/DockerInterpreterProcessTest.java | 109 ++--
zeppelin-plugins/launcher/flink/pom.xml | 2 +-
.../launcher/FlinkInterpreterLauncher.java | 2 +-
zeppelin-plugins/launcher/k8s-standard/pom.xml | 2 +-
.../launcher/K8sRemoteInterpreterProcess.java | 6 +
.../launcher/K8sStandardInterpreterLauncher.java | 9 +-
.../launcher/K8sRemoteInterpreterProcessTest.java | 78 +--
.../interpreter/launcher/K8sSpecTemplateTest.java | 23 +-
.../K8sStandardInterpreterLauncherTest.java | 20 +-
.../interpreter/launcher/K8sUtilsTest.java | 29 +-
.../interpreter/launcher/PodPhaseWatcherTest.java | 28 +-
zeppelin-plugins/launcher/yarn/pom.xml | 2 +-
.../launcher/YarnInterpreterLauncher.java | 7 +-
.../launcher/YarnRemoteInterpreterProcess.java | 6 +
.../notebook/repo/FileSystemNotebookRepoTest.java | 22 +-
zeppelin-plugins/notebookrepo/gcs/pom.xml | 9 +
.../notebook/repo/GCSNotebookRepoTest.java | 218 ++++---
.../notebook/repo/GitHubNotebookRepoTest.java | 25 +-
zeppelin-plugins/notebookrepo/mongo/pom.xml | 5 +
.../notebook/repo/MongoNotebookRepoTest.java | 22 +-
.../zeppelin/notebook/repo/ToPathArrayTest.java | 108 ++--
.../notebook/repo/OSSNotebookRepoTest.java | 29 +-
zeppelin-plugins/notebookrepo/s3/pom.xml | 38 +-
.../zeppelin/notebook/repo/S3NotebookRepoTest.java | 40 +-
zeppelin-plugins/pom.xml | 4 +-
zeppelin-server/pom.xml | 55 +-
.../org/apache/zeppelin/rest/ClusterRestApi.java | 17 +-
.../apache/zeppelin/socket/ConnectionManager.java | 73 ++-
.../org/apache/zeppelin/socket/NotebookServer.java | 83 +--
.../cluster/ClusterAuthEventListenerTest.java | 10 +-
.../apache/zeppelin/cluster/ClusterEventTest.java | 65 +-
.../ClusterIntpSettingEventListenerTest.java | 6 +-
.../cluster/ClusterNoteEventListenerTest.java | 5 +-
.../configuration/RequestHeaderSizeTest.java | 18 +-
.../apache/zeppelin/metric/MetricEndpointTest.java | 25 +-
.../org/apache/zeppelin/realm/LdapRealmTest.java | 16 +-
.../org/apache/zeppelin/realm/PamRealmTest.java | 9 +-
.../org/apache/zeppelin/recovery/RecoveryTest.java | 36 +-
.../zeppelin/rest/ConfigurationsRestApiTest.java | 24 +-
.../zeppelin/rest/CredentialsRestApiTest.java | 28 +-
.../apache/zeppelin/rest/HeliumRestApiTest.java | 49 +-
.../zeppelin/rest/InterpreterRestApiTest.java | 54 +-
.../org/apache/zeppelin/rest/KnoxRestApiTest.java | 37 +-
.../zeppelin/rest/NotebookRepoRestApiTest.java | 22 +-
.../apache/zeppelin/rest/NotebookRestApiTest.java | 98 +--
.../zeppelin/rest/NotebookSecurityRestApiTest.java | 41 +-
.../apache/zeppelin/rest/SecurityRestApiTest.java | 41 +-
.../apache/zeppelin/rest/ZeppelinRestApiTest.java | 146 ++---
.../apache/zeppelin/security/DirAccessTest.java | 10 +-
.../org/apache/zeppelin/server/CorsFilterTest.java | 15 +-
.../zeppelin/server/HtmlAddonResourceTest.java | 14 +-
.../apache/zeppelin/service/AdminServiceTest.java | 15 +-
.../zeppelin/service/ConfigurationServiceTest.java | 24 +-
.../zeppelin/service/InterpreterServiceTest.java | 55 +-
.../zeppelin/service/NotebookServiceTest.java | 38 +-
.../service/ShiroAuthenticationServiceTest.java | 65 +-
.../zeppelin/service/shiro/AbstractShiroTest.java | 94 +++
.../zeppelin/socket/ConnectionManagerTest.java | 58 ++
.../apache/zeppelin/socket/NotebookServerTest.java | 86 +--
.../zeppelin/ticket/TicketContainerTest.java | 22 +-
.../org/apache/zeppelin/utils/CorsUtilsTest.java | 37 +-
.../org/apache/zeppelin/utils/PEMImporterTest.java | 165 ++---
zeppelin-web-angular/package-lock.json | 23 +-
zeppelin-web/package-lock.json | 698 ++++++++++++++++++---
zeppelin-web/package.json | 2 +-
zeppelin-web/pom.xml | 2 +-
.../notebook/paragraph/result/result.controller.js | 1 +
zeppelin-zengine/pom.xml | 21 +-
.../launcher/SparkInterpreterLauncher.java | 68 +-
.../launcher/StandardInterpreterLauncher.java | 5 +-
.../remote/ExecRemoteInterpreterProcess.java | 5 +
.../interpreter/remote/RemoteInterpreter.java | 14 +-
.../remote/RemoteInterpreterRunningProcess.java | 5 +
.../zeppelin/notebook/AuthorizationService.java | 13 +-
.../org/apache/zeppelin/notebook/NoteManager.java | 26 +-
.../org/apache/zeppelin/notebook/Notebook.java | 2 +-
.../notebook/NotebookAuthorizationInfoSaving.java | 4 +-
.../org/apache/zeppelin/notebook/Paragraph.java | 5 +-
.../zeppelin/notebook/ParagraphJobListener.java | 2 +-
.../zeppelin/notebook/repo/GitNotebookRepo.java | 33 +-
.../apache/zeppelin/scheduler/RemoteScheduler.java | 95 +--
.../zeppelin/conf/ZeppelinConfigurationTest.java | 43 +-
.../helium/HeliumApplicationFactoryTest.java | 26 +-
.../zeppelin/helium/HeliumBundleFactoryTest.java | 18 +-
.../zeppelin/helium/HeliumLocalRegistryTest.java | 12 +-
.../zeppelin/helium/HeliumOnlineRegistryTest.java | 16 +-
.../org/apache/zeppelin/helium/HeliumTest.java | 16 +-
.../interpreter/AbstractInterpreterTest.java | 11 +-
.../zeppelin/interpreter/ConfInterpreterTest.java | 7 +-
.../interpreter/InterpreterFactoryTest.java | 8 +-
.../interpreter/InterpreterSettingManagerTest.java | 14 +-
.../interpreter/InterpreterSettingTest.java | 21 +-
.../interpreter/ManagedInterpreterGroupTest.java | 8 +-
.../interpreter/SessionConfInterpreterTest.java | 4 +-
.../install/InstallInterpreterTest.java | 14 +-
.../launcher/SparkInterpreterLauncherTest.java | 12 +-
.../launcher/StandardInterpreterLauncherTest.java | 10 +-
.../lifecycle/TimeoutLifecycleManagerTest.java | 22 +-
.../recovery/FileSystemRecoveryStorageTest.java | 12 +-
.../recovery/LocalRecoveryStorageTest.java | 12 +-
.../interpreter/remote/AppendOutputRunnerTest.java | 10 +-
.../remote/RemoteAngularObjectTest.java | 8 +-
.../remote/RemoteInterpreterOutputTestStream.java | 12 +-
.../interpreter/remote/RemoteInterpreterTest.java | 22 +-
.../zeppelin/notebook/CredentialInjectorTest.java | 6 +-
.../org/apache/zeppelin/notebook/NoteAuthTest.java | 7 +-
.../apache/zeppelin/notebook/NoteManagerTest.java | 64 +-
.../org/apache/zeppelin/notebook/NoteTest.java | 66 +-
.../org/apache/zeppelin/notebook/NotebookTest.java | 35 +-
.../apache/zeppelin/notebook/ParagraphTest.java | 70 +--
.../zeppelin/notebook/ParagraphTextParserTest.java | 30 +-
.../notebook/repo/GitNotebookRepoTest.java | 116 +++-
.../repo/NotebookRepoSyncInitializationTest.java | 16 +-
.../notebook/repo/NotebookRepoSyncTest.java | 14 +-
.../notebook/repo/VFSNotebookRepoTest.java | 12 +-
.../apache/zeppelin/plugin/PluginManagerTest.java | 4 +-
.../resource/DistributedResourcePoolTest.java | 14 +-
.../zeppelin/scheduler/RemoteSchedulerTest.java | 19 +-
.../apache/zeppelin/search/LuceneSearchTest.java | 18 +-
.../zeppelin/storage/LocalConfigStorageTest.java | 4 +-
.../org/apache/zeppelin/user/CredentialsTest.java | 4 +-
.../org/apache/zeppelin/user/EncryptorTest.java | 6 +-
.../java/org/apache/zeppelin/util/UtilTest.java | 5 +-
294 files changed, 4667 insertions(+), 4830 deletions(-)
rename flink/flink-scala-parent/src/test/resources/{init_stream.scala =>
init_stream.scala2} (100%)
delete mode 100644
flink/flink1.12-shims/src/main/java/org/apache/zeppelin/flink/Flink112SqlInterpreter.java
delete mode 100644
flink/flink1.12-shims/src/main/java/org/apache/zeppelin/flink/shims112/SqlCommandParser.java
delete mode 100644
flink/flink1.12-shims/src/main/scala/org/apache/zeppelin/flink/shims112/Flink112ScalaShims.scala
rename flink/{flink1.12-shims => flink1.16-shims}/pom.xml (88%)
rename
flink/{flink1.12-shims/src/main/java/org/apache/zeppelin/flink/Flink112Shims.java
=> flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116Shims.java}
(53%)
copy
flink/{flink1.15-shims/src/main/java/org/apache/zeppelin/flink/Flink115SqlInterpreter.java
=>
flink1.16-shims/src/main/java/org/apache/zeppelin/flink/Flink116SqlInterpreter.java}
(99%)
copy flink/{flink1.15-shims =>
flink1.16-shims}/src/main/java/org/apache/zeppelin/flink/PrintUtils.java (100%)
copy flink/{flink1.15-shims =>
flink1.16-shims}/src/main/java/org/apache/zeppelin/flink/TimestampStringUtils.java
(100%)
rename flink/{flink1.12-shims/src/main/java/org/apache/zeppelin/flink/shims112
=>
flink1.16-shims/src/main/java/org/apache/zeppelin/flink/shims116}/CollectStreamTableSink.java
(98%)
copy java/src/test/{ =>
java}/org/apache/zeppelin/java/JavaInterpreterTest.java (100%)
rename java/src/test/{org/apache/zeppelin/java/JavaInterpreterTest.java =>
java/org/apache/zeppelin/java/JavaInterpreterUtilsTest.java} (60%)
delete mode 100644
java/src/test/org/apache/zeppelin/java/JavaInterpreterUtilsTest.java
copy testing/{env_python_3_with_flink_114.yml =>
env_python_3_with_flink_116.yml} (93%)
delete mode 100644
zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest112.java
delete mode 100644
zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinFlinkClusterTest112.java
create mode 100644
zeppelin-server/src/test/java/org/apache/zeppelin/service/shiro/AbstractShiroTest.java
create mode 100644
zeppelin-server/src/test/java/org/apache/zeppelin/socket/ConnectionManagerTest.java
