From 8d2c1397ba904d1223d913d98510684775f2d345 Mon Sep 17 00:00:00 2001
From: wuzhanpeng <wuzhanpeng@bigo.sg>
Date: Tue, 28 Dec 2021 14:58:01 +0800
Subject: [PATCH] fix not match primitive schema

---
 .../connectors/pulsar/serialization/PulsarPrimitiveSchema.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/serialization/PulsarPrimitiveSchema.java b/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/serialization/PulsarPrimitiveSchema.java
index 6fa2c6fe..9dbc68b7 100644
--- a/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/serialization/PulsarPrimitiveSchema.java
+++ b/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/serialization/PulsarPrimitiveSchema.java
@@ -77,7 +77,7 @@ public class PulsarPrimitiveSchema<T>
         pulsarPrimitives.put(Float.TYPE, FloatSchema.of());
         pulsarPrimitives.put(Double.class, DoubleSchema.of());
         pulsarPrimitives.put(Double.TYPE, DoubleSchema.of());
-        pulsarPrimitives.put(Byte[].class, BytesSchema.of());
+        pulsarPrimitives.put(byte[].class, BytesSchema.of());
         pulsarPrimitives.put(Date.class, DateSchema.of());
         pulsarPrimitives.put(Time.class, TimeSchema.of());
         pulsarPrimitives.put(Timestamp.class, TimestampSchema.of());