File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
arangodb-spark-commons/src/main/scala/org/apache/spark/sql/arangodb/commons Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -15,6 +15,7 @@ import org.apache.spark.sql.arangodb.commons.exceptions.ArangoDBMultiException
1515import org .apache .spark .sql .arangodb .commons .filter .PushableFilter
1616import org .apache .spark .sql .types .StructType
1717
18+ import java .util .UUID
1819import java .util .concurrent .TimeoutException
1920import scala .annotation .tailrec
2021import scala .collection .JavaConverters .mapAsJavaMapConverter
@@ -169,6 +170,8 @@ class ArangoClient(options: ArangoDBConf) extends Logging {
169170 request.putQueryParam(" keepNull" , options.writeOptions.keepNull)
170171 request.putQueryParam(" mergeObjects" , options.writeOptions.mergeObjects)
171172
173+ request.putHeaderParam(" x-arango-spark-request-id" , UUID .randomUUID.toString)
174+
172175 request.setBody(data)
173176 val response = arangoDB.execute(request)
174177
You can’t perform that action at this time.
0 commit comments