From b905cd53c20f5714fb213547f4258f9cf7fc0710 Mon Sep 17 00:00:00 2001 From: Shanicky Chen Date: Thu, 23 Nov 2023 16:50:04 +0800 Subject: [PATCH] Add comment explaining affected_table_change field in CreateSinkRequest. --- proto/ddl_service.proto | 2 +- proto/stream_plan.proto | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/proto/ddl_service.proto b/proto/ddl_service.proto index 0eb928375eda2..46fe4305482d4 100644 --- a/proto/ddl_service.proto +++ b/proto/ddl_service.proto @@ -77,10 +77,10 @@ message AlterSourceResponse { uint64 version = 2; } - message CreateSinkRequest { catalog.Sink sink = 1; stream_plan.StreamFragmentGraph fragment_graph = 2; + // It is used to provide a replace plan for the downstream table in `create sink into table` requests. optional ReplaceTablePlan affected_table_change = 3; } diff --git a/proto/stream_plan.proto b/proto/stream_plan.proto index 4e4ee33384fe8..718a28907e7a8 100644 --- a/proto/stream_plan.proto +++ b/proto/stream_plan.proto @@ -90,7 +90,6 @@ message ThrottleMutation { map actor_throttle = 1; } - message CombinedMutation { repeated BarrierMutation mutations = 1; }