fix

Signed-off-by: Song Gao <disxiaofei@163.com>
lf-edge · Dec 19, 2024 · 94b19be · 94b19be
1 parent 15010f5
commit 94b19be
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 9 deletions.
diff --git a/internal/converter/json/converter_test.go b/internal/converter/json/converter_test.go
@@ -23,7 +23,6 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/lf-edge/ekuiper/v2/internal/conf"
 	"github.com/lf-edge/ekuiper/v2/internal/topo/context"
 	"github.com/lf-edge/ekuiper/v2/pkg/ast"
 	mockContext "github.com/lf-edge/ekuiper/v2/pkg/mock/context"
@@ -770,11 +769,10 @@ func TestDecodeField(t *testing.T) {
 }
 
 func TestIssue3441(t *testing.T) {
-	conf.IsTesting = false
 	originSchema := map[string]*ast.JsonStreamField{
 		"id": nil,
 	}
-	f := NewFastJsonConverter(originSchema, nil)
+	f := NewFastJsonConverter(originSchema, map[string]any{"useInt64ForWholeNumber": true})
 	data := `{"id":1795292668348461056}`
 	ctx := mockContext.NewMockContext("test", "op1")
 	m, err := f.Decode(ctx, []byte(data))

diff --git a/internal/io/memory/lookupsource_test.go b/internal/io/memory/lookupsource_test.go
@@ -131,7 +131,6 @@ func TestUpdateLookup(t *testing.T) {
 }
 
 func TestLookup(t *testing.T) {
-	conf.IsTesting = true
 	contextLogger := conf.Log.WithField("rule", "test2")
 	ctx := context.WithValue(context.Background(), context.LoggerKey, contextLogger)
 	ls := GetLookupSource().(api.LookupSource)

diff --git a/internal/topo/node/decode_op_test.go b/internal/topo/node/decode_op_test.go
@@ -24,7 +24,6 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/lf-edge/ekuiper/v2/internal/conf"
 	"github.com/lf-edge/ekuiper/v2/internal/pkg/def"
 	"github.com/lf-edge/ekuiper/v2/internal/xsql"
 	"github.com/lf-edge/ekuiper/v2/pkg/ast"
@@ -393,7 +392,6 @@ func TestPayloadDecodeWithSchema(t *testing.T) {
 }
 
 func TestPayloadBatchDecodeWithSchema(t *testing.T) {
-	conf.IsTesting = true
 	tests := []struct {
 		name   string
 		input  any

diff --git a/internal/topo/node/lookup_node_test.go b/internal/topo/node/lookup_node_test.go
@@ -23,7 +23,6 @@ import (
 	"github.com/lf-edge/ekuiper/contract/v2/api"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/lf-edge/ekuiper/v2/internal/conf"
 	"github.com/lf-edge/ekuiper/v2/internal/pkg/def"
 	"github.com/lf-edge/ekuiper/v2/internal/topo/lookup"
 	"github.com/lf-edge/ekuiper/v2/internal/xsql"
@@ -342,7 +341,6 @@ func TestLookup(t *testing.T) {
 }
 
 func TestLookupInner(t *testing.T) {
-	conf.IsTesting = true
 	tests := []struct {
 		name   string
 		input  any
@@ -610,7 +608,6 @@ func TestLookupInner(t *testing.T) {
 }
 
 func TestLookupPayload(t *testing.T) {
-	conf.IsTesting = true
 	tests := []struct {
 		name   string
 		input  any