From cbe457477631c16df1c5555c45cac4b927a1dea9 Mon Sep 17 00:00:00 2001 From: Stas Panasiuk Date: Thu, 21 Mar 2024 09:28:33 -0400 Subject: [PATCH] [CYB-206] dev log removed --- .../cloudera/cyber/indexing/hive/util/AvroSchemaUtil.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) 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) {