diff --git a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
index 5cf10a879cc2..2d528b3a7439 100644
--- a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
+++ b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
@@ -150,6 +150,7 @@ private static DataSchema.ColumnDataType convertColumnDataType(RelDataTypeField
       case VARCHAR:
         return DataSchema.ColumnDataType.STRING;
       case BINARY:
+      case VARBINARY:
         return DataSchema.ColumnDataType.BYTES;
       default:
         throw new IllegalStateException("Unexpected RelDataTypeField: " + relDataTypeField.getType());