We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 062d91c commit 82b92feCopy full SHA for 82b92fe
1 file changed
hologres-connector-spark-base/src/main/scala/com/alibaba/hologres/spark/sink/copy/CopyContext.scala
@@ -1,6 +1,7 @@
1
package com.alibaba.hologres.spark.sink.copy
2
3
import com.alibaba.hologres.client.copy.RecordOutputStream
4
+import com.alibaba.hologres.client.copy.CopyMode
5
import com.alibaba.hologres.client.model.TableSchema
6
import com.alibaba.hologres.org.postgresql.PGProperty
7
import com.alibaba.hologres.org.postgresql.copy.CopyManager
@@ -103,7 +104,7 @@ class CopyContext {
103
104
throw new RuntimeException(e)
105
}
106
- if (hologresConfigs.copyMode == CopyMode.BULK_LOAD_ON_CONFLICT) {
107
+ if (configs.copyMode == CopyMode.BULK_LOAD_ON_CONFLICT) {
108
try {
109
{val stmt = conn.createStatement()
110
stmt.execute("set hg_experimental_copy_enable_on_conflict = on;")
0 commit comments