[producer] Allow top-level union-schema in the shell producer (#698)

linkedin · Oct 16, 2023 · 1e08181 · 1e08181
1 parent 94c59de
commit 1e08181
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/clients/venice-producer/src/main/java/com/linkedin/venice/producer/online/ProducerTool.java b/clients/venice-producer/src/main/java/com/linkedin/venice/producer/online/ProducerTool.java
@@ -12,7 +12,6 @@
 import com.linkedin.venice.client.store.ClientFactory;
 import com.linkedin.venice.client.store.StatTrackingStoreClient;
 import com.linkedin.venice.exceptions.VeniceException;
-import com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter;
 import com.linkedin.venice.security.SSLFactory;
 import com.linkedin.venice.utils.ExceptionUtils;
 import com.linkedin.venice.utils.SslUtils;
@@ -225,10 +224,6 @@ private static Object getValueObject(String valueString, RouterBasedStoreSchemaF
   }
 
   private static Object adaptDataToSchema(String dataString, Schema dataSchema) {
-    while (dataSchema.getType().equals(Schema.Type.UNION)) {
-      dataSchema = VsonAvroSchemaAdapter.stripFromUnion(dataSchema);
-    }
-
     Object data;
     switch (dataSchema.getType()) {
       case INT: