diff --git a/spark/spark-tensorflow-connector/pom.xml b/spark/spark-tensorflow-connector/pom.xml
index 389ab173..114ee6a2 100644
--- a/spark/spark-tensorflow-connector/pom.xml
+++ b/spark/spark-tensorflow-connector/pom.xml
@@ -4,7 +4,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
org.tensorflow
- spark-tensorflow-connector_2.11
+ spark-tensorflow-connector_2.12
jar
1.10.0
spark-tensorflow-connector
@@ -27,13 +27,14 @@
UTF-8
- 3.2.2
- 2.11
- 1.0
- 2.2.6
- 3.0
+ 4.2.0
+ 2.12.10
+ 2.12
+ 2.0.0
+ 3.0.8
+ 3.8.0
1.8
- 2.3.1
+ 3.0.0-preview2
2.7.3
4.11
@@ -86,7 +87,7 @@
incremental
true
- ${scala.binary.version}
+ ${scala.version}
false
diff --git a/spark/spark-tensorflow-connector/src/main/scala/org/tensorflow/spark/datasources/tfrecords/DefaultSource.scala b/spark/spark-tensorflow-connector/src/main/scala/org/tensorflow/spark/datasources/tfrecords/DefaultSource.scala
index bea6623d..628ed65a 100644
--- a/spark/spark-tensorflow-connector/src/main/scala/org/tensorflow/spark/datasources/tfrecords/DefaultSource.scala
+++ b/spark/spark-tensorflow-connector/src/main/scala/org/tensorflow/spark/datasources/tfrecords/DefaultSource.scala
@@ -167,7 +167,7 @@ class DefaultSource extends DataSourceRegister
}
}
-object DefaultSource {
+object DefaultSource extends scala.Serializable {
// The function run on each worker.
// Writes the partition to a file and returns the number of records output.
private def writePartitionLocal(