diff --git a/gradle-plugin/src/main/kotlin/org/jetbrains/kotlinx/spark/api/gradlePlugin/SparkKotlinCompilerGradlePlugin.kt b/gradle-plugin/src/main/kotlin/org/jetbrains/kotlinx/spark/api/gradlePlugin/SparkKotlinCompilerGradlePlugin.kt index 23b83c41..fa3c77c5 100644 --- a/gradle-plugin/src/main/kotlin/org/jetbrains/kotlinx/spark/api/gradlePlugin/SparkKotlinCompilerGradlePlugin.kt +++ b/gradle-plugin/src/main/kotlin/org/jetbrains/kotlinx/spark/api/gradlePlugin/SparkKotlinCompilerGradlePlugin.kt @@ -19,7 +19,7 @@ class SparkKotlinCompilerGradlePlugin : KotlinCompilerPluginSupportPlugin { it.extensions.findByType()?.apply { compilerOptions { // Make sure the parameters of data classes are visible to scala - javaParameters.set(true) +// javaParameters.set(true) // Avoid NotSerializableException by making lambdas serializable freeCompilerArgs.add("-Xlambdas=class") diff --git a/kotlin-spark-api/src/test/kotlin/org/jetbrains/kotlinx/spark/api/StreamingTest.kt b/kotlin-spark-api/src/test/kotlin/org/jetbrains/kotlinx/spark/api/StreamingTest.kt index 86542aa8..3667fa45 100644 --- a/kotlin-spark-api/src/test/kotlin/org/jetbrains/kotlinx/spark/api/StreamingTest.kt +++ b/kotlin-spark-api/src/test/kotlin/org/jetbrains/kotlinx/spark/api/StreamingTest.kt @@ -219,13 +219,13 @@ private fun checkpointFile(checkpointDir: String, checkpointTime: Time): Path { private fun getCheckpointFiles( checkpointDir: String, fs: scala.Option -): scala.collection.immutable.Seq { +): scala.collection.Seq { val klass = Class.forName("org.apache.spark.streaming.Checkpoint$") val moduleField = klass.getField("MODULE$").also { it.isAccessible = true } val module = moduleField.get(null) val getCheckpointFilesMethod = klass.getMethod("getCheckpointFiles", String::class.java, scala.Option::class.java) .also { it.isAccessible = true } - return getCheckpointFilesMethod.invoke(module, checkpointDir, fs) as scala.collection.immutable.Seq + return getCheckpointFilesMethod.invoke(module, checkpointDir, fs) as scala.collection.Seq } private fun createCorruptedCheckpoint(): String {