From 10f9ff6b0919de296548d437a157ded793b100b6 Mon Sep 17 00:00:00 2001
From: zwang28 <84491488@qq.com>
Date: Tue, 5 Sep 2023 22:38:37 +0800
Subject: [PATCH] fix(test): set correct row per second

---
 src/tests/state_cleaning_test/data/agg.toml             | 2 +-
 src/tests/state_cleaning_test/data/join.toml            | 4 ++--
 src/tests/state_cleaning_test/data/temporal_filter.toml | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/tests/state_cleaning_test/data/agg.toml b/src/tests/state_cleaning_test/data/agg.toml
index 921908bc73fe..926fc4276b8b 100644
--- a/src/tests/state_cleaning_test/data/agg.toml
+++ b/src/tests/state_cleaning_test/data/agg.toml
@@ -11,7 +11,7 @@ init_sqls = [
         WATERMARK FOR created_at AS created_at - interval '9' second
     ) APPEND ONLY WITH (
         connector = 'datagen',
-        rows_per_second = 100,
+        datagen.rows.per.second = 100,
         datagen.split.num = 16,
         fields.created_at.max_past_mode = 'relative',
         fields.created_at.max_past = '10s',
diff --git a/src/tests/state_cleaning_test/data/join.toml b/src/tests/state_cleaning_test/data/join.toml
index 76d5379231c9..f03600acdfdf 100644
--- a/src/tests/state_cleaning_test/data/join.toml
+++ b/src/tests/state_cleaning_test/data/join.toml
@@ -10,7 +10,7 @@ init_sqls = [
         WATERMARK FOR created_at AS created_at - interval '9' second
     ) APPEND ONLY WITH (
         connector = 'datagen',
-        rows_per_second = 100,
+        datagen.rows.per.second = 100,
         datagen.split.num = 16,
         fields.created_at.max_past_mode = 'relative',
         fields.created_at.max_past = '10s',
@@ -30,7 +30,7 @@ init_sqls = [
         WATERMARK FOR created_at AS created_at - interval '9' second
     ) APPEND ONLY WITH (
         connector = 'datagen',
-        rows_per_second = 200,
+        datagen.rows.per.second = 200,
         datagen.split.num = 16,
         fields.created_at.max_past_mode = 'relative',
         fields.created_at.max_past = '10s',
diff --git a/src/tests/state_cleaning_test/data/temporal_filter.toml b/src/tests/state_cleaning_test/data/temporal_filter.toml
index 043bb852a766..6010dc0e1260 100644
--- a/src/tests/state_cleaning_test/data/temporal_filter.toml
+++ b/src/tests/state_cleaning_test/data/temporal_filter.toml
@@ -9,7 +9,7 @@ init_sqls = [
         WATERMARK FOR created_at AS created_at - interval '9' second
     ) APPEND ONLY WITH (
         connector = 'datagen',
-        rows_per_second = 200,
+        datagen.rows.per.second = 200,
         datagen.split.num = 16,
         fields.created_at.max_past_mode = 'relative',
         fields.created_at.max_past = '10s',