diff --git a/modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala b/modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala index 49b2311..9922c16 100644 --- a/modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala +++ b/modules/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala @@ -203,8 +203,10 @@ object Channel { props.setProperty(ParameterProvider.ENABLE_SNOWPIPE_STREAMING_METRICS, "false") // Disable SDK's background flushing because we manage it ourselves - props.setProperty(ParameterProvider.BUFFER_FLUSH_INTERVAL_IN_MILLIS, Long.MaxValue.toString) props.setProperty(ParameterProvider.BUFFER_FLUSH_CHECK_INTERVAL_IN_MILLIS, Long.MaxValue.toString) + // Max allowed value for MAX_CLIENT_LAG is 10 min. However, background flushing is disabled with above + // line. Therefore, it isn't very important what value we use in here. + props.setProperty(ParameterProvider.MAX_CLIENT_LAG, "600000") props.setProperty(ParameterProvider.INSERT_THROTTLE_INTERVAL_IN_MILLIS, "0") props.setProperty(ParameterProvider.INSERT_THROTTLE_THRESHOLD_IN_PERCENTAGE, "0") props.setProperty(ParameterProvider.INSERT_THROTTLE_THRESHOLD_IN_BYTES, "0") diff --git a/project/Dependencies.scala b/project/Dependencies.scala index f182169..23b853a 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -24,7 +24,7 @@ object Dependencies { val slf4j = "2.0.7" val azureSdk = "1.9.1" val sentry = "6.25.2" - val snowflake = "2.0.3" + val snowflake = "2.2.2" val jaxb = "2.3.1" val awsSdk2 = "2.25.16" val netty = "4.1.100.Final" // Version override