Bump snowflake-ingest-sdk to 2.2.2 (#47)

snowplow-incubator · Oct 11, 2024 · d093127 · d093127
1 parent 423ae6b
commit d093127
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...les/core/src/main/scala/com.snowplowanalytics.snowplow.snowflake/processing/Channel.scala b/...les/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
@@ -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