Skip to content

Commit

Permalink
put lowercase param name
Browse files Browse the repository at this point in the history
  • Loading branch information
sfc-gh-bzabek committed Nov 14, 2024
1 parent 068829a commit 3779598
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ public StreamingClientProperties(Map<String, String> connectorConfig) {
// Override only if the streaming client properties are explicitly set in config
this.parameterOverrides = new HashMap<>();
if (isIcebergEnabled) {
parameterOverrides.put("ENABLE_ICEBERG_STREAMING", "true");
parameterOverrides.put("enable_iceberg_streaming", "true");
}
Optional<String> snowpipeStreamingMaxClientLag =
Optional.ofNullable(connectorConfig.get(SNOWPIPE_STREAMING_MAX_CLIENT_LAG));
Expand Down

0 comments on commit 3779598

Please sign in to comment.