diff --git a/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java b/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java
index 19839a0205b171345563eead3caa2678b273a645..feaa373b3fa63b641b14d9cc3b98b7fac51bf194 100644
--- a/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java
+++ b/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java
@@ -86,7 +86,7 @@ public class SqlCreateTable extends SqlCreate implements ExtendedSqlNode {
 		super(OPERATOR, pos, false, false);
 		this.tableName = requireNonNull(tableName, "tableName should not be null");
 		this.columnList = requireNonNull(columnList, "columnList should not be null");
-		this.primaryKeyList = requireNonNull(primaryKeyList, "primayKeyList should not be null");
+		this.primaryKeyList = requireNonNull(primaryKeyList, "primaryKeyList should not be null");
 		this.uniqueKeysList = requireNonNull(uniqueKeysList, "uniqueKeysList should not be null");
 		this.propertyList = requireNonNull(propertyList, "propertyList should not be null");
 		this.partitionKeyList = requireNonNull(partitionKeyList, "partitionKeyList should not be null");