diff --git a/ksql-engine/src/main/java/io/confluent/ksql/physical/PhysicalPlanBuilder.java b/ksql-engine/src/main/java/io/confluent/ksql/physical/PhysicalPlanBuilder.java
index 1f0ed1aeb4a5..001bceddbd45 100644
--- a/ksql-engine/src/main/java/io/confluent/ksql/physical/PhysicalPlanBuilder.java
+++ b/ksql-engine/src/main/java/io/confluent/ksql/physical/PhysicalPlanBuilder.java
@@ -49,7 +49,7 @@
 import io.confluent.ksql.util.Pair;
 import io.confluent.ksql.util.SchemaUtil;
 import io.confluent.ksql.util.SerDeUtil;
-import io.confluent.ksql.util.WindowedSerde;
+import io.confluent.ksql.serde.WindowedSerde;
 import org.apache.kafka.common.serialization.Serde;
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.connect.data.Field;
diff --git a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java
index f61e0ce7f6bd..e30e1a9436bd 100644
--- a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java
+++ b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java
@@ -20,7 +20,7 @@
 import io.confluent.ksql.parser.tree.Expression;
 import io.confluent.ksql.GenericRow;
 import io.confluent.ksql.util.Pair;
-import io.confluent.ksql.util.WindowedSerde;
+import io.confluent.ksql.serde.WindowedSerde;
 import org.apache.kafka.common.serialization.Serde;
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.connect.data.Field;
diff --git a/ksql-serde/src/main/java/io/confluent/ksql/serde/WindowedSerde.java b/ksql-serde/src/main/java/io/confluent/ksql/serde/WindowedSerde.java
index 36a22fec1ba7..445d575aed85 100644
--- a/ksql-serde/src/main/java/io/confluent/ksql/serde/WindowedSerde.java
+++ b/ksql-serde/src/main/java/io/confluent/ksql/serde/WindowedSerde.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  **/
 
-package io.confluent.ksql.util;
+package io.confluent.ksql.serde;
 
 import org.apache.kafka.common.serialization.Deserializer;
 import org.apache.kafka.common.serialization.Serde;