fix

Signed-off-by: Song Gao <disxiaofei@163.com>

Author: Yisaer

internal/topo/node/node_test/window_inc_agg_event_op_test.go

@@ -24,7 +24,6 @@ import (
 	"github.com/lf-edge/ekuiper/v2/internal/conf"
 	"github.com/lf-edge/ekuiper/v2/internal/pkg/def"
 	"github.com/lf-edge/ekuiper/v2/internal/pkg/store"
-	"github.com/lf-edge/ekuiper/v2/internal/testx"
 	"github.com/lf-edge/ekuiper/v2/internal/topo/node"
 	"github.com/lf-edge/ekuiper/v2/internal/topo/planner"
 	"github.com/lf-edge/ekuiper/v2/internal/xsql"
@@ -33,9 +32,6 @@ import (
 )
 
 func TestIncEventHoppingWindowState(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	o := &def.RuleOption{
 		PlanOptimizeStrategy: &def.PlanOptimizeStrategy{

internal/topo/node/node_test/window_inc_agg_op_test.go

@@ -106,9 +106,6 @@ func TestWindowState(t *testing.T) {
 }
 
 func TestIncAggCountWindowState(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	o := &def.RuleOption{
 		BufferLength: 10,
 	}
@@ -174,9 +171,6 @@ func TestIncAggCountWindowState(t *testing.T) {
 }
 
 func TestIncAggWindow(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	o := &def.RuleOption{
 		BufferLength: 10,
 	}
@@ -228,9 +222,6 @@ func TestIncAggWindow(t *testing.T) {
 }
 
 func TestIncAggAlignTumblingWindow(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	node.EnableAlignWindow = true
 	o := &def.RuleOption{
@@ -331,9 +322,6 @@ func TestIncAggTumblingWindow(t *testing.T) {
 }
 
 func TestIncAggSlidingWindow(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	o := &def.RuleOption{
 		BufferLength: 10,
@@ -397,9 +385,6 @@ func TestIncAggSlidingWindow(t *testing.T) {
 }
 
 func TestIncAggSlidingWindowOver(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	o := &def.RuleOption{
 		BufferLength: 10,
@@ -453,9 +438,6 @@ func TestIncAggSlidingWindowOver(t *testing.T) {
 }
 
 func TestIncAggSlidingWindowDelay(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	o := &def.RuleOption{
 		BufferLength: 10,
@@ -545,9 +527,6 @@ func waitExecute() {
 }
 
 func TestIncHoppingWindow(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	node.EnableAlignWindow = false
 	o := &def.RuleOption{
@@ -605,9 +584,6 @@ func TestIncHoppingWindow(t *testing.T) {
 }
 
 func TestIncAggAlignHoppingWindow(t *testing.T) {
-	if testx.Race {
-		t.Skip("skip race test")
-	}
 	conf.IsTesting = true
 	node.EnableAlignWindow = true
 	o := &def.RuleOption{