Skip to content

Commit

Permalink
change the way parameter is put into overrideMap
Browse files Browse the repository at this point in the history
  • Loading branch information
sfc-gh-bzabek committed Nov 13, 2024
1 parent d25acc4 commit e5fc167
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -91,8 +91,9 @@ public StreamingClientProperties(Map<String, String> connectorConfig) {

// Override only if the streaming client properties are explicitly set in config
this.parameterOverrides = new HashMap<>();
parameterOverrides.put(ENABLE_ICEBERG_STREAMING, isIcebergEnabled);

if (isIcebergEnabled) {
parameterOverrides.put(ENABLE_ICEBERG_STREAMING, "true");
}
Optional<String> snowpipeStreamingMaxClientLag =
Optional.ofNullable(connectorConfig.get(SNOWPIPE_STREAMING_MAX_CLIENT_LAG));
snowpipeStreamingMaxClientLag.ifPresent(
Expand Down

0 comments on commit e5fc167

Please sign in to comment.