diff --git a/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java b/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java index 413638750..16461b330 100644 --- a/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java +++ b/flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java @@ -14,11 +14,7 @@ import org.apache.flink.types.Row; import java.time.Instant; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.Set; +import java.util.*; public class AvroSchemaUtil { @@ -52,7 +48,6 @@ public static void putRowIntoAvro(Row row, GenericRecord record, String fieldNam } } record.put(avroFieldName, value); - System.out.println("fieldName: " + fieldName + " value: " + value); } private static Object convertToAvroObject(Schema fieldSchema, Object value) {