This is an automated email from the ASF dual-hosted git repository.
jongyoul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push:
new 02cbd6ee24 [HOTFIX] Change the location of bank.csv to fix the
integration tests (#4623)
02cbd6ee24 is described below
commit 02cbd6ee2425f0be87dee1b444580b0c2cb7e9ce
Author: Jongyoul Lee <[email protected]>
AuthorDate: Thu Jun 29 16:18:12 2023 +0900
[HOTFIX] Change the location of bank.csv to fix the integration tests
(#4623)
---
livy/src/test/resources/livy_tutorial_1.scala | 2 +-
notebook/Spark Tutorial/2. Spark Basic Features_2A94M5J1Z.zpln | 2 +-
notebook/Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln | 2 +-
.../test/java/org/apache/zeppelin/integration/SparkParagraphIT.java | 4 ++--
zeppelin-jupyter/src/test/resources/spark_example_notebook.zpln | 2 +-
.../src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln | 2 +-
zeppelin-server/src/test/resources/2A94M5J1Z/note.json | 2 +-
zeppelin-server/src/test/resources/2A94M5J2Z/note.json | 2 +-
.../src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln | 2 +-
9 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/livy/src/test/resources/livy_tutorial_1.scala
b/livy/src/test/resources/livy_tutorial_1.scala
index 430dbbfe85..f0bf117de2 100644
--- a/livy/src/test/resources/livy_tutorial_1.scala
+++ b/livy/src/test/resources/livy_tutorial_1.scala
@@ -8,7 +8,7 @@ import java.nio.charset.Charset
// load bank data
val bankText = sc.parallelize(
IOUtils.toString(
- new URL("https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv";),
+ new
URL("https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv";),
Charset.forName("utf8")).split("\n"))
case class Bank(age: Integer, job: String, marital: String, education: String,
balance: Integer)
diff --git a/notebook/Spark Tutorial/2. Spark Basic Features_2A94M5J1Z.zpln
b/notebook/Spark Tutorial/2. Spark Basic Features_2A94M5J1Z.zpln
index 878b6d2ef7..04c3a35adc 100644
--- a/notebook/Spark Tutorial/2. Spark Basic Features_2A94M5J1Z.zpln
+++ b/notebook/Spark Tutorial/2. Spark Basic Features_2A94M5J1Z.zpln
@@ -55,7 +55,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"user": "anonymous",
"dateUpdated": "2021-07-26 04:36:10.274",
"progress": 0,
diff --git a/notebook/Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln
b/notebook/Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln
index c1d4657b20..378698d1a3 100644
--- a/notebook/Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln
+++ b/notebook/Spark Tutorial/5. SparkR Basics_2BWJFTXKM.zpln
@@ -213,7 +213,7 @@
},
{
"title": "Create a Spark Dataframe",
- "text": "%spark\n\nimport org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age: Integer,
job: String, marital: String, education: String, balance: Integer)\n\nval bank
\u003d bankText.map(s \u003d\u003e s.split(\";\")).filter(s \u0 [...]
+ "text": "%spark\n\nimport org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age:
Integer, job: String, marital: String, education: String, balance:
Integer)\n\nval bank \u003d bankText.map(s \u003d\u003e s.split( [...]
"user": "anonymous",
"dateUpdated": "2021-07-31 12:58:21.193",
"progress": 0,
diff --git
a/zeppelin-integration/src/test/java/org/apache/zeppelin/integration/SparkParagraphIT.java
b/zeppelin-integration/src/test/java/org/apache/zeppelin/integration/SparkParagraphIT.java
index 05eb0a44bd..fa0133a00b 100644
---
a/zeppelin-integration/src/test/java/org/apache/zeppelin/integration/SparkParagraphIT.java
+++
b/zeppelin-integration/src/test/java/org/apache/zeppelin/integration/SparkParagraphIT.java
@@ -68,7 +68,7 @@ public class SparkParagraphIT extends AbstractZeppelinIT {
import org.apache.commons.io.IOUtils
import java.net.URL
import java.nio.charset.Charset
- val bankText = sc.parallelize(IOUtils.toString(new
URL("https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv";),Charset.forName("utf8")).split("\n"))
+ val bankText = sc.parallelize(IOUtils.toString(new
URL("https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv";),Charset.forName("utf8")).split("\n"))
case class Bank(age: Integer, job: String, marital: String, education:
String, balance: Integer)
val bank = bankText.map(s => s.split(";")).filter(s => s(0) !=
"\"age\"").map(s => Bank(s(0).toInt,s(1).replaceAll("\"",
""),s(2).replaceAll("\"", ""),s(3).replaceAll("\"", ""),s(5).replaceAll("\"",
"").toInt)).toDF()
@@ -77,7 +77,7 @@ public class SparkParagraphIT extends AbstractZeppelinIT {
setTextOfParagraph(2, "import org.apache.commons.io.IOUtils\\n" +
"import java.net.URL\\n" +
"import java.nio.charset.Charset\\n" +
- "val bankText = sc.parallelize(IOUtils.toString(new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),Charset.forName(\"utf8\")).split(\"\\\\n\"))\\n"
+
+ "val bankText = sc.parallelize(IOUtils.toString(new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),Charset.forName(\"utf8\")).split(\"\\\\n\"))\\n"
+
"case class Bank(age: Integer, job: String, marital: String,
education: String, balance: Integer)\\n" +
"\\n" +
"val bank = bankText.map(s => s.split(\";\")).filter(s => s(0) !=
\"\\\\\"age\\\\\"\").map(s => Bank(s(0).toInt,s(1).replaceAll(\"\\\\\"\",
\"\"),s(2).replaceAll(\"\\\\\"\", \"\"),s(3).replaceAll(\"\\\\\"\",
\"\"),s(5).replaceAll(\"\\\\\"\", \"\").toInt)).toDF()\\n" +
diff --git a/zeppelin-jupyter/src/test/resources/spark_example_notebook.zpln
b/zeppelin-jupyter/src/test/resources/spark_example_notebook.zpln
index b801f1d87a..67910c0b7b 100644
--- a/zeppelin-jupyter/src/test/resources/spark_example_notebook.zpln
+++ b/zeppelin-jupyter/src/test/resources/spark_example_notebook.zpln
@@ -52,7 +52,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"user": "anonymous",
"dateUpdated": "2020-05-08 11:18:36.766",
"config": {
diff --git
a/zeppelin-plugins/notebookrepo/github/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
b/zeppelin-plugins/notebookrepo/github/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
index 8d7d2df97c..1c2db7bacb 100644
---
a/zeppelin-plugins/notebookrepo/github/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
+++
b/zeppelin-plugins/notebookrepo/github/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
@@ -38,7 +38,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"config": {
"colWidth": 12.0,
"graph": {
diff --git a/zeppelin-server/src/test/resources/2A94M5J1Z/note.json
b/zeppelin-server/src/test/resources/2A94M5J1Z/note.json
index 6e8e06fe29..01786399ac 100644
--- a/zeppelin-server/src/test/resources/2A94M5J1Z/note.json
+++ b/zeppelin-server/src/test/resources/2A94M5J1Z/note.json
@@ -52,7 +52,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"user": "anonymous",
"dateUpdated": "Dec 17, 2016 3:30:09 PM",
"config": {
diff --git a/zeppelin-server/src/test/resources/2A94M5J2Z/note.json
b/zeppelin-server/src/test/resources/2A94M5J2Z/note.json
index dd9a74df9f..f1b6b726dc 100644
--- a/zeppelin-server/src/test/resources/2A94M5J2Z/note.json
+++ b/zeppelin-server/src/test/resources/2A94M5J2Z/note.json
@@ -52,7 +52,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"user": "anonymous",
"dateUpdated": "Dec 17, 2016 3:30:09 PM",
"config": {
diff --git
a/zeppelin-zengine/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
b/zeppelin-zengine/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
index 8d7d2df97c..1c2db7bacb 100644
---
a/zeppelin-zengine/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
+++
b/zeppelin-zengine/src/test/resources/notebook/my_project/my_note1_2A94M5J1Z.zpln
@@ -38,7 +38,7 @@
},
{
"title": "Load data into table",
- "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://s3.amazonaws.com/apache-zeppelin/tutorial/bank/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ncase class Bank(age [...]
+ "text": "import org.apache.commons.io.IOUtils\nimport
java.net.URL\nimport java.nio.charset.Charset\n\n// Zeppelin creates and
injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)\n// So you
don\u0027t need create them manually\n\n// load bank data\nval bankText \u003d
sc.parallelize(\n IOUtils.toString(\n new
URL(\"https://raw.githubusercontent.com/apache/zeppelin/master/testing/resources/bank.csv\";),\n
Charset.forName(\"utf8\")).split(\"\\n\"))\n\ [...]
"config": {
"colWidth": 12.0,
"graph": {
