fix(frontend): fix changelog append_only (#17583)

risingwavelabs · Aug 26, 2024 · 072d7e7 · 072d7e7
1 parent 6caaab5
commit 072d7e7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/integration_tests/snowflake-sink/upsert/create_sink.sql b/integration_tests/snowflake-sink/upsert/create_sink.sql
@@ -13,7 +13,4 @@ CREATE SINK snowflake_sink FROM ss_mv WITH (
  snowflake.aws_secret_access_key = 'EXAMPLE_SECRET_KEY',
  snowflake.aws_region = 'EXAMPLE_REGION',
  snowflake.s3_path = 'EXAMPLE_S3_PATH',
- -- depends on your mv setup, note that snowflake sink *only* supports
- -- `append-only` mode at present.
- force_append_only = 'true'
 );
diff --git a/src/frontend/src/optimizer/plan_node/stream_changelog.rs b/src/frontend/src/optimizer/plan_node/stream_changelog.rs
@@ -43,7 +43,8 @@ impl StreamChangeLog {
  let base = PlanBase::new_stream_with_core(
  &core,
  dist,
- input.append_only(),
+ // The changelog will convert all delete/update to insert, so it must be true here.
+ true,
  input.emit_on_window_close(),
  watermark_columns,
  );