Skip to content

Commit 00d8b26

Browse files
committed
SparkIntegration now uses spark connect :)
1 parent 03a54eb commit 00d8b26

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

Diff for: jupyter/src/main/kotlin/org/jetbrains/kotlinx/spark/api/jupyter/Integration.kt

+2
Original file line numberDiff line numberDiff line change
@@ -299,6 +299,8 @@ abstract class Integration(protected val notebook: Notebook, private val options
299299
"| ${param.index} -> this.${param.name}"
300300
}
301301

302+
println("Sparkified `$name`, this class can be used by Spark in a new cell.")
303+
302304
@Language("kotlin")
303305
val code =
304306
"""

Diff for: jupyter/src/main/kotlin/org/jetbrains/kotlinx/spark/api/jupyter/SparkIntegration.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ class SparkIntegration(notebook: Notebook, options: MutableMap<String, String?>)
200200
try {
201201
spark!!.addArtifact(it)
202202
} catch (e: Exception) {
203-
println("Error while adding artifact $it: $e")
203+
if (properties.debug) println("Error while adding artifact $it: $e")
204204
}
205205
}
206206

0 commit comments

Comments
 (0)