fix: default dialect (#284)

rhajek · rhajek · commit 8abd56cd1a54 · 2021-12-03T17:10:23.000+01:00
diff --git a/client-kotlin/src/main/kotlin/com/influxdb/client/kotlin/internal/QueryKotlinApiImpl.kt b/client-kotlin/src/main/kotlin/com/influxdb/client/kotlin/internal/QueryKotlinApiImpl.kt
@@ -194,7 +194,7 @@ internal class QueryKotlinApiImpl(private val service: QueryService, private val
         val channel = Channel<T>()
 
         val queryCall = service.postQueryResponseBody(null, null,
-                null, org, null, query)
+                null, org, null, query.dialect(AbstractInfluxDBClient.DEFAULT_DIALECT))
 
         val responseConsumer = object : FluxResponseConsumer {
 
diff --git a/client-scala/src/main/scala/com/influxdb/client/scala/internal/QueryScalaApiImpl.scala b/client-scala/src/main/scala/com/influxdb/client/scala/internal/QueryScalaApiImpl.scala
@@ -102,7 +102,8 @@ class QueryScalaApiImpl(@Nonnull service: QueryService, @Nonnull options: Influx
 
     Source.unfoldResource[FluxRecord, AbstractQueryApi#FluxRecordIterator](
       () => {
-        val call = service.postQueryResponseBody(null, null, null, org, null, query)
+        val call = service.postQueryResponseBody(null, null, null, org, null,
+          query.dialect(AbstractInfluxDBClient.DEFAULT_DIALECT))
 
         queryIterator(call)
 
