[minor] minor improvement

Author: leonardBang

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/HudiConfig.java

@@ -69,11 +69,6 @@ private static ConfigOption<Boolean> booleanOption(
     public static final ConfigOption<String> PATH =
             stringOption(FlinkOptions.PATH.key(), FlinkOptions.PATH.description());
 
-    //    public static final ConfigOption<String> TABLE_TYPE =
-    //            stringOption(
-    //                    FlinkOptions.TABLE_TYPE.key(),
-    //                    FlinkOptions.TABLE_TYPE.defaultValue(),
-    //                    FlinkOptions.TABLE_TYPE.description());
     public static final ConfigOption<String> TABLE_TYPE =
             stringOption(
                     "hoodie.table.type",

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/util/RowDataUtils.java

@@ -143,7 +143,7 @@ public static FieldGetter createFieldGetter(DataType fieldType, int fieldPos, Zo
                         };
                 break;
             case TINYINT:
-                fieldGetter = row -> row.getBoolean(fieldPos);
+                fieldGetter = row -> row.getByte(fieldPos);
                 break;
             case SMALLINT:
                 fieldGetter = row -> row.getInt(fieldPos);

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToHudiE2eITCase.java

@@ -116,7 +116,7 @@ public static void initializeContainers() {
     public void before() throws Exception {
         LOG.info("Starting containers...");
 
-        // 2. Instantiate the correct class and apply class-specific methods
+        // Instantiate the correct class and apply class-specific methods
         if (debug) {
             // Use FixedHost instead of GenericContainer to ensure that ports are fixed for easier
             // debugging during dev