You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/event/TableAwareCorrespondent.java
+5-1Lines changed: 5 additions & 1 deletion
Original file line number
Diff line number
Diff line change
@@ -132,7 +132,7 @@ public boolean requestCreatingTable(CreateTableEvent createTableEvent) {
132
132
}
133
133
134
134
/**
135
-
* An CoordinationRequest that encapsulates a {@link CreateTableEvent}.
135
+
* A CoordinationRequest that encapsulates a {@link CreateTableEvent}.
136
136
*
137
137
* <p>This request is sent from the {@code MultiTableEventStreamWriteFunction} to the {@code
138
138
* MultiTableStreamWriteOperatorCoordinator} to signal that a new table has been discovered in
@@ -157,6 +157,10 @@ public String toString() {
157
157
}
158
158
}
159
159
160
+
/**
161
+
* Response for a {@link CreateTableRequest}. This response is sent from writer coordinator to
162
+
* indicate whether the table is created successfully.
0 commit comments