fix: enable bq storage api

goto · May 27, 2024 · 0e3a72c · 0e3a72c
1 parent 40fbc09
commit 0e3a72c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/bigquery/BigQuerySinkBuilder.java b/dagger-core/src/main/java/com/gotocompany/dagger/core/sink/bigquery/BigQuerySinkBuilder.java
@@ -44,6 +44,7 @@ private Configuration setDefaultValues(Configuration inputConf) {
         configMap.put("SCHEMA_REGISTRY_STENCIL_FETCH_HEADERS", "");
         configMap.put("SINK_METRICS_APPLICATION_PREFIX", "dagger_");
         configMap.put("SINK_BIGQUERY_ROW_INSERT_ID_ENABLE", "false");
+        configMap.put("SINK_BIGQUERY_STORAGE_API_ENABLE", "true");
         return new Configuration(ParameterTool.fromMap(configMap));
     }