Skip to content

Commit 0d65900

Browse files
committed
fix test hand due to unsupported operation
1 parent 8cf9c1a commit 0d65900

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/sink/serializer/RowSerializationSchema.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ public RowWithOp serialize(RowData value) throws Exception {
8282
throw new IllegalStateException(
8383
"Converter not initialized. The open() method must be called before serializing records.");
8484
}
85-
8685
InternalRow row = converter.replace(value);
8786
OperationType opType = toOperationType(value.getRowKind());
8887
// commenting this out for now to satisfy the FlinkRowDataChannelComputer since it doesn't
@@ -110,13 +109,9 @@ private OperationType toOperationType(RowKind rowKind) {
110109
return null;
111110
}
112111
}
112+
113113
if (isAppendOnly) {
114-
if (rowKind == RowKind.INSERT) {
115-
return OperationType.APPEND;
116-
} else {
117-
throw new UnsupportedOperationException(
118-
"Unsupported row kind: " + rowKind + " in append-only mode");
119-
}
114+
return OperationType.APPEND;
120115
} else {
121116
switch (rowKind) {
122117
case INSERT:

0 commit comments

Comments
 (0)