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(