From c82e3462e3d56b1f6c92d80720a9503da8e57765 Mon Sep 17 00:00:00 2001
From: sandyfog <154525105@qq.com>
Date: Mon, 13 Jun 2022 10:55:24 +0800
Subject: [PATCH] [MINOR]  fix AvroSchemaConverter duplicate branch in 'switch'
 (#5813)

---
 .../main/java/org/apache/hudi/util/AvroSchemaConverter.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
index 6e87ff1fb..9a33df3a4 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java
@@ -71,6 +71,8 @@ public class AvroSchemaConverter {
         }
         return DataTypes.ROW(fields).notNull();
       case ENUM:
+      case STRING:
+        // convert Avro's Utf8/CharSequence to String
         return DataTypes.STRING().notNull();
       case ARRAY:
         return DataTypes.ARRAY(convertToDataType(schema.getElementType())).notNull();
@@ -110,9 +112,6 @@ public class AvroSchemaConverter {
         }
         // convert fixed size binary data to primitive byte arrays
         return DataTypes.VARBINARY(schema.getFixedSize()).notNull();
-      case STRING:
-        // convert Avro's Utf8/CharSequence to String
-        return DataTypes.STRING().notNull();
       case BYTES:
         // logical decimal type
         if (schema.getLogicalType() instanceof LogicalTypes.Decimal) {