diff --git a/meta/statement_executor_test.go b/meta/statement_executor_test.go
index 3b9a9c6db2f..1e35d4ebbc5 100644
--- a/meta/statement_executor_test.go
+++ b/meta/statement_executor_test.go
@@ -560,7 +560,7 @@ func TestStatementExecutor_ExecuteStatement_CreateContinuousQuery(t *testing.T)
 			t.Fatalf("unexpected database: %s", database)
 		} else if name != "cq0" {
 			t.Fatalf("unexpected name: %s", name)
-		} else if query != `SELECT count(*) INTO db1 FROM db0 GROUP BY time(1h)` {
+		} else if query != `CREATE CONTINUOUS QUERY cq0 ON db0 BEGIN SELECT count(*) INTO db1 FROM db0 GROUP BY time(1h) END` {
 			t.Fatalf("unexpected query: %s", query)
 		}
 		return nil