This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/bigquery/com.google.guava-guava-32.0.0-jre in repository https://gitbox.apache.org/repos/asf/zeppelin.git
discard 20326ebf6a Bump guava from 24.1.1-jre to 32.0.0-jre in /bigquery add 1e9c7fd049 Update kubernetes client to 5.4.1 and fix unit tests (#4133) add 5c435ef378 Upgraded h2 version in jdbc (#4618) add 7c8685a2d7 [HOTFIX] Add bank.csv for integration test (#4617) add cb8a4f5ff5 Remove ivy and oro (#4622) add 55a614ad16 [ZEPPELIN-5933] Polish jetty (#4621) add 02cbd6ee24 [HOTFIX] Change the location of bank.csv to fix the integration tests (#4623) add 50459b5f2d [MINOR] Change notification emails (#4626) add 3de1a49140 [ZEPPELIN-5902] Support Spark 3.4 (#4586) add 3f9e98e183 Bump shiro-core from 1.9.1 to 1.10.0 (#4481) add 9ac9876b47 Bump snappy-java from 1.1.8.4 to 1.1.10.1 in /cassandra (#4619) add cc66ce206c Update jetty to latest 9.x version (#4627) add 66b958d039 [ZEPPELIN-5935] Update jsoup version (#4625) add df84affca4 Bump h2 from 2.1.210 to 2.2.220 in /jdbc (#4630) add f025a697c1 [HOTFIX] Validate note name (#4632) add e3a3468bfb [HOTFIX] avoid password leaks (#4634) add 319dee60c4 fixed minor formatting issues preventing the full build (#4620) add b5a860833b Install holoview 1.16, 1.17 drops python 3.7 support see https://github.com/holoviz/holoviews/pull/5695 (#4638) add 2601e91415 Execute checkstyle during default build (#4637) add 12c76a74b9 [ZEPPELIN-5207] Build with JDK 11 in CI (#4497) add 8ed7bff3eb [ZEPPELIN-5946] Drop Spark 2.4,3.0,3.1 Support (#4640) add ed958b538d [ZEPPELIN-5945] Build Zeppelin-Distribution with JDK11 and use Spark 3.3 as default (#4639) add 026a74d40f update docs to download redshift jdbc dependencies on migrated repo (#4642) add 5eb9824587 [ZEPPELIN-5955] migrate cassandra (#4649) add b1fbb8a492 [ZEPPELIN-5951] migrate bigquery to Junit5 (#4645) add 6181bfe42e [ZEPPELIN-5954] migrate elasticsearch to Junit5 (#4648) add 989bb2117b [ZEPPELIN-5950] Migrate sparql to Junit5 (#4644) add c4b24993f1 [ZEPPELIN-5952] migrate mongodb to Junit5 (#4646) add 0a48d9944c [ZEPPELIN-5949] Update testcontainers and migrate neo4j to Junit5 (#4643) add ada0ae0910 Bump org.apache.spark:spark-core_2.12 in /spark/spark3-shims (#4650) add 0e14cd3d29 [ZEPPELIN-5848] migrate influxdb to Junit5 (#4647) add 1c42e00530 [ZEPPELIN-5961] migrate markdown interpreter to JUnit5 (#4656) add e8aff2468a [ZEPPELIN-5960] migrate submarine to JUnit5 (#4655) add fade856fe6 [ZEPPELIN-5958] Migrate shell to JUnit5 (#4653) add c1659934c9 [ZEPPELIN-5959] migrate livy to JUnit5 (#4654) add 11f6aa6f29 [ZEPPELIN-5848] Junit5 Migration (#4641) add c86bfadaa5 [ZEPPELIN-5965] Remove Kotlin Interpreter (#4659) add 5de2d035fa [ZEPPELIN-5962] LivyInterpreter support more parameter when create session (#4657) add d67d834bec [ZEPPELIN-5964] Fix renaming bug (#4658) add ee3b053ac9 [ZEPPELIN-5792][FRONT_BUILD] Remove bower (#4651) add 85bb3b4ca2 Bump org.xerial.snappy:snappy-java in /cassandra (#4664) add 3ebb815737 [ZEPPELIN-5946][FOLLOWUP] Use Spark 3.4.1 in default (#4652) add 6c85e87967 [MINOR][NOTICE] Update copyright year in NOTICE (#4666) add 3d700fbe73 [ZEPPELIN-5967] Remove support for deb packaging (#4670) add b9cb004515 [ZEPPELIN-5946][FOLLOWUP] Clean up code for legacy Spark versions (#4668) add b5d75d4af3 [ZEPPELIN-5968] Bump Jetty 9.4.52.v20230823 (#4673) add afd4c3ec10 [ZEPPELIN-5966] Support Spark 3.5 (#4665) add fb9d2045f3 Bump @babel/traverse from 7.6.3 to 7.23.2 in /zeppelin-web-angular (#4679) add 9680241285 Bump guava from 24.1.1-jre to 32.0.0-jre in /shell (#4615) add efadcd6aea [ZEPPELIN-5972] Support Flink 1.17 (#4677) add 5e68a916ee [MINOR] Remove unused conda env for Flink 1.12 (#4680) add 579074ea25 [ZEPPELIN-3725] Fix SQL injection (#4676) add 4352a10ab9 [ZEPPELIN-5875] Add: z.show works with subtypes of DataFrame (#4683) add 9dadde36d8 [ZEPPELIN-5978] Remove support for old Flink 1.13 and 1.14 (#4688) add 73e1aa37d4 [ZEPPELIN-5979] Support and use Python 3.9 in default (#4690) add 6a388a9b54 [MINOR] Fix log message in YarnAppMonitor (#4695) add ebb03865f2 [ZEPPELIN-5980] Merge zeppelin-display into spark-interperter (#4692) add a3723c552a [ZEPPELIN-5983] Upgrade to NodeJS 16 (#4696) add 464761e3a3 [ZEPPELIN-5982] Merge flink-scala-parent module into flink-scala-2.12 (#4694) add c9c3437a11 [ZEPPELIN-5970][ZEPPELIN-5971] bugs occur when zeppelin.livy.tableWithUTFCharacters is enabled (#4675) add 56da029ffe remove global scala-* profiles (#4698) add 7586318cca [MINOR] Update jdbc.md Change postgres username (#4704) add 8de6804027 Bump mathjax from 2.7.0 to 3.0.0 in /zeppelin-web (#4705) add 8ddf7294fe Bump org.apache.shiro:shiro-core from 1.10.0 to 1.13.0 (#4703) add 4bbd05b349 Bump follow-redirects from 1.15.3 to 1.15.4 in /zeppelin-web (#4702) add 6294cce64d Bump follow-redirects from 1.15.3 to 1.15.4 in /zeppelin-web-angular (#4701) add cfbdab07f2 [MINOR] Upgrade jackson version in /zeppelin-server (#4635) add 057480f9d6 [HOTFIX] Disable shell interpreter (#4708) add cb6763d516 Fix GCSNotebookRepoTests (#4711) add 49e2740a1d [HOTFIX] Check permission when updating cron information (#4631) add 0d5f79085f [MINOR] Change minimum java version to 11 in docs (#4710) add 01231e6292 [HOTFIX] Change the link of `helium.json` from S3 to zeppelin.apache.org (#4713) add e65b5430e4 [ZEPPELIN-5990] Disable sensitive configuration for JDBC url (#4709) add a57b4b22a7 [ZEPPELIN-5995] Update Kubernetes Library and hopefully fix flaky tests (#4712) add 207d47f431 [MINOR] Set Snapshot version to 0.12.0-SNAPSHOT (#4720) add 362a2e4b97 Bump org.postgresql:postgresql from 42.4.3 to 42.7.2 in /jdbc (#4723) add 65d0bcc1ee [HOTFIX] Escape Ldap search filters (#4714) add dd08a3966e [HOTFIX] Escape envs when using `.conf` (#4715) add 50efcf82f1 Fix the new zeppelin ui. The specific reason is that the use of excessively wide column widths resulted in the remaining fields being squeezed out of the screen, and nz table did not have a scroll bar set to display scrolling. (#4727) add 129b218144 Bump ip from 1.1.8 to 1.1.9 in /zeppelin-web (#4724) add ccf1a992da Bump lodash from 4.17.15 to 4.17.21 in /zeppelin-web-angular (#4689) add 83685795e0 [HOTFIX] Escape HeliumPackage information (#4728) add d0a71c7049 [NO-ISSUE] Use reload4j instead of log4j (#4719) add 9cfc4bd815 [NO-ISSUE] Upgrade org.json jar (#4722) add 0f366d8a00 [ZEPPELIN-6001] k8s images fix (#4729) add 8febca4561 [ZEPPELIN-6000] Polish some files mainly in zengine (#4731) add 57331efb63 [ZEPPELIN-6003] Log source info of SQL in JDBCInterpreter (#4732) add 3bf19f4414 [ZEPPELIN-6002] Fix completer NPE (#4730) add 74e22ea6fc [ZEPPELIN-5986] Bump Maven surefire/failsafe plugins to recover JUnit5 tests (#4734) add 8b8848ad82 [ZEPPELIN-6005] Update Kyuubi JDBC docs (#4738) add 15d175a0a0 Bump org.apache.commons:commons-configuration2 from 2.8.0 to 2.10.1 (#4740) add f4dcdfdf61 [MINOR] Fix missing changed versions (#4737) add 24b88da551 Bump com.nimbusds:nimbus-jose-jwt in /zeppelin-server (#4733) add 7f2be73ca7 [ZEPPELIN-6007] Enhance release scripts for tar shasum commands detection (#4747) add f2253f1ee6 [ZEPPELIN-6008] Fix parameter usage of bokeh in test case (#4748) add fa6e3ee3b8 [ZEPPELIN-5969] Remove Hadoop2 and move to Hadoop3 shaded client (#4691) add 911f97d914 [HOTFIX] Remove rendering helium description as HTML in Frontend (#4755) add df865f0e59 Bump express from 4.18.2 to 4.19.2 in /zeppelin-web-angular (#4744) add b61bfb55db update scripts/docker/zeppelin/bin/Dockerfile to JDK11 (#4753) add 3c6051221f Bump some apache common libs (#4757) add 67098fdd4a [ZEPPELIN-6006] Remove command line applications when downloading applications (#4746) add ca2481dd65 [ZEPPELIN-6016] Rewrite and enable Livy integration tests (#4743) add d16ef699bd [ZEPPELIN-6017] Revert changes about ZEPPELIN_IDENT_STRING in ZEPPELIN-5421 add e1329ebb6a [ZEPPELIN-6015] Update ci-action plugins (#4759) add 3eae255c10 [ZEPPELIN-5999] Reduce instance objects from Zeppelin (#4726) add 9c0f112d2e [ZEPPELIN-6019] Remove Submarine support (#4763) add abc4182ed3 [ZEPPELIN-6022] Skip decryption of credentials.json when file is empty (#4765) add ded5b29daf [ZEPPELIN-6018] Update gRPC version from 1.51.0 to 1.55.1 for successful Apache Zeppelin build on s390x architecture (#4758) add 19808172ed [ZEPPELIN-6027] Enhanced Integration with Apache Kyuubi (#4770) add dbf112fb03 [ZEPPELIN-6028] Enhance default value assignment for ZEPPELIN_IDENT_STRING (#4772) add 289e954db5 [ZEPPELIN-6029] Set COPYFILE_DISABLE=1 for macOS tar (#4774) add 91893ef5e9 [ZEPPELIN-6031] Clean up test directories even after unexpected exit of `AbstractInterpreterTest` (#4775) add 1111736142 [ZEPPELIN-6035] fix Cron setting for Notebook (#4777) add bcf3499fc8 [ZEPPELIN-6020] Remove TestUtils class in zeppelin-server (#4764) add b6b9a6629f [ZEPPELIN-6047] add setConfig method to action-bar.component.ts (#4771) add 61d7e7fde9 [ZEPPELIN-6034] Write a Dockerfile for shell interpreter (#4781) add 32a3be41b2 [ZEPPELIN-6026] Zeppelin Websocket code 1006 (#4784) add afc4141b97 [ZEPPELIN-6046] Fix(zeppelin-web): downgrade mathjax (3.0.0 -> 2.7.9) (#4786) add fb64356e57 [ZEPPELIN-6037] Unification of the ZeppelinConfiguration variable (#4782) add ad18bc099d [ZEPPELIN-6051] Skip the hidden files in notebook listing (reopen) (#4792) add 25b6001148 [HOTFIX] Escaping vulnerable text when modal opens (#4795) add 855f977e8f [ZEPPELIN-6050] Upgrade node, npm, yarn version of helium (#4799) add bad66e08b0 [ZEPPELIN-6053] Fix(zeppelin-web): Upgrade webpack-dev-server to enable HMR (#4787) add 18ffb3441f [ZEPPELIN-6040] Run mode "docker" not working properly (#4780) add 90780447af [ZEPPELIN-6032] Provide docker-compose-zeppelin-only.yml file for quick start (#4776) add 364a556dec [ZEPPELIN-6063] Fix delay in paragraph results rendering in new UI (#4801) add 32f2a8e67b [ZEPPELIN-6038] Unification of the Logger variable (#4793) add adcf047d89 [ZEPPELIN-6065] Remove broken links on the Apache Shiro authentication page (#4803) add d4f9e3eabd [ZEPPELIN-6066] Cleanups around Job and Scheduler (#4804) add 22bfdc7b7b [ZEPPELIN-6070] Script for checking out PR to local (#4805) add 7708b7150c [ZEPPELIN-6064] Change default web UI to new UI (#4802) add 13412adf4c [ZEPPELIN-6076] Fix rendering runtime dynamic components in new UI (#4809) add 950fe0b43b update org.apache.jena:jena-arq 3.12.0 to 4.2.0 (#4507) add baf62b22af Revert "update org.apache.jena:jena-arq 3.12.0 to 4.2.0 (#4507)" (#4814) add 6ad5baa5b3 [ZEPPELIN-6048] Write a Dockerfile for jdbc interpreter image build (#4794) add 1641ce1e52 [ZEPPELIN-6081] Fix Incorrect npm dev Command in README for zeppelin-web-angular (#4819) add 205014f0e4 [ZEPPELIN-6080] Add support for bq single region dataset query (#4815) add 940cf13935 [ZEPPELIN-6079] Fix Interpreter Configuration not working in new UI (#4818) add 6a71af0434 [ZEPPELIN-6073][BUILD] Canonicalize binary distribution tarball name (#4807) add 7ae89809da [ZEPPELIN-6088] Fix some flaky tests in zeppelin-integration (#4826) add a985c56ab4 [ZEPPELIN-1480] rework websocket sending to prevent partial frontend hangup (#4800) add 876d1dc7fd [ZEPPELIN-6071] Bump pty4j version to 0.12.10-jdk8 add 81783ddc4c [MINOR][LICENSE] Update NOTICE copyright add ad79848a90 [ZEPPELIN-6091] Drop support for Spark 3.2 add 35e1299126 [MINOR] Remove duplicate entry in .gitignore add 8720c46f36 [ZEPPELIN-6094] Fix broken impersonation add 72a3fd32a3 [ZEPPELIN-6054] Eliminate no-invalid-this warnings add e20cbbc16c [ZEPPELIN-6089][INFRA] Improve the merge PR script add ac48cc2db1 [ZEPPELIN-6099] Fix default ZEPPELIN_ANGULAR_WAR value add dfedb889a0 [ZEPPELIN-6108] Update MongoDB interpreter default shell value from mongo to mongosh add 9a28960c31 [ZEPPELIN-6104] Fix NPE when some MongoDB Interpreter configs are missing add b9ff26f0fa [ZEPPELIN-6105] add 'reload note' button to the new interface add 22855002c2 [ZEPPELIN-6102] Fix cron disabling and refresh issue add 4aff03bb71 [ZEPPELIN-6111] Update to include optional classic UI instructions add aa5abd572d [ZEPPELIN-6112] Fix running documentation website server add 640e2df3cd [ZEPPELIN-6072] Unify tooltips across action bar buttons, and add tooltips to paragraph controller add c5ccc8e584 [ZEPPELIN-3317] Update personalized mode document page add 17e1e739fc [ZEPPELIN-6110] Specify the Node.js engine version below 17 in the `web-angular` add 1633c52788 [ZEPPELIN-6114] Remove broken link for Google Analytics tracking add 334da53d7f [ZEPPELIN-6103] Revert "[HOTFIX] Escape envs when using `.conf` (#4715)" add 7fe18f49aa [ZEPPELIN-6089][INFRA][FOLLOWUP] Consider multiple digits when comparing version numbers add 383ae3b274 [ZEPPELIN-6117][INFRA] Remove deprecated Mambaforge add 79f30d5fed [ZEPPELIN-6086] Remove Spark Shims and unofficial support for Spark 4.0 add ca4cc5a5dd [ZEPPELIN-6101] Remove cluster interpreter add 5c1145fcd6 [ZEPPELIN-6116] Switch from `npm install --no-lockfile` to `npm ci` add 6e5f30c1c6 [ZEPPELIN-6078] Reduce interpreter size add 597f50c29e [ZEPPELIN-6119] Bump default Spark version to 3.5.3 add ed2ee4dfef [ZEPPELIN-6118] Remove unnecessary hadoop3 profile add 70013d725c [ZEPPELIN-6110][FOLLOWUP] Regenerate `package-lock.json` add 45c981be36 [ZEPPELIN-6125] Enable updates on the same branch using dev/checkout_zeppelin_pr.sh add 356b525cca [ZEPPELIN-6120] Jackson dependency governance add a2301f3491 [ZEPPELIN-6101][FOLLOWUP] Fix build with profile include-hadoop add 00b7c55369 [ZEPPELIN-6085] Add configuration option for setting the default UI add bdf5b067b6 [ZEPPELIN-6126] Remove hadoop dependencies out of the final zeppelin-web.war add cd31c31d8d [ZEPPELIN-6096] Cursor appears cut off in Notebook editor add de406a7e71 [ZEPPELIN-6097] Suppress duplicated error popup and fix broken CSS add 31c011b507 [ZEPPELIN-6127] Fix setting incorrect ZEPPELIN_ANGULAR_WAR value add 3af24504f3 [ZEPPELIN-6133] Bump Groovy from 2.4.7 to 2.4.21 add 06e1dc5edb [ZEPPELIN-6134] Test Livy 0.8 and Spark 3.2 with Java 11 add 4fb401f157 [ZEPPELIN-6132] Bump Maven 3.9.9 and Maven Wrapper 3.3.2 add b9860b6eda [ZEPPELIN-6090] Drop JDK8 from CI add 0203ee595e [ZEPPELIN-6137] Fix Windows compile tests add 414f4d1c47 [ZEPPELIN-6136] Java release to 11 add ea0802d24b [ZEPPELIN-6138] Update Apache Parent add 3575a3cf88 [NO-ISSUE] Implement Origin check for terminal interpreter WebSocket connections add f172b917ae [ZEPPELIN-6135] Fix clean goal not removing interpreter/ output(Spark,Flink) add e46337302d [ZEPPELIN-6095] validate decoded url in jdbc interpreter add 97b12e6a6c [ZEPPELIN-6147] Make interpreter searching case-insensitive in new ui add 80c88251a8 [ZEPPELIN-6146] Replace 'application/zpln' with '.zpln' in 'accept' attribute of file importer add 50e23f384e [ZEPPELIN-6140] Add logs to the runParagraph method add ce04862b58 [ZEPPELIN-6141] Update the link to the page where all issues are sorted add 4a7fdb16f3 [ZEPPELIN-6131] Update Interpreter to Store Values as Integers When Applicable add 0a7f86126e [ZEPPELIN-6145] Remove useless message type in Terminal Interpreter add d21e362861 [ZEPPELIN-6150] `zeppelin.sh` shall respect HADOOP_HOME to find `hadoop` command add ae48f71a56 [ZEPPELIN-6151] Remove AngularJS -> Angular Code Migration Suggestion Feature add f3551eb3a8 [ZEPPELIN-6143] Add Interpreter Event Server Port configuration option add b6e40d4224 [ZEPPELIN-6157] Download artifacts from CDN if available add db0ea40c68 [MINOR] Remove extra text from license (#4907) add 2717bed66b [ZEPPELIN-6168] Fix k8s interpreter service name removing all dots from pod name add a279ceb7cc [ZEPPELIN-6169] upgrade to bcpkix-jdk18on 1.80 add e8422bccf3 [MINOR] Update the description indicating the user should not use Zeppelin dev port(default 9000) (#4906) add 7afcf3e59d [ZEPPELIN-2729] Paragraph numbering add d95f43a358 [ZEPPELIN-6164] Fix the problem that the dep or property in the last … add 53be157c38 [ZEPPELIN-6175] Correction of linter errors in zeppelin-web add 2f31f8c6a7 [ZEPPELIN-6179] Switch to ubuntu 24.04 for GitHub-CI workflows add e928edb080 [ZEPPELIN-6158] Update Jetty and other libraries to use Jakarta add 08ebfc105b Bump guava from 24.1.1-jre to 32.0.0-jre in /bigquery 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 (20326ebf6a) \ N -- N -- N refs/heads/dependabot/maven/bigquery/com.google.guava-guava-32.0.0-jre (08ebfc105b) 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 | 6 +- .asf.yaml | 5 +- .github/workflows/core.yml | 285 +- .github/workflows/frontend.yml | 57 +- .github/workflows/quick.yml | 24 +- .gitignore | 18 +- .mvn/wrapper/MavenWrapperDownloader.java | 156 +- .mvn/wrapper/maven-wrapper.jar | Bin 50710 -> 0 bytes .mvn/wrapper/maven-wrapper.properties | 35 +- Dockerfile | 10 +- LICENSE | 27 - NOTICE | 4 +- README.md | 2 +- alluxio/pom.xml | 16 +- .../zeppelin/alluxio/AlluxioInterpreter.java | 10 +- angular/pom.xml | 2 +- bigquery/pom.xml | 6 +- .../zeppelin/bigquery/BigQueryInterpreter.java | 43 +- .../src/main/resources/interpreter-setting.json | 7 + .../zeppelin/bigquery/BigQueryInterpreterTest.java | 36 +- .../src/{main => test}/resources/constants.json | 0 .../src/test/resources/log4j.properties | 0 bin/common.cmd | 4 + bin/common.sh | 10 +- bin/interpreter.sh | 18 +- bin/zeppelin-daemon.sh | 16 +- bin/zeppelin.sh | 4 +- build-tools/pom.xml | 2 +- .../src/main/resources/zeppelin/checkstyle.xml | 29 +- cassandra/pom.xml | 17 +- .../cassandra/CassandraInterpreterTest.java | 751 +- .../zeppelin/cassandra/InterpreterLogicTest.java | 348 +- .../zeppelin/cassandra/BoundValuesParserTest.scala | 8 +- .../zeppelin/cassandra/CqlFormatterTest.scala | 8 +- .../zeppelin/cassandra/EnhancedSessionTest.scala | 4 +- .../zeppelin/cassandra/ParagraphParserTest.scala | 15 +- conf/interpreter-list | 36 +- conf/zeppelin-env.cmd.template | 2 +- conf/zeppelin-env.sh.template | 5 +- conf/zeppelin-site.xml.template | 22 +- dev/change_scala_version.sh | 75 - dev/change_zeppelin_version.sh | 6 + dev/checkout_zeppelin_pr.sh | 66 + dev/common_release.sh | 11 +- dev/create_release.sh | 9 +- dev/merge_zeppelin_pr.py | 671 +- dev/publish_release.sh | 6 +- dev/test_zeppelin_pr.py | 111 - docs/Gemfile | 6 + docs/Gemfile.lock | 324 +- docs/README.md | 4 +- docs/_config.yml | 6 +- docs/_includes/JB/setup | 4 +- docs/_includes/themes/zeppelin/_navigation.html | 2 - .../zeppelin/img/docs-img/spark_SPARK_HOME16.png | Bin 123514 -> 0 bytes .../zeppelin/img/docs-img/spark_SPARK_HOME24.png | Bin 122833 -> 0 bytes .../zeppelin/img/docs-img/spark_deprecate.png | Bin 176802 -> 0 bytes .../zeppelin/img/ui-img/switch_to_classic_ui.png | Bin 0 -> 18455 bytes .../contribution/how_to_contribute_code.md | 7 +- .../contribution/useful_developer_tools.md | 7 +- docs/development/helium/overview.md | 2 +- docs/index.md | 2 - docs/interpreter/bigquery.md | 5 + docs/interpreter/flink.md | 14 +- docs/interpreter/jdbc.md | 30 +- docs/interpreter/kotlin.md | 84 - docs/interpreter/mongodb.md | 4 +- docs/interpreter/python.md | 2 +- docs/interpreter/r.md | 2 +- docs/interpreter/spark.md | 39 +- docs/interpreter/submarine.md | 407 - docs/quickstart/docker.md | 1 - docs/quickstart/explore_ui.md | 29 +- docs/quickstart/install.md | 4 +- docs/quickstart/kubernetes.md | 16 +- docs/setup/basics/how_to_build.md | 57 +- docs/setup/deployment/flink_and_spark_cluster.md | 63 +- docs/setup/operation/configuration.md | 33 + docs/setup/security/shiro_authentication.md | 4 +- docs/usage/interpreter/installation.md | 69 +- docs/usage/interpreter/user_impersonation.md | 2 +- docs/usage/other_features/personalized_mode.md | 7 + elasticsearch/pom.xml | 12 +- .../elasticsearch/ElasticsearchInterpreter.java | 14 +- .../ElasticsearchInterpreterTest.java | 104 +- .../client/ElasticsearchClientTypeBuilderTest.java | 28 +- .../client/ElasticsearchClientTypeTest.java | 12 +- file/pom.xml | 2 +- .../org/apache/zeppelin/file/FileInterpreter.java | 8 +- .../apache/zeppelin/file/HDFSFileInterpreter.java | 21 +- .../zeppelin/file/HDFSFileInterpreterTest.java | 52 +- flink-cmd/pom.xml | 12 +- flink/README.md | 37 +- flink/flink-scala-2.11/flink-scala-parent | 1 - flink/flink-scala-2.11/pom.xml | 83 - .../org/apache/zeppelin/flink/FlinkExprTyper.scala | 75 - .../zeppelin/flink/FlinkILoopInterpreter.scala | 240 - .../zeppelin/flink/FlinkScala211Interpreter.scala | 54 - flink/flink-scala-2.12/flink-scala-parent | 1 - flink/flink-scala-2.12/pom.xml | 1239 +- .../flink/ApplicationModeExecutionEnvironment.java | 0 .../flink/ApplicationModeStreamEnvironment.java | 0 .../zeppelin/flink/FlinkBatchSqlInterpreter.java | 0 .../apache/zeppelin/flink/FlinkInterpreter.java | 5 +- .../apache/zeppelin/flink/FlinkSqlInterpreter.java | 2 +- .../zeppelin/flink/FlinkStreamSqlInterpreter.java | 0 .../org/apache/zeppelin/flink/HadoopUtils.java | 0 .../apache/zeppelin/flink/IPyFlinkInterpreter.java | 0 .../java/org/apache/zeppelin/flink/JobManager.java | 0 .../apache/zeppelin/flink/PyFlinkInterpreter.java | 0 .../org/apache/zeppelin/flink/TableEnvFactory.java | 0 .../apache/zeppelin/flink/internal/JarHelper.java | 0 .../flink/internal/ScalaShellEnvironment.java | 0 .../internal/ScalaShellStreamEnvironment.java | 0 .../zeppelin/flink/sql/AbstractStreamSqlJob.java | 2 +- .../zeppelin/flink/sql/AppendStreamSqlJob.java | 2 +- .../zeppelin/flink/sql/SingleRowStreamSqlJob.java | 0 .../zeppelin/flink/sql/UpdateStreamSqlJob.java | 0 .../src/main/resources/interpreter-setting.json | 2 +- .../src/main/resources/python/zeppelin_ipyflink.py | 0 .../src/main/resources/python/zeppelin_pyflink.py | 0 .../zeppelin/flink/FlinkScala212Interpreter.scala | 6 +- .../zeppelin/flink/FlinkScalaInterpreter.scala | 8 +- .../zeppelin/flink/FlinkZeppelinContext.scala | 0 .../zeppelin/flink/internal/FlinkILoop.scala | 0 .../zeppelin/flink/internal/FlinkShell.scala | 0 .../flink/FlinkBatchSqlInterpreterTest.java | 0 .../zeppelin/flink/FlinkInterpreterTest.java | 61 +- .../zeppelin/flink/FlinkSqlInterpreterTest.java | 11 +- .../flink/FlinkStreamSqlInterpreterTest.java | 4 +- .../zeppelin/flink/IPyFlinkInterpreterTest.java | 93 +- .../java/org/apache/zeppelin/flink/JavaLower.java | 0 .../java/org/apache/zeppelin/flink/JavaUpper.java | 0 .../org/apache/zeppelin/flink/JobManagerTest.java | 8 +- .../zeppelin/flink/PyFlinkInterpreterTest.java | 31 +- .../src/test/resources/flink-conf.yaml | 0 .../src/test/resources/init_stream.scala2 | 0 .../src/test/resources/log4j.properties | 0 .../src/test/resources/log4j2.properties | 0 flink/flink-scala-parent/pom.xml | 1043 - flink/flink-shims/pom.xml | 2 +- .../java/org/apache/zeppelin/flink/FlinkShims.java | 3 + .../org/apache/zeppelin/flink/FlinkVersion.java | 4 +- flink/flink1.13-shims/pom.xml | 213 - .../org/apache/zeppelin/flink/Flink113Shims.java | 380 - .../zeppelin/flink/Flink113SqlInterpreter.java | 562 - .../flink/shims113/Flink113ScalaShims.scala | 36 - .../flink/shims114/CollectStreamTableSink.java | 97 - flink/flink1.15-shims/pom.xml | 6 +- flink/flink1.16-shims/pom.xml | 6 +- .../org/apache/zeppelin/flink/Flink116Shims.java | 2 - flink/{flink1.14-shims => flink1.17-shims}/pom.xml | 27 +- .../org/apache/zeppelin/flink/Flink117Shims.java} | 89 +- .../zeppelin/flink/Flink117SqlInterpreter.java} | 12 +- .../java/org/apache/zeppelin/flink/PrintUtils.java | 0 .../zeppelin/flink/TimestampStringUtils.java | 0 .../flink/shims117}/CollectStreamTableSink.java | 2 +- flink/pom.xml | 56 +- groovy/pom.xml | 4 +- .../apache/zeppelin/groovy/GroovyInterpreter.java | 17 +- hbase/pom.xml | 51 +- .../apache/zeppelin/hbase/HbaseInterpreter.java | 14 +- .../zeppelin/hbase/HbaseInterpreterTest.java | 33 +- helium-dev/pom.xml | 2 +- .../helium/ZeppelinApplicationDevServer.java | 12 +- .../apache/zeppelin/helium/ZeppelinDevServer.java | 4 +- influxdb/pom.xml | 12 +- .../zeppelin/influxdb/InfluxDBInterpeterTest.java | 37 +- java/pom.xml | 2 +- .../org/apache/zeppelin/java/JavaInterpreter.java | 2 +- .../java/org/apache/zeppelin/java/StaticRepl.java | 8 +- .../apache/zeppelin/java/JavaInterpreterTest.java | 22 +- .../zeppelin/java/JavaInterpreterUtilsTest.java | 17 +- jdbc/Dockerfile | 50 + jdbc/README.md | 36 + jdbc/pom.xml | 214 +- .../org/apache/zeppelin/jdbc/JDBCInterpreter.java | 47 +- .../org/apache/zeppelin/jdbc/SqlCompleter.java | 55 +- .../BeelineInPlaceUpdateStream.java | 37 +- .../apache/zeppelin/jdbc/kyuubi/KyuubiUtils.java | 118 + .../apache/zeppelin/jdbc/kyuubi/ProgressBar.java | 53 + jdbc/src/main/resources/interpreter-setting.json | 21 + .../jdbc/JDBCInterpreterInterpolationTest.java | 9 +- .../apache/zeppelin/jdbc/JDBCInterpreterTest.java | 75 +- .../org/apache/zeppelin/jdbc/SqlCompleterTest.java | 44 +- k8s/zeppelin-server.yaml | 6 +- kotlin/README.md | 83 - kotlin/pom.xml | 117 - .../apache/zeppelin/kotlin/KotlinInterpreter.java | 189 - .../kotlin/completion/KotlinCompleter.java | 68 - .../zeppelin/kotlin/completion/KotlinKeywords.java | 104 - .../zeppelin/kotlin/context/KotlinReceiver.java | 37 - .../zeppelin/kotlin/reflect/ContextUpdater.java | 160 - .../kotlin/reflect/KotlinFunctionInfo.java | 69 - .../zeppelin/kotlin/reflect/KotlinReflectUtil.java | 37 - .../kotlin/reflect/KotlinVariableInfo.java | 60 - .../apache/zeppelin/kotlin/repl/ClassWriter.java | 91 - .../apache/zeppelin/kotlin/repl/KotlinRepl.java | 272 - .../kotlin/repl/building/KotlinReplProperties.java | 129 - .../kotlin/repl/building/ReplBuilding.java | 108 - kotlin/src/main/resources/interpreter-setting.json | 28 - .../zeppelin/kotlin/KotlinInterpreterTest.java | 326 - livy/README.md | 9 +- livy/pom.xml | 222 +- .../apache/zeppelin/livy/BaseLivyInterpreter.java | 21 +- .../zeppelin/livy/LivySparkSQLInterpreter.java | 39 +- .../java/org/apache/zeppelin/livy/LivyVersion.java | 4 +- .../apache/zeppelin/livy/LivyInterpreterIT.java | 205 +- .../zeppelin/livy/LivySQLInterpreterTest.java | 38 +- .../org/apache/zeppelin/livy/WithLivyServer.java | 143 + livy/src/test/resources/livy_tutorial_1.scala | 2 +- markdown/pom.xml | 2 +- .../apache/zeppelin/markdown/FlexmarkParser.java | 3 +- .../org/apache/zeppelin/markdown/Markdown.java | 4 +- .../zeppelin/markdown/FlexmarkParserTest.java | 92 +- .../zeppelin/markdown/Markdown4jParserTest.java | 16 +- .../org/apache/zeppelin/markdown/MarkdownTest.java | 19 +- mongodb/pom.xml | 2 +- .../zeppelin/mongodb/MongoDbInterpreter.java | 8 +- .../src/main/resources/interpreter-setting.json | 2 +- .../zeppelin/mongodb/MongoDbInterpreterTest.java | 54 +- mvnw | 356 +- mvnw.cmd | 388 +- neo4j/pom.xml | 11 +- .../graph/neo4j/Neo4jConnectionManager.java | 2 +- .../graph/neo4j/Neo4jCypherInterpreterTest.java | 58 +- .../2. Spark Basic Features_2A94M5J1Z.zpln | 2 +- .../Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln | 2 +- pom.xml | 1353 +- python/pom.xml | 2 +- .../apache/zeppelin/python/IPythonInterpreter.java | 8 +- .../zeppelin/python/PythonCondaInterpreter.java | 12 +- .../zeppelin/python/PythonDockerInterpreter.java | 6 +- .../apache/zeppelin/python/PythonInterpreter.java | 9 +- .../org/apache/zeppelin/python/PythonUtils.java | 41 +- .../src/main/resources/python/zeppelin_context.py | 2 +- .../zeppelin/python/BasePythonInterpreterTest.java | 111 +- .../zeppelin/python/IPythonInterpreterTest.java | 158 +- .../python/PythonCondaInterpreterTest.java | 24 +- .../python/PythonDockerInterpreterTest.java | 12 +- .../python/PythonInterpreterMatplotlibTest.java | 49 +- .../python/PythonInterpreterPandasSqlTest.java | 137 +- .../python/PythonInterpreterPandasSqlTestTest.java | 33 +- .../zeppelin/python/PythonInterpreterTest.java | 33 +- rlang/pom.xml | 27 +- .../java/org/apache/zeppelin/r/IRInterpreter.java | 11 +- .../java/org/apache/zeppelin/r/RInterpreter.java | 11 +- .../java/org/apache/zeppelin/r/SparkRBackend.java | 17 +- .../main/java/org/apache/zeppelin/r/ZeppelinR.java | 8 +- .../org/apache/zeppelin/r/ZeppelinRDisplay.java | 4 +- .../org/apache/zeppelin/r/IRInterpreterTest.java | 18 +- .../org/apache/zeppelin/r/RInterpreterTest.java | 36 +- .../apache/zeppelin/r/ShinyInterpreterTest.java | 47 +- scripts/docker/interpreter/Dockerfile | 20 +- .../spark_yarn_cluster/Dockerfile | 4 +- .../zeppelin-cpu-submarine-interpreter/Dockerfile | 20 - .../zeppelin-cpu-submarine-interpreter/build.sh | 19 - .../Dockerfile | 70 - .../zeppelin-gpu-submarine-interpreter/Dockerfile | 20 - .../zeppelin-gpu-submarine-interpreter/build.sh | 19 - .../Dockerfile | 72 - .../build.sh | 19 - scripts/docker/zeppelin-interpreter/Dockerfile | 54 +- .../docker/zeppelin-interpreter/conda_packages.txt | 22 - scripts/docker/zeppelin-interpreter/condarc | 5 + .../env_python_3_with_R.yml | 8 +- .../docker/zeppelin-interpreter/pip_packages.txt | 1 - scripts/docker/zeppelin-quick-start/README.md | 29 + .../docker-compose-zeppelin-only.yml} | 13 +- scripts/docker/zeppelin-server/Dockerfile | 10 +- scripts/docker/zeppelin/bin/Dockerfile | 12 +- shell/Dockerfile | 50 + shell/HTERM.md | 197 - shell/PTY4J.md | 135 - shell/README.md | 35 + shell/pom.xml | 12 +- .../apache/zeppelin/shell/TerminalInterpreter.java | 26 +- .../zeppelin/shell/terminal/TerminalThread.java | 19 +- .../zeppelin/shell/terminal/helper/IOHelper.java | 180 - .../shell/terminal/service/TerminalService.java | 18 +- .../websocket/TerminalSessionConfigurator.java | 25 +- .../shell/terminal/websocket/TerminalSocket.java | 33 +- shell/src/main/resources/html/js/index.js | 8 - .../main/resources/libpty/freebsd/x86/libpty.so | Bin 9978 -> 0 bytes .../main/resources/libpty/freebsd/x86_64/libpty.so | Bin 12370 -> 0 bytes .../main/resources/libpty/linux/ppc64le/libpty.so | Bin 72560 -> 0 bytes .../src/main/resources/libpty/linux/x86/libpty.so | Bin 10221 -> 0 bytes .../main/resources/libpty/linux/x86_64/libpty.so | Bin 13388 -> 0 bytes .../main/resources/libpty/macosx/x86/libpty.dylib | Bin 14156 -> 0 bytes .../resources/libpty/macosx/x86_64/libpty.dylib | Bin 14264 -> 0 bytes .../main/resources/libpty/win/x86/winpty-agent.exe | Bin 601624 -> 0 bytes shell/src/main/resources/libpty/win/x86/winpty.dll | Bin 524808 -> 0 bytes .../main/resources/libpty/win/x86_64/cyglaunch.exe | Bin 15360 -> 0 bytes .../resources/libpty/win/x86_64/winpty-agent.exe | Bin 749592 -> 0 bytes .../main/resources/libpty/win/x86_64/winpty.dll | Bin 656392 -> 0 bytes .../main/resources/libpty/win/xp/winpty-agent.exe | Bin 601624 -> 0 bytes shell/src/main/resources/libpty/win/xp/winpty.dll | Bin 524808 -> 0 bytes .../apache/zeppelin/shell/BaseInterpreterTest.java | 8 +- .../zeppelin/shell/ShellInterpreterTest.java | 25 +- .../zeppelin/shell/TerminalInterpreterTest.java | 168 +- .../shell/terminal/TerminalSocketTest.java | 55 +- spark-submit/pom.xml | 2 +- .../spark/submit/SparkSubmitInterpreter.java | 10 +- spark/README.md | 10 +- spark/interpreter/pom.xml | 295 +- .../spark/AbstractSparkScalaInterpreter.java | 5 - .../apache/zeppelin/spark/IPySparkInterpreter.java | 4 - .../zeppelin/spark/KotlinSparkInterpreter.java | 191 - .../apache/zeppelin/spark/PySparkInterpreter.java | 4 +- .../apache/zeppelin/spark/SparkIRInterpreter.java | 35 +- .../apache/zeppelin/spark/SparkInterpreter.java | 13 - .../apache/zeppelin/spark/SparkRInterpreter.java | 19 +- .../org/apache/zeppelin/spark/SparkVersion.java | 27 +- .../main/java/org/apache/zeppelin/spark/Utils.java | 21 +- .../spark/kotlin/KotlinZeppelinBindings.java | 52 - .../zeppelin/spark/kotlin/SparkKotlinReceiver.java | 43 - .../src/main/resources/interpreter-setting.json | 36 +- .../src/main/resources/python/zeppelin_pyspark.py | 4 +- .../display/angular/AbstractAngularElem.scala | 0 .../display/angular/AbstractAngularModel.scala | 0 .../angular/notebookscope/AngularElem.scala | 4 +- .../angular/notebookscope/AngularModel.scala | 0 .../angular/paragraphscope/AngularElem.scala | 4 +- .../angular/paragraphscope/AngularModel.scala | 0 .../zeppelin/spark/IPySparkInterpreterTest.java | 14 +- .../zeppelin/spark/KotlinSparkInterpreterTest.java | 246 - .../spark/PySparkInterpreterMatplotlibTest.java | 58 +- .../zeppelin/spark/PySparkInterpreterTest.java | 16 +- .../zeppelin/spark/SparkIRInterpreterTest.java | 14 +- .../zeppelin/spark/SparkInterpreterTest.java | 49 +- .../zeppelin/spark/SparkRInterpreterTest.java | 26 +- .../org/apache/zeppelin/spark/SparkShimsTest.java | 160 - .../zeppelin/spark/SparkShinyInterpreterTest.java | 40 +- .../zeppelin/spark/SparkSqlInterpreterTest.java | 77 +- .../org/apache/zeppelin/spark/SparkUtilsTest.java | 116 + .../apache/zeppelin/spark/SparkVersionTest.java | 44 +- .../display/angular/AbstractAngularElemTest.scala | 10 +- .../display/angular/AbstractAngularModelTest.scala | 11 +- .../angular/notebookscope/AngularElemTest.scala | 0 .../angular/notebookscope/AngularModelTest.scala | 0 .../angular/paragraphscope/AngularElemTest.scala | 0 .../angular/paragraphscope/AngularModelTest.scala | 0 spark/pom.xml | 24 +- spark/scala-2.11/pom.xml | 58 - .../scala-2.11/src/main/resources/log4j.properties | 50 - .../zeppelin/spark/SparkScala211Interpreter.scala | 325 - .../zeppelin/spark/SparkZeppelinContext.scala | 243 - spark/scala-2.12/pom.xml | 6 +- .../zeppelin/spark/SparkScala212Interpreter.scala | 20 +- .../zeppelin/spark/SparkZeppelinContext.scala | 9 +- spark/scala-2.13/pom.xml | 6 +- .../org/apache/zeppelin/spark/SparkILoop.scala | 2 +- .../zeppelin/spark/SparkScala213Interpreter.scala | 34 +- .../zeppelin/spark/SparkZeppelinContext.scala | 9 +- spark/{spark2-shims => spark-common}/pom.xml | 24 +- .../org/apache/zeppelin/spark/SparkUtils.java} | 101 +- spark/spark-scala-parent/pom.xml | 36 +- spark/spark-shims/pom.xml | 64 - .../java/org/apache/zeppelin/spark/SparkShims.java | 169 - .../org/apache/zeppelin/spark/Spark2Shims.java | 140 - spark/spark3-shims/pom.xml | 78 - sparql/pom.xml | 2 +- .../zeppelin/sparql/SparqlJenaEngineTest.java | 34 +- submarine/pom.xml | 172 - .../submarine/IPySubmarineInterpreter.java | 44 - .../zeppelin/submarine/PySubmarineInterpreter.java | 92 - .../zeppelin/submarine/SubmarineContext.java | 76 - .../zeppelin/submarine/SubmarineInterpreter.java | 268 - .../submarine/SubmarineShellInterpreter.java | 113 - .../submarine/commons/SubmarineCommand.java | 49 - .../submarine/commons/SubmarineConstants.java | 116 - .../zeppelin/submarine/commons/SubmarineUI.java | 244 - .../zeppelin/submarine/commons/SubmarineUtils.java | 301 - .../submarine/hadoop/FinalApplicationStatus.java | 24 - .../zeppelin/submarine/hadoop/HdfsClient.java | 379 - .../submarine/hadoop/YarnApplicationState.java | 27 - .../zeppelin/submarine/hadoop/YarnClient.java | 623 - .../zeppelin/submarine/job/SubmarineJob.java | 502 - .../zeppelin/submarine/job/SubmarineJobStatus.java | 52 - .../submarine/job/thread/JobRunThread.java | 242 - .../submarine/job/thread/TensorboardRunThread.java | 203 - .../src/main/resources/interpreter-setting.json | 314 - .../jinja_templates/submarine-job-run-tf.jinja | 55 - .../jinja_templates/submarine-tensorboard.jinja | 36 - .../ui_templates/submarine-command-options.json | 88 - .../ui_templates/submarine-dashboard.jinja | 157 - .../ui_templates/submarine-log-head.jinja | 24 - .../resources/ui_templates/submarine-usage.jinja | 111 - .../zeppelin/submarine/BaseInterpreterTest.java | 81 - .../apache/zeppelin/submarine/HdfsClientTest.java | 88 - .../zeppelin/submarine/JinjaTemplatesTest.java | 473 - .../submarine/PySubmarineInterpreterTest.java | 86 - .../submarine/SubmarineInterpreterTest.java | 105 - .../zeppelin/submarine/SubmarineJobTest.java | 87 - .../apache/zeppelin/submarine/YarnClientTest.java | 88 - .../src/test/resources/DefaultExecutorTest.sh | 19 - .../test/resources/app-v1-services-app_name.json | 145 - submarine/src/test/resources/log4j.properties | 47 - ...on_id-appattempts-appattempt_id-containers.json | 68 - ...v1-cluster-apps-application_id-appattempts.json | 19 - .../ws-v1-cluster-apps-application_id-failed.json | 59 - ...ws-v1-cluster-apps-application_id-finished.json | 60 - .../ws-v1-cluster-apps-application_id-running.json | 277 - testing/downloadLivy.sh | 22 +- testing/downloadSpark.sh | 8 +- testing/env_python_3.7_with_R.yml | 1 + testing/env_python_3.8_with_R.yml | 1 + ...on_3.8_with_R.yml => env_python_3.9_with_R.yml} | 1 + testing/env_python_3.yml | 28 +- testing/env_python_3_with_R.yml | 4 +- testing/env_python_3_with_R_and_tensorflow.yml | 6 +- testing/env_python_3_with_flink_113.yml | 29 - testing/env_python_3_with_flink_114.yml | 29 - testing/env_python_3_with_flink_115.yml | 1 + testing/env_python_3_with_flink_116.yml | 1 + ...ink_112.yml => env_python_3_with_flink_117.yml} | 3 +- testing/resources/bank.csv | 4522 +++ zeppelin-client-examples/pom.xml | 8 +- zeppelin-client/pom.xml | 10 +- zeppelin-common/pom.xml | 8 +- zeppelin-display/pom.xml | 169 - zeppelin-distribution/README.md | 2 +- zeppelin-distribution/build-infrastructure.md | 8 +- zeppelin-distribution/pom.xml | 235 +- .../src/assemble/distribution.xml | 11 +- zeppelin-distribution/src/bin_license/LICENSE | 117 +- zeppelin-distribution/src/deb/control/control | 26 - zeppelin-distribution/src/deb/control/prerm | 27 - zeppelin-distribution/src/deb/init.d/zeppelind | 36 - zeppelin-examples/pom.xml | 2 +- zeppelin-examples/zeppelin-example-clock/pom.xml | 16 +- .../apache/zeppelin/example/app/clock/Clock.java | 2 +- .../zeppelin-example-horizontalbar/pom.xml | 16 +- .../zeppelin-example-spell-echo/pom.xml | 17 +- .../zeppelin-example-spell-flowchart/pom.xml | 16 +- .../zeppelin-example-spell-markdown/pom.xml | 16 +- .../zeppelin-example-spell-translator/pom.xml | 16 +- zeppelin-integration/pom.xml | 115 +- .../org/apache/zeppelin/AbstractZeppelinIT.java | 82 +- .../java/org/apache/zeppelin/CommandExecutor.java | 10 +- .../test/java/org/apache/zeppelin/ProcessData.java | 20 +- .../java/org/apache/zeppelin/WebDriverManager.java | 247 +- .../java/org/apache/zeppelin/ZeppelinITUtils.java | 17 +- .../zeppelin/integration/AuthenticationIT.java | 221 +- .../apache/zeppelin/integration/InterpreterIT.java | 64 +- .../integration/InterpreterModeActionsIT.java | 584 +- .../zeppelin/integration/ParagraphActionsIT.java | 950 +- .../zeppelin/integration/PersonalizeActionsIT.java | 286 +- .../zeppelin/integration/SparkParagraphIT.java | 172 +- .../apache/zeppelin/integration/ZeppelinIT.java | 130 +- zeppelin-interpreter-integration/pom.xml | 185 +- .../zeppelin/integration/FlinkIntegrationTest.java | 72 +- .../integration/FlinkIntegrationTest113.java | 35 +- .../integration/FlinkIntegrationTest114.java | 34 +- .../zeppelin/integration/JdbcIntegrationTest.java | 58 +- .../zeppelin/integration/MiniHadoopCluster.java | 2 +- .../apache/zeppelin/integration/MiniZeppelin.java | 88 - .../zeppelin/integration/ShellIntegrationTest.java | 49 +- .../zeppelin/integration/SparkIntegrationTest.java | 167 +- .../integration/SparkIntegrationTest24.java | 51 - .../integration/SparkIntegrationTest30.java | 57 - .../integration/SparkIntegrationTest31.java | 57 - .../integration/SparkIntegrationTest32.java | 58 - .../integration/SparkIntegrationTest33.java | 42 +- .../integration/SparkIntegrationTest34.java | 19 +- .../integration/SparkSubmitIntegrationTest.java | 85 +- .../YarnInterpreterLauncherIntegrationTest.java | 72 +- .../integration/ZSessionIntegrationTest.java | 186 +- .../integration/ZeppelinClientIntegrationTest.java | 142 +- .../ZeppelinClientWithAuthIntegrationTest.java | 77 +- .../integration/ZeppelinFlinkClusterTest.java | 81 +- .../integration/ZeppelinFlinkClusterTest113.java | 33 +- .../integration/ZeppelinFlinkClusterTest114.java | 33 +- .../integration/ZeppelinFlinkClusterTest115.java | 23 +- .../integration/ZeppelinSparkClusterTest.java | 461 +- .../integration/ZeppelinSparkClusterTest24.java | 39 - .../integration/ZeppelinSparkClusterTest30.java | 40 - .../integration/ZeppelinSparkClusterTest31.java | 40 - .../integration/ZeppelinSparkClusterTest32.java | 40 - .../integration/ZeppelinSparkClusterTest33.java | 27 +- .../integration/ZeppelinSparkClusterTest34.java | 17 +- zeppelin-interpreter-parent/pom.xml | 22 +- zeppelin-interpreter-shaded/pom.xml | 9 +- zeppelin-interpreter/pom.xml | 105 +- .../zeppelin/cluster/BroadcastServiceAdapter.java | 44 - .../apache/zeppelin/cluster/ClusterCallback.java | 26 - .../apache/zeppelin/cluster/ClusterManager.java | 600 - .../zeppelin/cluster/ClusterManagerClient.java | 79 - .../zeppelin/cluster/ClusterManagerServer.java | 390 - .../apache/zeppelin/cluster/ClusterMonitor.java | 256 - .../zeppelin/cluster/ClusterPrimitiveType.java | 57 - .../zeppelin/cluster/ClusterStateMachine.java | 179 - .../zeppelin/cluster/event/ClusterEvent.java | 46 - .../cluster/event/ClusterEventListener.java | 28 - .../zeppelin/cluster/event/ClusterMessage.java | 73 - .../ZeppelinClusterMembershipEventListener.java | 50 - .../apache/zeppelin/cluster/meta/ClusterMeta.java | 145 - .../zeppelin/cluster/meta/ClusterMetaEntity.java | 58 - .../cluster/meta/ClusterMetaOperation.java | 26 - .../zeppelin/cluster/meta/ClusterMetaType.java | 25 - .../cluster/protocol/LocalRaftClientProtocol.java | 163 - .../cluster/protocol/LocalRaftProtocol.java | 58 - .../cluster/protocol/LocalRaftProtocolFactory.java | 57 - .../cluster/protocol/LocalRaftServerProtocol.java | 527 - .../protocol/RaftClientMessagingProtocol.java | 123 - .../cluster/protocol/RaftMessagingProtocol.java | 83 - .../protocol/RaftServerMessagingProtocol.java | 346 - .../zeppelin/conf/ZeppelinConfiguration.java | 148 +- .../zeppelin/dep/AbstractDependencyResolver.java | 18 +- .../main/java/org/apache/zeppelin/dep/Booter.java | 6 +- .../apache/zeppelin/dep/DependencyResolver.java | 9 +- .../apache/zeppelin/dep/RepositoryListener.java | 36 +- .../org/apache/zeppelin/dep/TransferListener.java | 14 +- .../org/apache/zeppelin/display/AngularObject.java | 4 +- .../org/apache/zeppelin/helium/Application.java | 6 +- .../apache/zeppelin/helium/ApplicationLoader.java | 2 +- .../org/apache/zeppelin/helium/HeliumPackage.java | 45 +- .../apache/zeppelin/helium/SpellPackageInfo.java | 5 + .../apache/zeppelin/interpreter/Interpreter.java | 6 + .../zeppelin/interpreter/InterpreterContext.java | 5 +- .../zeppelin/interpreter/InterpreterOption.java | 15 +- .../zeppelin/interpreter/InterpreterResult.java | 4 +- .../InterpreterResultMessageOutput.java | 4 +- .../zeppelin/interpreter/LazyOpenInterpreter.java | 6 + .../remote/RemoteInterpreterServer.java | 63 +- .../org/apache/zeppelin/resource/Resource.java | 4 +- .../zeppelin/scheduler/AbstractScheduler.java | 3 +- .../apache/zeppelin/scheduler/ExecutorFactory.java | 34 +- .../apache/zeppelin/scheduler/FIFOScheduler.java | 2 +- .../java/org/apache/zeppelin/scheduler/Job.java | 9 +- .../zeppelin/scheduler/JobProgressPoller.java | 4 +- ...rThreadFactory.java => NamedThreadFactory.java} | 15 +- .../zeppelin/scheduler/ParallelScheduler.java | 6 +- .../zeppelin/scheduler/SchedulerFactory.java | 40 +- .../apache/zeppelin/user/AuthenticationInfo.java | 4 +- .../zeppelin/cluster/ClusterMultiNodeTest.java | 160 - .../zeppelin/cluster/ClusterSingleNodeTest.java | 147 - .../java/org/apache/zeppelin/dep/BooterTest.java | 5 +- .../zeppelin/dep/DependencyResolverTest.java | 6 +- .../zeppelin/helium/ApplicationLoaderTest.java | 7 +- .../apache/zeppelin/helium/HeliumPackageTest.java | 7 +- .../org/apache/zeppelin/scheduler/SleepingJob.java | 2 +- .../src/test/resources/zeppelin-site-test.xml | 5 - zeppelin-jupyter-interpreter-shaded/pom.xml | 8 +- zeppelin-jupyter-interpreter/pom.xml | 2 +- .../apache/zeppelin/jupyter/IPythonKernelTest.java | 24 +- .../org/apache/zeppelin/jupyter/IRKernelTest.java | 63 +- zeppelin-jupyter/pom.xml | 7 +- .../zeppelin/jupyter/nbformat/JupyterUtilTest.java | 20 +- .../src/test/resources/spark_example_notebook.zpln | 2 +- zeppelin-plugins/launcher/cluster/pom.xml | 85 - .../launcher/ClusterInterpreterCheckThread.java | 83 - .../launcher/ClusterInterpreterLauncher.java | 274 - .../launcher/ClusterInterpreterProcess.java | 74 - .../launcher/ClusterInterpreterLauncherTest.java | 144 - .../interpreter/launcher/ClusterMockTest.java | 164 - .../cluster/src/test/resources/log4j.properties | 24 - zeppelin-plugins/launcher/docker/pom.xml | 8 +- .../launcher/DockerInterpreterProcess.java | 80 +- .../launcher/DockerInterpreterProcessTest.java | 39 +- zeppelin-plugins/launcher/flink/pom.xml | 2 +- .../launcher/FlinkInterpreterLauncher.java | 3 +- zeppelin-plugins/launcher/k8s-standard/pom.xml | 23 +- .../launcher/K8sRemoteInterpreterProcess.java | 5 +- .../zeppelin/interpreter/launcher/K8sUtils.java | 2 +- .../launcher/K8sRemoteInterpreterProcessTest.java | 70 +- .../K8sStandardInterpreterLauncherTest.java | 8 +- .../interpreter/launcher/K8sUtilsTest.java | 20 +- .../interpreter/launcher/PodPhaseWatcherTest.java | 48 +- zeppelin-plugins/launcher/yarn/pom.xml | 71 +- .../launcher/YarnInterpreterLauncher.java | 5 +- .../launcher/YarnRemoteInterpreterProcess.java | 9 +- zeppelin-plugins/notebookrepo/azure/pom.xml | 6 +- .../zeppelin/notebook/repo/AzureNotebookRepo.java | 19 +- zeppelin-plugins/notebookrepo/filesystem/pom.xml | 184 +- .../notebook/repo/FileSystemNotebookRepo.java | 11 +- .../notebook/repo/FileSystemNotebookRepoTest.java | 17 +- zeppelin-plugins/notebookrepo/gcs/pom.xml | 11 +- .../zeppelin/notebook/repo/GCSNotebookRepo.java | 26 +- .../notebook/repo/GCSNotebookRepoTest.java | 132 +- zeppelin-plugins/notebookrepo/github/pom.xml | 2 +- .../zeppelin/notebook/repo/GitHubNotebookRepo.java | 41 +- .../notebook/repo/GitHubNotebookRepoTest.java | 68 +- .../notebook/my_project/my_note1_2A94M5J1Z.zpln | 2 +- zeppelin-plugins/notebookrepo/mongo/pom.xml | 4 +- .../zeppelin/notebook/repo/MongoNotebookRepo.java | 63 +- .../notebook/repo/MongoNotebookRepoTest.java | 53 +- zeppelin-plugins/notebookrepo/oss/pom.xml | 2 +- .../zeppelin/notebook/repo/OSSNotebookRepo.java | 21 +- .../notebook/repo/MockStorageOperator.java | 37 +- .../notebook/repo/OSSNotebookRepoTest.java | 28 +- zeppelin-plugins/notebookrepo/s3/pom.xml | 59 +- .../zeppelin/notebook/repo/S3NotebookRepo.java | 50 +- .../zeppelin/notebook/repo/S3NotebookRepoTest.java | 19 +- zeppelin-plugins/pom.xml | 14 +- zeppelin-server/pom.xml | 150 +- .../apache/zeppelin/metric/PrometheusServlet.java | 28 +- .../java/org/apache/zeppelin/realm/LdapRealm.java | 73 +- .../realm/jwt/KnoxAuthenticationFilter.java | 7 +- .../apache/zeppelin/realm/jwt/KnoxJwtRealm.java | 2 +- .../kerberos/KerberosAuthenticationFilter.java | 10 +- .../zeppelin/realm/kerberos/KerberosRealm.java | 76 +- .../org/apache/zeppelin/rest/AbstractRestApi.java | 2 +- .../org/apache/zeppelin/rest/AdminRestApi.java | 14 +- .../org/apache/zeppelin/rest/ClusterRestApi.java | 242 - .../zeppelin/rest/ConfigurationsRestApi.java | 16 +- .../apache/zeppelin/rest/CredentialRestApi.java | 20 +- .../org/apache/zeppelin/rest/HeliumRestApi.java | 49 +- .../apache/zeppelin/rest/InterpreterRestApi.java | 26 +- .../org/apache/zeppelin/rest/LoginRestApi.java | 44 +- .../apache/zeppelin/rest/NotebookRepoRestApi.java | 34 +- .../org/apache/zeppelin/rest/NotebookRestApi.java | 26 +- .../org/apache/zeppelin/rest/SecurityRestApi.java | 18 +- .../org/apache/zeppelin/rest/SessionRestApi.java | 27 +- .../org/apache/zeppelin/rest/ZeppelinRestApi.java | 16 +- .../rest/exception/BadRequestException.java | 6 +- .../rest/exception/ForbiddenException.java | 6 +- .../rest/exception/NoteNotFoundException.java | 4 +- .../rest/exception/ParagraphNotFoundException.java | 4 +- .../rest/exception/SessionNoteFoundException.java | 4 +- .../exception/WebApplicationExceptionMapper.java | 10 +- .../message/UpdateInterpreterSettingRequest.java | 45 + .../rest/message/gson/ExceptionSerializer.java | 2 +- .../org/apache/zeppelin/server/CorsFilter.java | 35 +- .../org/apache/zeppelin/server/GsonProvider.java | 16 +- .../apache/zeppelin/server/HtmlAddonResource.java | 173 - .../zeppelin/server/ImmediateErrorHandlerImpl.java | 2 +- .../apache/zeppelin/server/IndexHtmlServlet.java | 116 + .../org/apache/zeppelin/server/JsonResponse.java | 24 +- .../apache/zeppelin/server/RestApiApplication.java | 70 + .../org/apache/zeppelin/server/ZeppelinServer.java | 527 +- .../org/apache/zeppelin/service/AdminService.java | 2 +- .../zeppelin/service/ConfigurationService.java | 2 +- .../zeppelin/service/InterpreterService.java | 14 +- .../apache/zeppelin/service/JobManagerService.java | 15 +- .../zeppelin/service/NoAuthenticationService.java | 2 +- .../apache/zeppelin/service/NotebookService.java | 112 +- .../zeppelin/service/SessionManagerService.java | 11 +- .../service/ShiroAuthenticationService.java | 16 +- .../apache/zeppelin/socket/ConnectionManager.java | 12 +- .../org/apache/zeppelin/socket/NotebookServer.java | 293 +- .../org/apache/zeppelin/socket/NotebookSocket.java | 14 +- .../zeppelin/socket/SessionConfigurator.java | 21 +- .../utils/AnyOfRolesUserAuthorizationFilter.java | 5 +- .../java/org/apache/zeppelin/utils/CorsUtils.java | 11 +- .../org/apache/zeppelin/utils/ExceptionUtils.java | 8 +- .../org/apache/zeppelin/utils/ServerUtils.java | 4 +- .../java/org/apache/zeppelin/utils/TestUtils.java | 50 - .../org/apache/zeppelin/MiniZeppelinServer.java | 326 + .../cluster/ClusterAuthEventListenerTest.java | 68 - .../apache/zeppelin/cluster/ClusterEventTest.java | 567 - .../cluster/ClusterNoteEventListenerTest.java | 83 - .../zeppelin/cluster/ZeppelinServerMock.java | 185 - .../configuration/RequestHeaderSizeTest.java | 35 +- .../apache/zeppelin/integration/TestHelper.java | 46 + .../apache/zeppelin/metric/MetricEndpointTest.java | 33 +- .../org/apache/zeppelin/realm/LdapRealmTest.java | 13 + .../org/apache/zeppelin/recovery/RecoveryTest.java | 171 +- .../apache/zeppelin/rest/AbstractTestRestApi.java | 316 +- .../zeppelin/rest/ConfigurationsRestApiTest.java | 53 +- .../zeppelin/rest/CredentialsRestApiTest.java | 4 +- .../apache/zeppelin/rest/HeliumRestApiTest.java | 20 +- .../zeppelin/rest/InterpreterRestApiTest.java | 68 +- .../org/apache/zeppelin/rest/KnoxRestApiTest.java | 17 +- .../zeppelin/rest/NotebookRepoRestApiTest.java | 15 +- .../apache/zeppelin/rest/NotebookRestApiTest.java | 229 +- .../zeppelin/rest/NotebookSecurityRestApiTest.java | 25 +- .../apache/zeppelin/rest/SecurityRestApiTest.java | 14 +- .../apache/zeppelin/rest/SessionRestApiTest.java | 95 + .../apache/zeppelin/rest/ZeppelinRestApiTest.java | 277 +- .../UpdateInterpreterSettingRequestTest.java | 115 + .../apache/zeppelin/security/DirAccessTest.java | 59 +- .../org/apache/zeppelin/server/CorsFilterTest.java | 15 +- .../zeppelin/server/HtmlAddonResourceTest.java | 71 - .../zeppelin/server/IndexHtmlServletTest.java | 113 + .../zeppelin/service/ConfigurationServiceTest.java | 24 +- .../zeppelin/service/InterpreterServiceTest.java | 13 +- .../zeppelin/service/NotebookServiceTest.java | 117 +- .../zeppelin/socket/ConnectionManagerTest.java | 6 +- .../apache/zeppelin/socket/NotebookServerTest.java | 65 +- .../org/apache/zeppelin/utils/CorsUtilsTest.java | 25 +- .../src/test/resources/2A94M5J1Z/note.json | 2 +- .../src/test/resources/2A94M5J2Z/note.json | 2 +- .../pom.xml | 56 +- .../org/apache/zeppelin/test/DownloadRequest.java | 77 + .../org/apache/zeppelin/test/DownloadUtils.java | 629 + .../org/apache/zeppelin/test/SemanticVersion.java | 76 +- .../apache/zeppelin/test/DownloadUtilsTest.java | 80 + zeppelin-test/src/test/resources/log4j2.properties | 25 + zeppelin-web-angular/README.md | 16 +- zeppelin-web-angular/WEB-INF/web.xml | 22 +- zeppelin-web-angular/package-lock.json | 33208 ++++++++++++++----- zeppelin-web-angular/package.json | 20 +- zeppelin-web-angular/pom.xml | 4 +- .../src/interfaces/message-common.interface.ts | 3 - .../interfaces/message-data-type-map.interface.ts | 2 + .../src/interfaces/message-notebook.interface.ts | 1 + .../src/interfaces/message-operator.interface.ts | 7 + .../projects/zeppelin-sdk/src/message.ts | 4 + .../src/app/app-message.interceptor.ts | 17 +- .../runtime-dynamic-module/ng-zorro-antd-module.ts | 2 +- .../runtime-dynamic-module/ngmodule.decorator.ts} | 5 +- .../runtime-dynamic-module.module.ts | 2 +- .../app/pages/workspace/home/home.component.html | 2 +- .../workspace/interpreter/interpreter.component.ts | 5 +- .../workspace/interpreter/item/item.component.ts | 6 +- .../notebook/action-bar/action-bar.component.html | 16 +- .../notebook/action-bar/action-bar.component.ts | 12 +- .../paragraph/code-editor/code-editor.component.ts | 2 +- .../paragraph/control/control.component.html | 16 +- .../notebook/paragraph/paragraph.component.ts | 43 +- .../workspace/share/result/result.component.ts | 5 +- .../src/app/services/message.service.ts | 4 + .../app/services/ng-template-adapter.service.ts | 65 - .../src/app/share/header/header.component.html | 2 +- .../src/app/share/header/header.component.ts | 10 + .../ng1-migration/ng1-migration.component.html | 65 - .../ng1-migration/ng1-migration.component.less | 88 - .../share/ng1-migration/ng1-migration.component.ts | 185 - .../share/note-import/note-import.component.html | 2 +- zeppelin-web-angular/src/app/share/share.module.ts | 6 +- .../table/table-visualization.component.html | 3 +- zeppelin-web-angular/src/index.html | 9 +- zeppelin-web/.bowerrc | 4 - zeppelin-web/Gruntfile.js | 58 +- zeppelin-web/README.md | 45 +- zeppelin-web/bower.json | 80 - zeppelin-web/e2e/collaborativeMode.spec.js | 2 +- zeppelin-web/e2e/home.spec.js | 8 +- zeppelin-web/e2e/searchBlock.spec.js | 2 +- zeppelin-web/karma.conf.js | 109 +- zeppelin-web/package-lock.json | 30801 +++++++++-------- zeppelin-web/package.json | 77 +- zeppelin-web/pom.xml | 23 +- zeppelin-web/protractor.conf.js | 4 +- zeppelin-web/src/WEB-INF/web.xml | 9 - zeppelin-web/src/app/app.js | 2 +- zeppelin-web/src/app/helium/helium.controller.js | 6 +- zeppelin-web/src/app/home/home.html | 2 +- .../src/app/notebook/notebook-actionBar.html | 8 + .../src/app/notebook/notebook.controller.js | 19 + .../src/app/notebook/notebook.controller.test.js | 7 +- .../app/notebook/paragraph/paragraph-control.html | 4 + .../app/notebook/paragraph/paragraph.controller.js | 31 + .../builtins/visualization-d3network.js | 12 +- .../visualization/builtins/visualization-table.js | 11 +- .../src/components/navbar/navbar.controller.js | 8 + zeppelin-web/src/components/navbar/navbar.html | 2 +- zeppelin-web/src/index.html | 142 +- zeppelin-web/webpack.config.js | 38 +- zeppelin-zengine/pom.xml | 108 +- .../java/org/apache/zeppelin/helium/Helium.java | 37 +- .../zeppelin/helium/HeliumApplicationFactory.java | 24 +- .../zeppelin/helium/HeliumBundleFactory.java | 43 +- .../zeppelin/helium/HeliumOnlineRegistry.java | 24 +- .../org/apache/zeppelin/helium/HeliumRegistry.java | 2 +- .../zeppelin/helium/HeliumRegistrySerializer.java | 6 +- .../zeppelin/interpreter/InterpreterFactory.java | 2 +- .../zeppelin/interpreter/InterpreterSetting.java | 64 +- .../interpreter/InterpreterSettingManager.java | 122 +- .../interpreter/ManagedInterpreterGroup.java | 10 +- .../interpreter/RemoteInterpreterEventServer.java | 8 +- .../interpreter/SessionConfInterpreter.java | 2 +- .../zeppelin/interpreter/YarnAppMonitor.java | 16 +- .../interpreter/install/InstallInterpreter.java | 19 +- .../launcher/SparkInterpreterLauncher.java | 53 +- .../interpreter/recovery/StopInterpreter.java | 21 +- .../interpreter/remote/AppendOutputRunner.java | 3 +- .../interpreter/remote/RemoteInterpreter.java | 5 +- .../zeppelin/notebook/AuthorizationService.java | 119 +- .../zeppelin/notebook/FileSystemStorage.java | 5 +- .../apache/zeppelin/notebook/GsonNoteParser.java | 84 + .../java/org/apache/zeppelin/notebook/Note.java | 130 +- .../org/apache/zeppelin/notebook/NoteAuth.java | 22 +- .../zeppelin/notebook/NoteEventAsyncListener.java | 4 +- .../notebook/NoteJsonExclusionStrategy.java | 59 + .../org/apache/zeppelin/notebook/NoteManager.java | 39 +- .../org/apache/zeppelin/notebook/NoteParser.java | 57 + .../org/apache/zeppelin/notebook/Notebook.java | 34 +- .../org/apache/zeppelin/notebook/Paragraph.java | 6 +- .../notebook/exception/CorruptedNoteException.java | 9 +- .../notebook/repo/AbstractNotebookRepo.java | 25 +- .../zeppelin/notebook/repo/GitNotebookRepo.java | 16 +- .../notebook/repo/InMemoryNotebookRepo.java | 7 +- .../zeppelin/notebook/repo/NotebookRepo.java | 9 +- .../zeppelin/notebook/repo/NotebookRepoSync.java | 60 +- .../zeppelin/notebook/repo/VFSNotebookRepo.java | 51 +- .../notebook/scheduler/QuartzSchedulerService.java | 10 +- .../org/apache/zeppelin/plugin/PluginManager.java | 23 +- .../apache/zeppelin/scheduler/RemoteScheduler.java | 12 +- .../org/apache/zeppelin/search/LuceneSearch.java | 10 +- .../apache/zeppelin/search/NoSearchService.java | 2 +- .../org/apache/zeppelin/search/SearchService.java | 2 +- .../org/apache/zeppelin/storage/ConfigStorage.java | 22 +- .../java/org/apache/zeppelin/user/Credentials.java | 22 +- .../zeppelin/conf/ZeppelinConfigurationTest.java | 109 +- .../helium/HeliumApplicationFactoryTest.java | 25 +- .../zeppelin/helium/HeliumBundleFactoryTest.java | 45 +- .../zeppelin/helium/HeliumLocalRegistryTest.java | 15 +- .../zeppelin/helium/HeliumOnlineRegistryTest.java | 25 +- .../org/apache/zeppelin/helium/HeliumTest.java | 35 +- .../apache/zeppelin/helium/HeliumTestRegistry.java | 1 - .../interpreter/AbstractInterpreterTest.java | 55 +- .../zeppelin/interpreter/ConfInterpreterTest.java | 12 +- .../interpreter/InterpreterFactoryTest.java | 8 +- .../interpreter/InterpreterSettingManagerTest.java | 39 +- .../interpreter/InterpreterSettingTest.java | 46 +- .../interpreter/ManagedInterpreterGroupTest.java | 11 +- .../interpreter/SessionConfInterpreterTest.java | 8 +- .../install/InstallInterpreterTest.java | 18 +- .../interpreter/integration/DownloadUtils.java | 175 - .../launcher/SparkInterpreterLauncherTest.java | 294 +- .../launcher/StandardInterpreterLauncherTest.java | 17 +- .../lifecycle/TimeoutLifecycleManagerTest.java | 8 +- .../interpreter/mock/MockInterpreter1.java | 158 +- .../interpreter/mock/MockInterpreter2.java | 138 +- .../recovery/FileSystemRecoveryStorageTest.java | 6 +- .../recovery/LocalRecoveryStorageTest.java | 6 +- .../interpreter/remote/AppendOutputRunnerTest.java | 10 +- .../remote/RemoteAngularObjectTest.java | 8 +- ... => RemoteInterpreterOutputTestStreamTest.java} | 69 +- .../interpreter/remote/RemoteInterpreterTest.java | 35 +- .../zeppelin/notebook/CredentialInjectorTest.java | 12 +- .../org/apache/zeppelin/notebook/NoteAuthTest.java | 34 +- .../apache/zeppelin/notebook/NoteManagerTest.java | 26 +- .../org/apache/zeppelin/notebook/NoteTest.java | 38 +- .../org/apache/zeppelin/notebook/NotebookTest.java | 312 +- .../apache/zeppelin/notebook/ParagraphTest.java | 33 +- .../zeppelin/notebook/ParagraphTextParserTest.java | 35 +- .../notebook/repo/GitNotebookRepoTest.java | 102 +- .../repo/NotebookRepoSyncInitializationTest.java | 169 +- .../notebook/repo/NotebookRepoSyncTest.java | 138 +- .../notebook/repo/VFSNotebookRepoTest.java | 60 +- .../notebook/repo/mock/VFSNotebookRepoMock.java | 11 +- .../apache/zeppelin/plugin/PluginManagerTest.java | 7 +- .../resource/DistributedResourcePoolTest.java | 10 +- .../zeppelin/scheduler/RemoteSchedulerTest.java | 50 +- .../apache/zeppelin/search/LuceneSearchTest.java | 52 +- .../zeppelin/storage/LocalConfigStorageTest.java | 8 +- .../org/apache/zeppelin/user/CredentialsTest.java | 4 +- .../org/apache/zeppelin/user/EncryptorTest.java | 4 +- .../java/org/apache/zeppelin/util/UtilTest.java | 6 +- .../notebook/my_project/my_note1_2A94M5J1Z.zpln | 2 +- 843 files changed, 63128 insertions(+), 56518 deletions(-) delete mode 100644 .mvn/wrapper/maven-wrapper.jar rename bigquery/src/{main => test}/resources/constants.json (100%) copy {markdown => bigquery}/src/test/resources/log4j.properties (100%) delete mode 100755 dev/change_scala_version.sh create mode 100755 dev/checkout_zeppelin_pr.sh delete mode 100755 dev/test_zeppelin_pr.py delete mode 100644 docs/assets/themes/zeppelin/img/docs-img/spark_SPARK_HOME16.png delete mode 100644 docs/assets/themes/zeppelin/img/docs-img/spark_SPARK_HOME24.png delete mode 100644 docs/assets/themes/zeppelin/img/docs-img/spark_deprecate.png create mode 100644 docs/assets/themes/zeppelin/img/ui-img/switch_to_classic_ui.png delete mode 100644 docs/interpreter/kotlin.md delete mode 100644 docs/interpreter/submarine.md delete mode 120000 flink/flink-scala-2.11/flink-scala-parent delete mode 100644 flink/flink-scala-2.11/pom.xml delete mode 100644 flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkExprTyper.scala delete mode 100644 flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkILoopInterpreter.scala delete mode 100644 flink/flink-scala-2.11/src/main/scala/org/apache/zeppelin/flink/FlinkScala211Interpreter.scala delete mode 120000 flink/flink-scala-2.12/flink-scala-parent rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/ApplicationModeExecutionEnvironment.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/ApplicationModeStreamEnvironment.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreter.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java (97%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java (96%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreter.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/HadoopUtils.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/IPyFlinkInterpreter.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/JobManager.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/PyFlinkInterpreter.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/TableEnvFactory.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/internal/JarHelper.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/internal/ScalaShellEnvironment.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/internal/ScalaShellStreamEnvironment.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/sql/AbstractStreamSqlJob.java (99%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/sql/AppendStreamSqlJob.java (98%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/sql/SingleRowStreamSqlJob.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/java/org/apache/zeppelin/flink/sql/UpdateStreamSqlJob.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/resources/interpreter-setting.json (99%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/resources/python/zeppelin_ipyflink.py (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/resources/python/zeppelin_pyflink.py (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala (99%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/scala/org/apache/zeppelin/flink/FlinkZeppelinContext.scala (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/scala/org/apache/zeppelin/flink/internal/FlinkILoop.scala (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/main/scala/org/apache/zeppelin/flink/internal/FlinkShell.scala (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/FlinkBatchSqlInterpreterTest.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/FlinkInterpreterTest.java (91%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/FlinkSqlInterpreterTest.java (98%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/FlinkStreamSqlInterpreterTest.java (99%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java (87%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/JavaLower.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/JavaUpper.java (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/JobManagerTest.java (90%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/java/org/apache/zeppelin/flink/PyFlinkInterpreterTest.java (85%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/resources/flink-conf.yaml (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/resources/init_stream.scala2 (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/resources/log4j.properties (100%) rename flink/{flink-scala-parent => flink-scala-2.12}/src/test/resources/log4j2.properties (100%) delete mode 100644 flink/flink-scala-parent/pom.xml delete mode 100644 flink/flink1.13-shims/pom.xml delete mode 100644 flink/flink1.13-shims/src/main/java/org/apache/zeppelin/flink/Flink113Shims.java delete mode 100644 flink/flink1.13-shims/src/main/java/org/apache/zeppelin/flink/Flink113SqlInterpreter.java delete mode 100644 flink/flink1.13-shims/src/main/scala/org/apache/zeppelin/flink/shims113/Flink113ScalaShims.scala delete mode 100644 flink/flink1.14-shims/src/main/java/org/apache/zeppelin/flink/shims114/CollectStreamTableSink.java rename flink/{flink1.14-shims => flink1.17-shims}/pom.xml (91%) rename flink/{flink1.14-shims/src/main/java/org/apache/zeppelin/flink/Flink114Shims.java => flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117Shims.java} (82%) rename flink/{flink1.14-shims/src/main/java/org/apache/zeppelin/flink/Flink114SqlInterpreter.java => flink1.17-shims/src/main/java/org/apache/zeppelin/flink/Flink117SqlInterpreter.java} (98%) copy flink/{flink1.15-shims => flink1.17-shims}/src/main/java/org/apache/zeppelin/flink/PrintUtils.java (100%) copy flink/{flink1.15-shims => flink1.17-shims}/src/main/java/org/apache/zeppelin/flink/TimestampStringUtils.java (100%) rename flink/{flink1.13-shims/src/main/java/org/apache/zeppelin/flink/shims113 => flink1.17-shims/src/main/java/org/apache/zeppelin/flink/shims117}/CollectStreamTableSink.java (98%) create mode 100644 jdbc/Dockerfile create mode 100644 jdbc/README.md copy jdbc/src/main/java/org/apache/zeppelin/jdbc/{hive => kyuubi}/BeelineInPlaceUpdateStream.java (73%) create mode 100644 jdbc/src/main/java/org/apache/zeppelin/jdbc/kyuubi/KyuubiUtils.java create mode 100644 jdbc/src/main/java/org/apache/zeppelin/jdbc/kyuubi/ProgressBar.java delete mode 100644 kotlin/README.md delete mode 100644 kotlin/pom.xml delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/KotlinInterpreter.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/completion/KotlinCompleter.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/completion/KotlinKeywords.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/context/KotlinReceiver.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/ContextUpdater.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinFunctionInfo.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinReflectUtil.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/reflect/KotlinVariableInfo.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/ClassWriter.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/KotlinRepl.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/building/KotlinReplProperties.java delete mode 100644 kotlin/src/main/java/org/apache/zeppelin/kotlin/repl/building/ReplBuilding.java delete mode 100644 kotlin/src/main/resources/interpreter-setting.json delete mode 100644 kotlin/src/test/java/org/apache/zeppelin/kotlin/KotlinInterpreterTest.java create mode 100644 livy/src/test/java/org/apache/zeppelin/livy/WithLivyServer.java copy zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/PythonPackagePredicate.java => python/src/test/java/org/apache/zeppelin/python/PythonInterpreterPandasSqlTestTest.java (61%) delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-cpu-submarine-interpreter/Dockerfile delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-cpu-submarine-interpreter/build.sh delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-cpu-tensorflow_1.13.1-hadoop_3.1.2/Dockerfile delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-gpu-submarine-interpreter/Dockerfile delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-gpu-submarine-interpreter/build.sh delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-gpu-tensorflow_1.13.1-hadoop_3.1.2/Dockerfile delete mode 100644 scripts/docker/submarine/1.0.0/zeppelin-gpu-tensorflow_1.13.1-hadoop_3.1.2/build.sh delete mode 100644 scripts/docker/zeppelin-interpreter/conda_packages.txt create mode 100644 scripts/docker/zeppelin-interpreter/condarc copy scripts/docker/{zeppelin/bin => zeppelin-interpreter}/env_python_3_with_R.yml (79%) delete mode 100644 scripts/docker/zeppelin-interpreter/pip_packages.txt create mode 100644 scripts/docker/zeppelin-quick-start/README.md rename scripts/docker/{submarine/1.0.0/zeppelin-cpu-tensorflow_1.13.1-hadoop_3.1.2/build.sh => zeppelin-quick-start/docker-compose-zeppelin-only.yml} (76%) create mode 100644 shell/Dockerfile delete mode 100644 shell/HTERM.md delete mode 100644 shell/PTY4J.md create mode 100644 shell/README.md delete mode 100644 shell/src/main/java/org/apache/zeppelin/shell/terminal/helper/IOHelper.java rename zeppelin-server/src/test/java/org/apache/zeppelin/cluster/ClusterIntpSettingEventListenerTest.java => shell/src/main/java/org/apache/zeppelin/shell/terminal/websocket/TerminalSessionConfigurator.java (56%) delete mode 100755 shell/src/main/resources/libpty/freebsd/x86/libpty.so delete mode 100755 shell/src/main/resources/libpty/freebsd/x86_64/libpty.so delete mode 100755 shell/src/main/resources/libpty/linux/ppc64le/libpty.so delete mode 100644 shell/src/main/resources/libpty/linux/x86/libpty.so delete mode 100644 shell/src/main/resources/libpty/linux/x86_64/libpty.so delete mode 100644 shell/src/main/resources/libpty/macosx/x86/libpty.dylib delete mode 100644 shell/src/main/resources/libpty/macosx/x86_64/libpty.dylib delete mode 100644 shell/src/main/resources/libpty/win/x86/winpty-agent.exe delete mode 100755 shell/src/main/resources/libpty/win/x86/winpty.dll delete mode 100644 shell/src/main/resources/libpty/win/x86_64/cyglaunch.exe delete mode 100644 shell/src/main/resources/libpty/win/x86_64/winpty-agent.exe delete mode 100644 shell/src/main/resources/libpty/win/x86_64/winpty.dll delete mode 100755 shell/src/main/resources/libpty/win/xp/winpty-agent.exe delete mode 100755 shell/src/main/resources/libpty/win/xp/winpty.dll delete mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/KotlinSparkInterpreter.java rename spark/{spark-shims => interpreter}/src/main/java/org/apache/zeppelin/spark/SparkVersion.java (75%) delete mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/kotlin/KotlinZeppelinBindings.java delete mode 100644 spark/interpreter/src/main/java/org/apache/zeppelin/spark/kotlin/SparkKotlinReceiver.java rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/AbstractAngularElem.scala (100%) rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/AbstractAngularModel.scala (100%) rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/notebookscope/AngularElem.scala (95%) rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/notebookscope/AngularModel.scala (100%) rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/paragraphscope/AngularElem.scala (95%) rename {zeppelin-display => spark/interpreter}/src/main/scala/org/apache/zeppelin/display/angular/paragraphscope/AngularModel.scala (100%) delete mode 100644 spark/interpreter/src/test/java/org/apache/zeppelin/spark/KotlinSparkInterpreterTest.java delete mode 100644 spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkShimsTest.java create mode 100644 spark/interpreter/src/test/java/org/apache/zeppelin/spark/SparkUtilsTest.java rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularElemTest.scala (94%) rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/AbstractAngularModelTest.scala (89%) rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/notebookscope/AngularElemTest.scala (100%) rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/notebookscope/AngularModelTest.scala (100%) rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/paragraphscope/AngularElemTest.scala (100%) rename {zeppelin-display => spark/interpreter}/src/test/scala/org/apache/zeppelin/display/angular/paragraphscope/AngularModelTest.scala (100%) delete mode 100644 spark/scala-2.11/pom.xml delete mode 100644 spark/scala-2.11/src/main/resources/log4j.properties delete mode 100644 spark/scala-2.11/src/main/scala/org/apache/zeppelin/spark/SparkScala211Interpreter.scala delete mode 100644 spark/scala-2.11/src/main/scala/org/apache/zeppelin/spark/SparkZeppelinContext.scala rename spark/{spark2-shims => spark-common}/pom.xml (83%) rename spark/{spark3-shims/src/main/java/org/apache/zeppelin/spark/Spark3Shims.java => spark-common/src/main/java/org/apache/zeppelin/spark/SparkUtils.java} (54%) delete mode 100644 spark/spark-shims/pom.xml delete mode 100644 spark/spark-shims/src/main/java/org/apache/zeppelin/spark/SparkShims.java delete mode 100644 spark/spark2-shims/src/main/java/org/apache/zeppelin/spark/Spark2Shims.java delete mode 100644 spark/spark3-shims/pom.xml delete mode 100644 submarine/pom.xml delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/IPySubmarineInterpreter.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/PySubmarineInterpreter.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/SubmarineContext.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/SubmarineInterpreter.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/SubmarineShellInterpreter.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/commons/SubmarineCommand.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/commons/SubmarineConstants.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/commons/SubmarineUI.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/commons/SubmarineUtils.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/hadoop/FinalApplicationStatus.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/hadoop/HdfsClient.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/hadoop/YarnApplicationState.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/hadoop/YarnClient.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/job/SubmarineJob.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/job/SubmarineJobStatus.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/job/thread/JobRunThread.java delete mode 100644 submarine/src/main/java/org/apache/zeppelin/submarine/job/thread/TensorboardRunThread.java delete mode 100644 submarine/src/main/resources/interpreter-setting.json delete mode 100644 submarine/src/main/resources/jinja_templates/submarine-job-run-tf.jinja delete mode 100644 submarine/src/main/resources/jinja_templates/submarine-tensorboard.jinja delete mode 100644 submarine/src/main/resources/ui_templates/submarine-command-options.json delete mode 100644 submarine/src/main/resources/ui_templates/submarine-dashboard.jinja delete mode 100644 submarine/src/main/resources/ui_templates/submarine-log-head.jinja delete mode 100644 submarine/src/main/resources/ui_templates/submarine-usage.jinja delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/BaseInterpreterTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/HdfsClientTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/JinjaTemplatesTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/PySubmarineInterpreterTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/SubmarineInterpreterTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/SubmarineJobTest.java delete mode 100644 submarine/src/test/java/org/apache/zeppelin/submarine/YarnClientTest.java delete mode 100755 submarine/src/test/resources/DefaultExecutorTest.sh delete mode 100644 submarine/src/test/resources/app-v1-services-app_name.json delete mode 100644 submarine/src/test/resources/log4j.properties delete mode 100644 submarine/src/test/resources/ws-v1-cluster-apps-application_id-appattempts-appattempt_id-containers.json delete mode 100644 submarine/src/test/resources/ws-v1-cluster-apps-application_id-appattempts.json delete mode 100644 submarine/src/test/resources/ws-v1-cluster-apps-application_id-failed.json delete mode 100644 submarine/src/test/resources/ws-v1-cluster-apps-application_id-finished.json delete mode 100644 submarine/src/test/resources/ws-v1-cluster-apps-application_id-running.json copy testing/{env_python_3.8_with_R.yml => env_python_3.9_with_R.yml} (96%) delete mode 100644 testing/env_python_3_with_flink_113.yml delete mode 100644 testing/env_python_3_with_flink_114.yml rename testing/{env_python_3_with_flink_112.yml => env_python_3_with_flink_117.yml} (88%) create mode 100644 testing/resources/bank.csv delete mode 100644 zeppelin-display/pom.xml delete mode 100644 zeppelin-distribution/src/deb/control/control delete mode 100644 zeppelin-distribution/src/deb/control/prerm delete mode 100755 zeppelin-distribution/src/deb/init.d/zeppelind delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/MiniZeppelin.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/SparkIntegrationTest24.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/SparkIntegrationTest30.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/SparkIntegrationTest31.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/SparkIntegrationTest32.java copy zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/exception/NotePathAlreadyExistsException.java => zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/SparkIntegrationTest34.java (68%) delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest24.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest30.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest31.java delete mode 100644 zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest32.java rename flink-cmd/src/test/java/org/apache/zeppelin/flink/cmd/FlinkCmdInterpreterTest.java => zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/ZeppelinSparkClusterTest34.java (66%) delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/BroadcastServiceAdapter.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterCallback.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterManager.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterManagerClient.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterManagerServer.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterMonitor.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterPrimitiveType.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/ClusterStateMachine.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/event/ClusterEvent.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/event/ClusterEventListener.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/event/ClusterMessage.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/listener/ZeppelinClusterMembershipEventListener.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/meta/ClusterMeta.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/meta/ClusterMetaEntity.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/meta/ClusterMetaOperation.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/meta/ClusterMetaType.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/LocalRaftClientProtocol.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/LocalRaftProtocol.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/LocalRaftProtocolFactory.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/LocalRaftServerProtocol.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/RaftClientMessagingProtocol.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/RaftMessagingProtocol.java delete mode 100644 zeppelin-interpreter/src/main/java/org/apache/zeppelin/cluster/protocol/RaftServerMessagingProtocol.java rename zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/{SchedulerThreadFactory.java => NamedThreadFactory.java} (74%) delete mode 100644 zeppelin-interpreter/src/test/java/org/apache/zeppelin/cluster/ClusterMultiNodeTest.java delete mode 100644 zeppelin-interpreter/src/test/java/org/apache/zeppelin/cluster/ClusterSingleNodeTest.java delete mode 100644 zeppelin-plugins/launcher/cluster/pom.xml delete mode 100644 zeppelin-plugins/launcher/cluster/src/main/java/org/apache/zeppelin/interpreter/launcher/ClusterInterpreterCheckThread.java delete mode 100644 zeppelin-plugins/launcher/cluster/src/main/java/org/apache/zeppelin/interpreter/launcher/ClusterInterpreterLauncher.java delete mode 100644 zeppelin-plugins/launcher/cluster/src/main/java/org/apache/zeppelin/interpreter/launcher/ClusterInterpreterProcess.java delete mode 100644 zeppelin-plugins/launcher/cluster/src/test/java/org/apache/zeppelin/interpreter/launcher/ClusterInterpreterLauncherTest.java delete mode 100644 zeppelin-plugins/launcher/cluster/src/test/java/org/apache/zeppelin/interpreter/launcher/ClusterMockTest.java delete mode 100644 zeppelin-plugins/launcher/cluster/src/test/resources/log4j.properties delete mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/rest/ClusterRestApi.java delete mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/server/HtmlAddonResource.java create mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/server/IndexHtmlServlet.java create mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/server/RestApiApplication.java delete mode 100644 zeppelin-server/src/main/java/org/apache/zeppelin/utils/TestUtils.java create mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/MiniZeppelinServer.java delete mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/cluster/ClusterAuthEventListenerTest.java delete mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/cluster/ClusterEventTest.java delete mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/cluster/ClusterNoteEventListenerTest.java delete mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/cluster/ZeppelinServerMock.java create mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/integration/TestHelper.java create mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/rest/SessionRestApiTest.java create mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/rest/message/UpdateInterpreterSettingRequestTest.java delete mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/server/HtmlAddonResourceTest.java create mode 100644 zeppelin-server/src/test/java/org/apache/zeppelin/server/IndexHtmlServletTest.java copy {zeppelin-client-examples => zeppelin-test}/pom.xml (62%) create mode 100644 zeppelin-test/src/main/java/org/apache/zeppelin/test/DownloadRequest.java create mode 100644 zeppelin-test/src/main/java/org/apache/zeppelin/test/DownloadUtils.java copy livy/src/main/java/org/apache/zeppelin/livy/LivyVersion.java => zeppelin-test/src/main/java/org/apache/zeppelin/test/SemanticVersion.java (50%) create mode 100644 zeppelin-test/src/test/java/org/apache/zeppelin/test/DownloadUtilsTest.java create mode 100644 zeppelin-test/src/test/resources/log4j2.properties copy zeppelin-web-angular/{projects/zeppelin-sdk/src/index.ts => src/app/core/runtime-dynamic-module/ngmodule.decorator.ts} (72%) delete mode 100644 zeppelin-web-angular/src/app/services/ng-template-adapter.service.ts delete mode 100644 zeppelin-web-angular/src/app/share/ng1-migration/ng1-migration.component.html delete mode 100644 zeppelin-web-angular/src/app/share/ng1-migration/ng1-migration.component.less delete mode 100644 zeppelin-web-angular/src/app/share/ng1-migration/ng1-migration.component.ts delete mode 100644 zeppelin-web/.bowerrc delete mode 100644 zeppelin-web/bower.json create mode 100644 zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/GsonNoteParser.java create mode 100644 zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/NoteJsonExclusionStrategy.java create mode 100644 zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/NoteParser.java copy zeppelin-plugins/notebookrepo/oss/src/main/java/org/apache/zeppelin/notebook/repo/RevisionsInfo.java => zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/AbstractNotebookRepo.java (63%) delete mode 100644 zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/integration/DownloadUtils.java rename zeppelin-zengine/src/test/java/org/apache/zeppelin/interpreter/remote/{RemoteInterpreterOutputTestStream.java => RemoteInterpreterOutputTestStreamTest.java} (70%)