fix for tunnel write provider

shujiewu · shujiewu · commit 2a58898aec34 · 2024-12-11T11:04:02.000+08:00
diff --git a/spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsWriteBuilder.scala b/spark-connector/datasource/src/main/scala/org/apache/spark/sql/execution/datasources/v2/odps/OdpsWriteBuilder.scala
@@ -127,7 +127,7 @@ case class OdpsWriteBuilder(
       }
 
       val settings = OdpsClient.get.getEnvironmentSettings
-      val provider = catalog.odpsOptions.tableReadProvider
+      val provider = catalog.odpsOptions.tableWriteProvider
 
       val arrowOptions = ArrowOptions.newBuilder()
         .withDatetimeUnit(TimestampUnit.MILLI)

Original file line number	Diff line number	Diff line change
`@@ -127,7 +127,7 @@ case class OdpsWriteBuilder(`
`127`	`127`	`}`
`128`	`128`
`129`	`129`	`val settings = OdpsClient.get.getEnvironmentSettings`
`130`		`- val provider = catalog.odpsOptions.tableReadProvider`
	`130`	`+ val provider = catalog.odpsOptions.tableWriteProvider`
`131`	`131`
`132`	`132`	`val arrowOptions = ArrowOptions.newBuilder()`
`133`	`133`	`.withDatetimeUnit(TimestampUnit.MILLI)`