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());