throw exception at illegal access

Author: polyzos

fluss-client/src/main/java/org/apache/fluss/client/utils/ConverterUtils.java

@@ -483,10 +483,11 @@ public GenericRow toRow(T pojo) {
             try {
                 value = fieldToRowConverters[i].convert(pojo);
             } catch (IllegalAccessException e) {
-                LOG.warn(
-                        "Failed to access field {} in POJO class {}.",
-                        rowType.getFieldNames().get(i),
-                        pojoClass.getName(),
+                throw new IllegalStateException(
+                        String.format(
+                                "Failed to access field %s in POJO class %s.",
+                                rowType.getFieldNames().get(i),
+                                pojoClass.getName()),
                         e);
             }
             row.setField(i, value);
@@ -517,10 +518,11 @@ public T fromRow(InternalRow row) {
                             pojoFields[i].set(pojo, value);
                         }
                     } catch (IllegalAccessException e) {
-                        LOG.warn(
-                                "Failed to set field {} in POJO class {}.",
-                                rowType.getFieldNames().get(i),
-                                pojoClass.getName(),
+                        throw new IllegalStateException(
+                                String.format(
+                                        "Failed to set field %s in POJO class %s.",
+                                        rowType.getFieldNames().get(i),
+                                        pojoClass.getName()),
                                 e);
                     }
                 }

fluss-client/src/test/java/org/apache/fluss/client/utils/ConverterUtilsTest.java

@@ -224,6 +224,22 @@ public void testRowWithMissingFields() {
         assertThat(convertedPojo.offsetDateTimeField).isNull();
     }
 
+    @Test
+    public void testFieldAccessFailureThrows() {
+        RowType rowType = RowType.builder().field("intField", DataTypes.INT()).build();
+
+        ConverterUtils<FinalFieldPojo> converter =
+                ConverterUtils.getConverter(FinalFieldPojo.class, rowType);
+
+        GenericRow row = new GenericRow(1);
+        row.setField(0, 42);
+
+        assertThatThrownBy(() -> converter.fromRow(row))
+                .isInstanceOf(IllegalStateException.class)
+                .hasMessageContaining("Failed to set field")
+                .hasMessageContaining("intField");
+    }
+
     @Test
     public void testWriteAndReadPojos() throws Exception {
         TablePath tablePath = new TablePath("test_db", "pojo_table");
@@ -466,4 +482,13 @@ private RowType createTestPojoRowType() {
                 .field("offsetDateTimeField", DataTypes.TIMESTAMP_LTZ())
                 .build();
     }
+
+    /** POJO with a final field to trigger IllegalAccessException on setting. */
+    public static class FinalFieldPojo {
+        private final int intField;
+
+        public FinalFieldPojo() {
+            this.intField = 0;
+        }
+    }
 }