Merge branch '1.8_v3.9.0_beta_1.1' into 'v1.8.0_dev'

1.8 v3.9.0 beta 1.1



See merge request !152

Author: simenliuxing

kafka/kafka-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java

@@ -217,7 +217,7 @@ public void setFetcher(AbstractFetcher<Row, ?> fetcher) {
 
     protected void registerPtMetric(AbstractFetcher<Row, ?> fetcher) throws Exception {
 
-        Field consumerThreadField = fetcher.getClass().getSuperclass().getDeclaredField("consumerThread");
+        Field consumerThreadField = fetcher.getClass().getDeclaredField("consumerThread");
         consumerThreadField.setAccessible(true);
         KafkaConsumerThread consumerThread = (KafkaConsumerThread) consumerThreadField.get(fetcher);