This is an automated email from the ASF dual-hosted git repository.
ipolyzos pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 660203879 [log] Fix error message in CompactedRowReader.java (#2694)
660203879 is described below
commit 660203879c32d4e861643b47df9c8deeceb2b274
Author: nhuantho <[email protected]>
AuthorDate: Tue Feb 17 13:32:43 2026 +0700
[log] Fix error message in CompactedRowReader.java (#2694)
Co-authored-by: nhuan.bc <[email protected]>
---
.../main/java/org/apache/fluss/row/compacted/CompactedRowReader.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/fluss-common/src/main/java/org/apache/fluss/row/compacted/CompactedRowReader.java
b/fluss-common/src/main/java/org/apache/fluss/row/compacted/CompactedRowReader.java
index 64075c95a..e51f2ad60 100644
---
a/fluss-common/src/main/java/org/apache/fluss/row/compacted/CompactedRowReader.java
+++
b/fluss-common/src/main/java/org/apache/fluss/row/compacted/CompactedRowReader.java
@@ -338,7 +338,8 @@ public class CompactedRowReader {
fieldReader = (reader, pos) ->
reader.readRow(nestedFieldTypes);
break;
default:
- throw new IllegalArgumentException("Unsupported type for
IndexedRow: " + fieldType);
+ throw new IllegalArgumentException(
+ "Unsupported type for CompatedRow: " + fieldType);
}
if (!fieldType.isNullable()) {
return fieldReader;