Skip to content

Commit cf17b1e

Browse files
committed
fix checkstyle violation
1 parent 6db99f9 commit cf17b1e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

fluss-client/src/main/java/org/apache/fluss/client/converter/ConverterCommons.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ static void validatePojoMatchesProjection(PojoType<?> pojoType, RowType projecti
8989
if (!pojoNames.containsAll(fieldNames)) {
9090
throw new IllegalArgumentException(
9191
String.format(
92-
"POJO fields %s must contain all projection fields %s. For full-table writes, POJO fields must exactly match table schema fields.",
92+
"POJO fields %s must contain all projection fields %s.",
9393
pojoNames, fieldNames));
9494
}
9595
for (int i = 0; i < projection.getFieldCount(); i++) {

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/emitter/FlinkRecordEmitter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ record = deserializationSchema.deserialize(new ScanRecordLogRecord(scanRecord));
108108
}
109109
}
110110

111-
/** Lightweight adapter to view a ScanRecord<InternalRow> as a LogRecord. */
111+
/** Lightweight adapter to view a {@code ScanRecord<InternalRow>} as a {@link LogRecord}. */
112112
private static final class ScanRecordLogRecord implements LogRecord {
113113
private final ScanRecord<InternalRow> delegate;
114114

0 commit comments

Comments
 (0)