Repository: lf-edge/ekuiper
Pull request #874 (2021-07-02 09:54:24)

refactor(*): rename go module name


Patch:
diff --git a/cmd/kuiper/main.go b/cmd/kuiper/main.go
index ed86da61..f8688ac7 100644
--- a/cmd/kuiper/main.go
+++ b/cmd/kuiper/main.go
@@ -3,8 +3,8 @@ package main
 import (
 	"bufio"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/server"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/server"
 	"github.com/urfave/cli"
 	"gopkg.in/yaml.v3"
 	"io/ioutil"
diff --git a/cmd/kuiperd/main.go b/cmd/kuiperd/main.go
index be1865ed..b6bad5e3 100644
--- a/cmd/kuiperd/main.go
+++ b/cmd/kuiperd/main.go
@@ -1,6 +1,6 @@
 package main
 
-import "github.com/emqx/kuiper/internal/server"
+import "github.com/lf-edge/ekuiper/internal/server"
 
 var (
 	Version      = "unknown"
diff --git a/docs/en_US/plugins/plugins_tutorial.md b/docs/en_US/plugins/plugins_tutorial.md
index f922d194..73bc217d 100755
--- a/docs/en_US/plugins/plugins_tutorial.md
+++ b/docs/en_US/plugins/plugins_tutorial.md
@@ -48,7 +48,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 )
 ```
 
@@ -70,8 +70,8 @@ package main
 import (
 	"database/sql"
 	"fmt"
-	"github.com/emqx/kuiper/common"
-	"github.com/emqx/kuiper/xstream/api"
+	"github.com/lf-edge/ekuiper/common"
+	"github.com/lf-edge/ekuiper/xstream/api"
 	_ "github.com/go-sql-driver/mysql"
 )
 
@@ -149,7 +149,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 	github.com/go-sql-driver/mysql v1.5.0
 )
  ```
@@ -164,10 +164,10 @@ Developers can locally compile eKuiper and the plugin for debugging, which steps
 1. Download eKuiper source code: `git clone https://github.com/lf-edge/ekuiper.git`
 2.  Compile eKuiper: run `make` under the eKuiper directory
 3. Compile the plugin:
-    1. Run `go mod edit -replace github.com/emqx/kuiper=$eKuiperPath` under the plugin project, make the eKuiper dependence point to the local eKuiper, and then please replace the download directory of step 1 by $eKuiperPath, the same below.
+    1. Run `go mod edit -replace github.com/lf-edge/ekuiper=$eKuiperPath` under the plugin project, make the eKuiper dependence point to the local eKuiper, and then please replace the download directory of step 1 by $eKuiperPath, the same below.
    2. Because the Golang plugin system has a very strict limitation of the dependency paths, it is more safe to build the plugin from the eKuiper main project. In the eKuiper project, add a new *mod* file with a name like *sample.mod* to point to your plugin project.
       ```
-      module github.com/emqx/kuiper
+      module github.com/lf-edge/ekuiper
       go 1.16
       require samplePlugin v0.0.0
       replace samplePlugin => ../samplePlugin     
@@ -203,7 +203,7 @@ export ETC_TARGET=$EKUIPER_SOURCE/etc
 export ZIP_TARGET=plugins
 export VERSION=0.0.1
 
-go mod edit -replace github.com/emqx/kuiper=$EKUIPER_SOURCE
+go mod edit -replace github.com/lf-edge/ekuiper=$EKUIPER_SOURCE
 
 go build -trimpath --buildmode=plugin -o $PLUGIN_TARGET/sinks/Mysql@v$VERSION.so sinks/mysql.go
 
diff --git a/docs/en_US/plugins/sinks/influx.md b/docs/en_US/plugins/sinks/influx.md
index 861a5dbb..86933a60 100644
--- a/docs/en_US/plugins/sinks/influx.md
+++ b/docs/en_US/plugins/sinks/influx.md
@@ -71,11 +71,11 @@ module plugins
 go 1.14
 
 require (
-        github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+        github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
         github.com/influxdata/influxdb-client-go v1.2.0
         github.com/influxdata/influxdb1-client v0.0.0-20200515024757-02f0bf5dbca3 // indirect
 )
 
-replace github.com/emqx/kuiper => /root/goProject/kuiper
+replace github.com/lf-edge/ekuiper => /root/goProject/kuiper
 
 ```
diff --git a/docs/en_US/plugins/sinks/tdengine.md b/docs/en_US/plugins/sinks/tdengine.md
index a44e7e5a..9a0e9a7e 100644
--- a/docs/en_US/plugins/sinks/tdengine.md
+++ b/docs/en_US/plugins/sinks/tdengine.md
@@ -7,16 +7,16 @@ module plugins
 
 go 1.13
 
-replace github.com/emqx/kuiper => /$eKuiper
+replace github.com/lf-edge/ekuiper => /$eKuiper
 
 require (
-    github.com/emqx/kuiper v0.0.0-00010101000000-000000000000 // indirect
+    github.com/lf-edge/ekuiper v0.0.0-00010101000000-000000000000 // indirect
     github.com/taosdata/driver-go v0.0.0-20200723061832-5be6460b0c20
 )
 ```
 
 ```shell
-go mod edit -replace github.com/emqx/kuiper=/$eKuiper
+go mod edit -replace github.com/lf-edge/ekuiper=/$eKuiper
 go build -trimpath -modfile extensions.mod --buildmode=plugin -o /$ekuiper/plugins/sinks/Tdengine@v1.0.0.so /$ekuiper/extensions/sinks/tdengine/tdengine.go
 ```
 ### Install plugin
diff --git a/docs/zh_CN/plugins/plugins_tutorial.md b/docs/zh_CN/plugins/plugins_tutorial.md
index 76f94077..040fba46 100644
--- a/docs/zh_CN/plugins/plugins_tutorial.md
+++ b/docs/zh_CN/plugins/plugins_tutorial.md
@@ -48,7 +48,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 )
 ```
 
@@ -70,8 +70,8 @@ package main
 import (
 	"database/sql"
 	"fmt"
-	"github.com/emqx/kuiper/common"
-	"github.com/emqx/kuiper/xstream/api"
+	"github.com/lf-edge/ekuiper/common"
+	"github.com/lf-edge/ekuiper/xstream/api"
 	_ "github.com/go-sql-driver/mysql"
 )
 
@@ -149,7 +149,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 	github.com/go-sql-driver/mysql v1.5.0
 )
  ```
@@ -164,10 +164,10 @@ require (
 1. 下载 eKuiper 源代码 `git clone https://github.com/lf-edge/ekuiper.git`
 2. 编译 eKuiper：在 eKuiper 目录下，运行 `make`
 3. 编译插件：
-    1. 在插件项目下，运行 `go mod edit -replace github.com/emqx/kuiper=$eKuiperPath`，使得 eKuiper 依赖指向本地 eKuiper，请替换 $eKuiperPath 到步骤1下载目录，下同。
+    1. 在插件项目下，运行 `go mod edit -replace github.com/lf-edge/ekuiper=$eKuiperPath`，使得 eKuiper 依赖指向本地 eKuiper，请替换 $eKuiperPath 到步骤1下载目录，下同。
     2. 由于 Go 语言插件系统对依赖的路径有非常严格的要求，为了确保插件可以顺利运行，建议在 eKuiper 主项目里进行编译。在 eKuiper 项目里，添加如下名为 sample.mod 的 mod 文件，用于插件编译。
        ```
-       module github.com/emqx/kuiper
+       module github.com/lf-edge/ekuiper
        go 1.16
        require samplePlugin v0.0.0
        replace samplePlugin => ../samplePlugin   
@@ -204,7 +204,7 @@ export ETC_TARGET=$EKUIPER_SOURCE/etc
 export ZIP_TARGET=plugins
 export VERSION=0.0.1
 
-go mod edit -replace github.com/emqx/kuiper=$EKUIPER_SOURCE
+go mod edit -replace github.com/lf-edge/ekuiper=$EKUIPER_SOURCE
 
 go build -trimpath --buildmode=plugin -o $PLUGIN_TARGET/sinks/Mysql@v$VERSION.so sinks/mysql.go
 
diff --git a/docs/zh_CN/plugins/sinks/influx.md b/docs/zh_CN/plugins/sinks/influx.md
index af17e4f5..5f65465c 100644
--- a/docs/zh_CN/plugins/sinks/influx.md
+++ b/docs/zh_CN/plugins/sinks/influx.md
@@ -70,11 +70,11 @@ module plugins
 go 1.14
 
 require (
-        github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+        github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
         github.com/influxdata/influxdb-client-go v1.2.0
         github.com/influxdata/influxdb1-client v0.0.0-20200515024757-02f0bf5dbca3 // indirect
 )
 
-replace github.com/emqx/kuiper => /root/goProject/ekuiper
+replace github.com/lf-edge/ekuiper => /root/goProject/ekuiper
 
 ```
diff --git a/docs/zh_CN/plugins/sinks/tdengine.md b/docs/zh_CN/plugins/sinks/tdengine.md
index aeb65353..4ba3318a 100644
--- a/docs/zh_CN/plugins/sinks/tdengine.md
+++ b/docs/zh_CN/plugins/sinks/tdengine.md
@@ -7,16 +7,16 @@ module plugins
 
 go 1.13
 
-replace github.com/emqx/kuiper => /$eKuiper
+replace github.com/lf-edge/ekuiper => /$eKuiper
 
 require (
-    github.com/emqx/kuiper v0.0.0-00010101000000-000000000000 // indirect
+    github.com/lf-edge/ekuiper v0.0.0-00010101000000-000000000000 // indirect
     github.com/taosdata/driver-go v0.0.0-20200723061832-5be6460b0c20
 )
 ```
 
 ```shell
-go mod edit -replace github.com/emqx/kuiper=/$eKuiper
+go mod edit -replace github.com/lf-edge/ekuiper=/$eKuiper
 go build -trimpath -modfile extensions.mod --buildmode=plugin -o /$ekuiper/plugins/sinks/Tdengine@v1.0.0.so /$ekuiper/extensions/sinks/tdengine/tdengine.go
 ```
 ### 安装插件
diff --git a/extensions.mod b/extensions.mod
index dc7c4e7d..b667500e 100644
--- a/extensions.mod
+++ b/extensions.mod
@@ -1,4 +1,4 @@
-module github.com/emqx/kuiper
+module github.com/lf-edge/ekuiper
 
 require (
 	github.com/Masterminds/sprig/v3 v3.2.1
@@ -40,9 +40,9 @@ require (
 	google.golang.org/protobuf v1.26.0
 	gopkg.in/ini.v1 v1.62.0
 	gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c
-	github.com/emqx/kuiper/extensions v0.0.0
+	github.com/lf-edge/ekuiper/extensions v0.0.0
 )
 
-replace github.com/emqx/kuiper/extensions => ./extensions
+replace github.com/lf-edge/ekuiper/extensions => ./extensions
 
 go 1.16
diff --git a/extensions.sum b/extensions.sum
index a714d959..dc0a0035 100644
--- a/extensions.sum
+++ b/extensions.sum
@@ -127,6 +127,7 @@ github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible h1:Y6sqxHMyB1D2YSzWkL
 github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible/go.mod h1:ZQnN8lSECaebrkQytbHj4xNgtg8CR7RYXnPok8e0EHA=
 github.com/lestrrat-go/strftime v1.0.3 h1:qqOPU7y+TM8Y803I8fG9c/DyKG3xH/xkng6keC1015Q=
 github.com/lestrrat-go/strftime v1.0.3/go.mod h1:E1nN3pCbtMSu1yjSVeyuRFVm/U0xoR76fd03sz+Qz4g=
+github.com/lf-edge/ekuiper v0.0.0-20210528134227-7e6a6a028a6f/go.mod h1:Cv3+JK88Uv8CVKNQyRLKaFoZz9pPdhuDTZ2nSz/UiOU=
 github.com/mattn/go-pointer v0.0.0-20190911064623-a0a44394634f/go.mod h1:2zXcozF6qYGgmsG+SeTZz3oAbFLdD3OWqnUbNvJZAlc=
 github.com/mattn/go-sqlite3 v1.14.5 h1:1IdxlwTNazvbKJQSxoJ5/9ECbEeaTTyeU7sEAZ5KKTQ=
 github.com/mattn/go-sqlite3 v1.14.5/go.mod h1:WVKg1VTActs4Qso6iwGbiFih2UIHo0ENGwNd0Lj+XmI=
diff --git a/extensions/functions/accumulateWordCount/accumulateWordCount.go b/extensions/functions/accumulateWordCount/accumulateWordCount.go
index e88c655b..5ff10038 100644
--- a/extensions/functions/accumulateWordCount/accumulateWordCount.go
+++ b/extensions/functions/accumulateWordCount/accumulateWordCount.go
@@ -2,8 +2,8 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"strings"
 )
 
diff --git a/extensions/functions/countPlusOne/countPlusOne.go b/extensions/functions/countPlusOne/countPlusOne.go
index 9b41507e..06c9fc66 100644
--- a/extensions/functions/countPlusOne/countPlusOne.go
+++ b/extensions/functions/countPlusOne/countPlusOne.go
@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type countPlusOneFunc struct {
diff --git a/extensions/functions/echo/echo.go b/extensions/functions/echo/echo.go
index b0e85582..f95c0950 100644
--- a/extensions/functions/echo/echo.go
+++ b/extensions/functions/echo/echo.go
@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type echo struct {
diff --git a/extensions/functions/geohash/geohash.go b/extensions/functions/geohash/geohash.go
index 7616a596..998fda78 100644
--- a/extensions/functions/geohash/geohash.go
+++ b/extensions/functions/geohash/geohash.go
@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/mmcloughlin/geohash"
 )
 
diff --git a/extensions/functions/image/resize.go b/extensions/functions/image/resize.go
index cc549cee..d0d4be25 100644
--- a/extensions/functions/image/resize.go
+++ b/extensions/functions/image/resize.go
@@ -3,7 +3,7 @@ package main
 import (
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/nfnt/resize"
 	"image"
 	"image/jpeg"
diff --git a/extensions/functions/image/thumbnail.go b/extensions/functions/image/thumbnail.go
index 6ec4937d..2cfdd1ca 100644
--- a/extensions/functions/image/thumbnail.go
+++ b/extensions/functions/image/thumbnail.go
@@ -3,7 +3,7 @@ package main
 import (
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/nfnt/resize"
 	"image"
 	"image/jpeg"
diff --git a/extensions/functions/labelImage/labelImage.go b/extensions/functions/labelImage/labelImage.go
index 36cff2d5..cb6ac6c8 100644
--- a/extensions/functions/labelImage/labelImage.go
+++ b/extensions/functions/labelImage/labelImage.go
@@ -6,7 +6,7 @@ import (
 	"bufio"
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	tflite "github.com/mattn/go-tflite"
 	"github.com/nfnt/resize"
 	"image"
diff --git a/extensions/sinks/file/file.go b/extensions/sinks/file/file.go
index 2941c275..16780c97 100644
--- a/extensions/sinks/file/file.go
+++ b/extensions/sinks/file/file.go
@@ -4,7 +4,7 @@ import (
 	"bufio"
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"os"
 	"sync"
 	"time"
diff --git a/extensions/sinks/image/image.go b/extensions/sinks/image/image.go
index e09f23aa..a1bd45a0 100644
--- a/extensions/sinks/image/image.go
+++ b/extensions/sinks/image/image.go
@@ -5,7 +5,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"image/jpeg"
 	"image/png"
 	"io/ioutil"
diff --git a/extensions/sinks/influx/influx.go b/extensions/sinks/influx/influx.go
index d34af255..f7c236d8 100644
--- a/extensions/sinks/influx/influx.go
+++ b/extensions/sinks/influx/influx.go
@@ -4,9 +4,9 @@ package main
 
 import (
 	"encoding/json"
-	api "github.com/emqx/kuiper/pkg/api"
 	_ "github.com/influxdata/influxdb1-client/v2"
 	client "github.com/influxdata/influxdb1-client/v2"
+	api "github.com/lf-edge/ekuiper/pkg/api"
 	"strings"
 	"time"
 )
diff --git a/extensions/sinks/memory/memory.go b/extensions/sinks/memory/memory.go
index 32f06739..67d3b0bf 100644
--- a/extensions/sinks/memory/memory.go
+++ b/extensions/sinks/memory/memory.go
@@ -1,6 +1,6 @@
 package main
 
-import "github.com/emqx/kuiper/pkg/api"
+import "github.com/lf-edge/ekuiper/pkg/api"
 
 type memory struct {
 	results [][]byte
diff --git a/extensions/sinks/tdengine/tdengine.go b/extensions/sinks/tdengine/tdengine.go
index 908800d1..1dedac97 100644
--- a/extensions/sinks/tdengine/tdengine.go
+++ b/extensions/sinks/tdengine/tdengine.go
@@ -6,9 +6,9 @@ import (
 	"database/sql"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	_ "github.com/taosdata/driver-go/taosSql"
 	"reflect"
 	"strings"
diff --git a/extensions/sinks/zmq/zmq.go b/extensions/sinks/zmq/zmq.go
index 6ff98b25..c395206b 100644
--- a/extensions/sinks/zmq/zmq.go
+++ b/extensions/sinks/zmq/zmq.go
@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	zmq "github.com/pebbe/zmq4"
 )
 
diff --git a/extensions/sources/random/random.go b/extensions/sources/random/random.go
index 751b78c1..d845da97 100644
--- a/extensions/sources/random/random.go
+++ b/extensions/sources/random/random.go
@@ -4,9 +4,9 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"math/rand"
 	"strings"
 	"time"
diff --git a/extensions/sources/zmq/zmq.go b/extensions/sources/zmq/zmq.go
index 09d801d4..6c4a7217 100644
--- a/extensions/sources/zmq/zmq.go
+++ b/extensions/sources/zmq/zmq.go
@@ -3,8 +3,8 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	zmq "github.com/pebbe/zmq4"
 )
 
diff --git a/go.mod b/go.mod
index 99518eaa..61084cdb 100644
--- a/go.mod
+++ b/go.mod
@@ -1,4 +1,4 @@
-module github.com/emqx/kuiper
+module github.com/lf-edge/ekuiper
 
 require (
 	github.com/Masterminds/sprig/v3 v3.2.1
diff --git a/internal/conf/conf.go b/internal/conf/conf.go
index 1674efdc..16ff2286 100644
--- a/internal/conf/conf.go
+++ b/internal/conf/conf.go
@@ -2,8 +2,8 @@ package conf
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
 	"github.com/lestrrat-go/file-rotatelogs"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/sirupsen/logrus"
 	"gopkg.in/yaml.v3"
 	"io"
diff --git a/internal/conf/time.go b/internal/conf/time.go
index 8f5e88dd..374ee383 100644
--- a/internal/conf/time.go
+++ b/internal/conf/time.go
@@ -2,7 +2,7 @@ package conf
 
 import (
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"time"
 )
 
diff --git a/internal/pkg/httpx/http.go b/internal/pkg/httpx/http.go
index 990808bf..6514afad 100644
--- a/internal/pkg/httpx/http.go
+++ b/internal/pkg/httpx/http.go
@@ -5,8 +5,8 @@ import (
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"io"
 	"io/ioutil"
 	"net/http"
diff --git a/internal/plugin/funcMeta.go b/internal/plugin/funcMeta.go
index b260cdae..b7772521 100644
--- a/internal/plugin/funcMeta.go
+++ b/internal/plugin/funcMeta.go
@@ -2,8 +2,8 @@ package plugin
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
 	"io/ioutil"
 	"path"
 	"strings"
diff --git a/internal/plugin/manager.go b/internal/plugin/manager.go
index 9b3ebcbe..a4742678 100644
--- a/internal/plugin/manager.go
+++ b/internal/plugin/manager.go
@@ -5,12 +5,12 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io/ioutil"
 	"os"
 	"os/exec"
diff --git a/internal/plugin/msgUtil.go b/internal/plugin/msgUtil.go
index 2185960a..6a81e300 100644
--- a/internal/plugin/msgUtil.go
+++ b/internal/plugin/msgUtil.go
@@ -1,7 +1,7 @@
 package plugin
 
 import (
-	kconf "github.com/emqx/kuiper/internal/conf"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
 	"gopkg.in/ini.v1"
 	"io/ioutil"
 	"path"
diff --git a/internal/plugin/sinkMeta.go b/internal/plugin/sinkMeta.go
index 9e5c4cd3..71032a93 100644
--- a/internal/plugin/sinkMeta.go
+++ b/internal/plugin/sinkMeta.go
@@ -2,9 +2,9 @@ package plugin
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"io/ioutil"
 	"path"
 	"strings"
diff --git a/internal/plugin/sourceMeta.go b/internal/plugin/sourceMeta.go
index c9522b7a..679a37e1 100644
--- a/internal/plugin/sourceMeta.go
+++ b/internal/plugin/sourceMeta.go
@@ -3,9 +3,9 @@ package plugin
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"io/ioutil"
 	"path"
 	"reflect"
diff --git a/internal/processor/rule.go b/internal/processor/rule.go
index a7758f51..52d46dd6 100644
--- a/internal/processor/rule.go
+++ b/internal/processor/rule.go
@@ -4,15 +4,15 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/node"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/node"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"os"
 	"path"
 )
diff --git a/internal/processor/stream.go b/internal/processor/stream.go
index 7bd421a7..4ce16bc5 100644
--- a/internal/processor/stream.go
+++ b/internal/processor/stream.go
@@ -4,11 +4,11 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"strings"
 )
 
diff --git a/internal/server/rest.go b/internal/server/rest.go
index 6e2e3025..1aa614f3 100644
--- a/internal/server/rest.go
+++ b/internal/server/rest.go
@@ -4,14 +4,14 @@ import (
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
 	"github.com/gorilla/handlers"
 	"github.com/gorilla/mux"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"golang.org/x/net/html"
 	"io"
 	"io/ioutil"
diff --git a/internal/server/rpc.go b/internal/server/rpc.go
index df776e5c..bd8b8d28 100644
--- a/internal/server/rpc.go
+++ b/internal/server/rpc.go
@@ -4,9 +4,9 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
 	"strings"
 	"time"
 )
diff --git a/internal/server/ruleManager.go b/internal/server/ruleManager.go
index 2722bc2c..66fc7e19 100644
--- a/internal/server/ruleManager.go
+++ b/internal/server/ruleManager.go
@@ -5,10 +5,10 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"sort"
 	"sync"
 )
diff --git a/internal/server/server.go b/internal/server/server.go
index 4575300d..2303982e 100644
--- a/internal/server/server.go
+++ b/internal/server/server.go
@@ -1,11 +1,11 @@
 package server
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/processor"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/processor"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 
 	"context"
diff --git a/internal/service/executors.go b/internal/service/executors.go
index 08f31c48..0b54e52c 100644
--- a/internal/service/executors.go
+++ b/internal/service/executors.go
@@ -4,12 +4,12 @@ import (
 	"context"
 	"crypto/tls"
 	"fmt"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/golang/protobuf/proto"
 	"github.com/jhump/protoreflect/dynamic"
 	"github.com/jhump/protoreflect/dynamic/grpcdynamic"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"github.com/ugorji/go/codec"
 	"google.golang.org/grpc"
 	"io/ioutil"
diff --git a/internal/service/externalFunc.go b/internal/service/externalFunc.go
index 8e224cca..e9ff1988 100644
--- a/internal/service/externalFunc.go
+++ b/internal/service/externalFunc.go
@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type ExternalFunc struct {
diff --git a/internal/service/manager.go b/internal/service/manager.go
index 25d2a645..6c15676c 100644
--- a/internal/service/manager.go
+++ b/internal/service/manager.go
@@ -3,11 +3,11 @@ package service
 import (
 	"archive/zip"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/kv"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io/ioutil"
 	"os"
 	"path"
diff --git a/internal/service/schema.go b/internal/service/schema.go
index 6e2ee4ef..ef74b9d8 100644
--- a/internal/service/schema.go
+++ b/internal/service/schema.go
@@ -3,14 +3,14 @@ package service
 import (
 	"encoding/json"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/golang/protobuf/proto"
 	dpb "github.com/golang/protobuf/protoc-gen-go/descriptor"
 	"github.com/jhump/protoreflect/desc"
 	"github.com/jhump/protoreflect/desc/protoparse"
 	"github.com/jhump/protoreflect/dynamic"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	_ "google.golang.org/genproto/googleapis/api/annotations"
 	"sync"
 )
diff --git a/internal/service/schemaHttp.go b/internal/service/schemaHttp.go
index 19e074a7..e496eee4 100644
--- a/internal/service/schemaHttp.go
+++ b/internal/service/schemaHttp.go
@@ -2,10 +2,10 @@ package service
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/cast"
 	dpb "github.com/golang/protobuf/protoc-gen-go/descriptor"
 	"github.com/jhump/protoreflect/desc"
 	"github.com/jhump/protoreflect/dynamic"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"google.golang.org/protobuf/reflect/protoreflect"
 	"net/http"
 	"regexp"
diff --git a/internal/topo/checkpoint/barrier_handler.go b/internal/topo/checkpoint/barrier_handler.go
index b162bc47..270b687a 100644
--- a/internal/topo/checkpoint/barrier_handler.go
+++ b/internal/topo/checkpoint/barrier_handler.go
@@ -1,7 +1,7 @@
 package checkpoint
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type BarrierHandler interface {
diff --git a/internal/topo/checkpoint/coordinator.go b/internal/topo/checkpoint/coordinator.go
index 6de82ece..c6519068 100644
--- a/internal/topo/checkpoint/coordinator.go
+++ b/internal/topo/checkpoint/coordinator.go
@@ -2,9 +2,9 @@ package checkpoint
 
 import (
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 )
 
diff --git a/internal/topo/checkpoint/defs.go b/internal/topo/checkpoint/defs.go
index 61f2cd93..f3438e3b 100644
--- a/internal/topo/checkpoint/defs.go
+++ b/internal/topo/checkpoint/defs.go
@@ -1,7 +1,7 @@
 package checkpoint
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type StreamTask interface {
diff --git a/internal/topo/collector/func.go b/internal/topo/collector/func.go
index 9f9b091d..b0b793e0 100644
--- a/internal/topo/collector/func.go
+++ b/internal/topo/collector/func.go
@@ -2,7 +2,7 @@ package collector
 
 import (
 	"errors"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 // CollectorFunc is a function used to colllect
diff --git a/internal/topo/context/default.go b/internal/topo/context/default.go
index c27d7b02..806c30bc 100644
--- a/internal/topo/context/default.go
+++ b/internal/topo/context/default.go
@@ -3,9 +3,9 @@ package context
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"github.com/sirupsen/logrus"
 	"sync"
 	"time"
diff --git a/internal/topo/context/func_context.go b/internal/topo/context/func_context.go
index fd6ca45a..962e4b5b 100644
--- a/internal/topo/context/func_context.go
+++ b/internal/topo/context/func_context.go
@@ -2,7 +2,7 @@ package context
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type DefaultFuncContext struct {
diff --git a/internal/topo/node/dynamic_channel_buffer.go b/internal/topo/node/dynamic_channel_buffer.go
index 372ece07..66cfd504 100644
--- a/internal/topo/node/dynamic_channel_buffer.go
+++ b/internal/topo/node/dynamic_channel_buffer.go
@@ -1,7 +1,7 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync/atomic"
 )
 
diff --git a/internal/topo/node/join_align_node.go b/internal/topo/node/join_align_node.go
index 839a7b4c..bc8c76d0 100644
--- a/internal/topo/node/join_align_node.go
+++ b/internal/topo/node/join_align_node.go
@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 // JoinAlignNode will block the stream and buffer all the table tuples. Once buffered, it will combine the later input with the buffer
diff --git a/internal/topo/node/node.go b/internal/topo/node/node.go
index a35b6c9a..2cfc53e5 100644
--- a/internal/topo/node/node.go
+++ b/internal/topo/node/node.go
@@ -2,10 +2,10 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"gopkg.in/yaml.v3"
 	"strings"
 	"sync"
diff --git a/internal/topo/node/operations.go b/internal/topo/node/operations.go
index 1916bd15..81ad558f 100644
--- a/internal/topo/node/operations.go
+++ b/internal/topo/node/operations.go
@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync"
 )
 
diff --git a/internal/topo/node/sink_cache.go b/internal/topo/node/sink_cache.go
index e4dc869f..d9d4d847 100644
--- a/internal/topo/node/sink_cache.go
+++ b/internal/topo/node/sink_cache.go
@@ -3,10 +3,10 @@ package node
 import (
 	"encoding/gob"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io"
 	"path"
 	"sort"
diff --git a/internal/topo/node/sink_node.go b/internal/topo/node/sink_node.go
index f2b11a75..e674d3b6 100644
--- a/internal/topo/node/sink_node.go
+++ b/internal/topo/node/sink_node.go
@@ -4,12 +4,12 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	ct "github.com/emqx/kuiper/internal/template"
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	ct "github.com/lf-edge/ekuiper/internal/template"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 	"text/template"
 	"time"
diff --git a/internal/topo/node/source_node.go b/internal/topo/node/source_node.go
index 17f181b6..a25e1b83 100644
--- a/internal/topo/node/source_node.go
+++ b/internal/topo/node/source_node.go
@@ -1,13 +1,13 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 )
 
diff --git a/internal/topo/node/source_pool.go b/internal/topo/node/source_pool.go
index 2c4a48ae..1d4cf4d5 100644
--- a/internal/topo/node/source_pool.go
+++ b/internal/topo/node/source_pool.go
@@ -3,9 +3,9 @@ package node
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	kctx "github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	kctx "github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync"
 )
 
diff --git a/internal/topo/node/sources_with_edgex.go b/internal/topo/node/sources_with_edgex.go
index bb711224..dc3516f9 100644
--- a/internal/topo/node/sources_with_edgex.go
+++ b/internal/topo/node/sources_with_edgex.go
@@ -4,9 +4,9 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {
diff --git a/internal/topo/node/sources_without_edgex.go b/internal/topo/node/sources_without_edgex.go
index 716ab4aa..1cb3e34c 100644
--- a/internal/topo/node/sources_without_edgex.go
+++ b/internal/topo/node/sources_without_edgex.go
@@ -4,7 +4,7 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {
diff --git a/internal/topo/node/stats_manager.go b/internal/topo/node/stats_manager.go
index 21a54ecf..2e449c52 100644
--- a/internal/topo/node/stats_manager.go
+++ b/internal/topo/node/stats_manager.go
@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/prometheus/client_golang/prometheus"
 	"strconv"
 	"time"
diff --git a/internal/topo/node/watermark.go b/internal/topo/node/watermark.go
index a1f8ee53..c7e4c26e 100644
--- a/internal/topo/node/watermark.go
+++ b/internal/topo/node/watermark.go
@@ -3,9 +3,9 @@ package node
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"math"
 	"sort"
 )
diff --git a/internal/topo/node/window_op.go b/internal/topo/node/window_op.go
index ed87bfd4..b7441af1 100644
--- a/internal/topo/node/window_op.go
+++ b/internal/topo/node/window_op.go
@@ -4,11 +4,11 @@ import (
 	"encoding/gob"
 	"fmt"
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"math"
 	"time"
 )
diff --git a/internal/topo/operator/aggregate_operator.go b/internal/topo/operator/aggregate_operator.go
index 0366c1c9..27d7c084 100644
--- a/internal/topo/operator/aggregate_operator.go
+++ b/internal/topo/operator/aggregate_operator.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type AggregateOp struct {
diff --git a/internal/topo/operator/field_processor.go b/internal/topo/operator/field_processor.go
index 49639ccb..db3ae44f 100644
--- a/internal/topo/operator/field_processor.go
+++ b/internal/topo/operator/field_processor.go
@@ -4,10 +4,10 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"math"
 	"reflect"
 	"strconv"
diff --git a/internal/topo/operator/filter_operator.go b/internal/topo/operator/filter_operator.go
index 904895f5..2da7d8c3 100644
--- a/internal/topo/operator/filter_operator.go
+++ b/internal/topo/operator/filter_operator.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type FilterOp struct {
diff --git a/internal/topo/operator/having_operator.go b/internal/topo/operator/having_operator.go
index 9764dbd9..36f0ef32 100644
--- a/internal/topo/operator/having_operator.go
+++ b/internal/topo/operator/having_operator.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type HavingOp struct {
diff --git a/internal/topo/operator/join_operator.go b/internal/topo/operator/join_operator.go
index 14468b2b..dde396c3 100644
--- a/internal/topo/operator/join_operator.go
+++ b/internal/topo/operator/join_operator.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 //TODO join expr should only be the equal op between 2 streams like tb1.id = tb2.id
diff --git a/internal/topo/operator/order_operator.go b/internal/topo/operator/order_operator.go
index 22523c39..cb28f90d 100644
--- a/internal/topo/operator/order_operator.go
+++ b/internal/topo/operator/order_operator.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type OrderOp struct {
diff --git a/internal/topo/operator/preprocessor.go b/internal/topo/operator/preprocessor.go
index d1aa621e..d6e89c6a 100644
--- a/internal/topo/operator/preprocessor.go
+++ b/internal/topo/operator/preprocessor.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"strings"
 )
 
diff --git a/internal/topo/operator/project_operator.go b/internal/topo/operator/project_operator.go
index fe0e4e6e..288cb331 100644
--- a/internal/topo/operator/project_operator.go
+++ b/internal/topo/operator/project_operator.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"strings"
 )
 
diff --git a/internal/topo/operator/table_processor.go b/internal/topo/operator/table_processor.go
index cebea281..ca27a999 100644
--- a/internal/topo/operator/table_processor.go
+++ b/internal/topo/operator/table_processor.go
@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type TableProcessor struct {
diff --git a/internal/topo/planner/aggregatePlan.go b/internal/topo/planner/aggregatePlan.go
index 2fe239da..47693379 100644
--- a/internal/topo/planner/aggregatePlan.go
+++ b/internal/topo/planner/aggregatePlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type AggregatePlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/analyzer.go b/internal/topo/planner/analyzer.go
index 0abb9a54..c1118aff 100644
--- a/internal/topo/planner/analyzer.go
+++ b/internal/topo/planner/analyzer.go
@@ -2,9 +2,9 @@ package planner
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"strconv"
 	"strings"
 )
diff --git a/internal/topo/planner/dataSourcePlan.go b/internal/topo/planner/dataSourcePlan.go
index 67fb2f95..a1d34097 100644
--- a/internal/topo/planner/dataSourcePlan.go
+++ b/internal/topo/planner/dataSourcePlan.go
@@ -2,9 +2,9 @@ package planner
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"sort"
 	"strings"
 )
diff --git a/internal/topo/planner/filterPlan.go b/internal/topo/planner/filterPlan.go
index 3eb215b1..510eb974 100644
--- a/internal/topo/planner/filterPlan.go
+++ b/internal/topo/planner/filterPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type FilterPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/havingPlan.go b/internal/topo/planner/havingPlan.go
index f2ce66a3..cdc18806 100644
--- a/internal/topo/planner/havingPlan.go
+++ b/internal/topo/planner/havingPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type HavingPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/joinAlignPlan.go b/internal/topo/planner/joinAlignPlan.go
index e4d9c156..31cc6ac9 100644
--- a/internal/topo/planner/joinAlignPlan.go
+++ b/internal/topo/planner/joinAlignPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type JoinAlignPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/joinPlan.go b/internal/topo/planner/joinPlan.go
index 0c27a7dc..ff582bfd 100644
--- a/internal/topo/planner/joinPlan.go
+++ b/internal/topo/planner/joinPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type JoinPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/logicalPlan.go b/internal/topo/planner/logicalPlan.go
index 589ea047..8359336f 100644
--- a/internal/topo/planner/logicalPlan.go
+++ b/internal/topo/planner/logicalPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type LogicalPlan interface {
 	Children() []LogicalPlan
diff --git a/internal/topo/planner/orderPlan.go b/internal/topo/planner/orderPlan.go
index 18136a22..eb06c9aa 100644
--- a/internal/topo/planner/orderPlan.go
+++ b/internal/topo/planner/orderPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type OrderPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/planner.go b/internal/topo/planner/planner.go
index d71b4d7f..577cca07 100644
--- a/internal/topo/planner/planner.go
+++ b/internal/topo/planner/planner.go
@@ -3,14 +3,14 @@ package planner
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/node"
-	"github.com/emqx/kuiper/internal/topo/operator"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/node"
+	"github.com/lf-edge/ekuiper/internal/topo/operator"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"path"
 )
 
diff --git a/internal/topo/planner/projectPlan.go b/internal/topo/planner/projectPlan.go
index f1c1103b..c69dfefd 100644
--- a/internal/topo/planner/projectPlan.go
+++ b/internal/topo/planner/projectPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type ProjectPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/planner/util.go b/internal/topo/planner/util.go
index b4985f59..70e6e497 100644
--- a/internal/topo/planner/util.go
+++ b/internal/topo/planner/util.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 func getRefSources(node ast.Node) ([]ast.StreamName, bool) {
 	result := make(map[ast.StreamName]bool)
diff --git a/internal/topo/planner/windowPlan.go b/internal/topo/planner/windowPlan.go
index 5653faa2..f277f87a 100644
--- a/internal/topo/planner/windowPlan.go
+++ b/internal/topo/planner/windowPlan.go
@@ -1,6 +1,6 @@
 package planner
 
-import "github.com/emqx/kuiper/pkg/ast"
+import "github.com/lf-edge/ekuiper/pkg/ast"
 
 type WindowPlan struct {
 	baseLogicalPlan
diff --git a/internal/topo/sink/edgex_sink.go b/internal/topo/sink/edgex_sink.go
index 2dd1c8be..0ef52001 100644
--- a/internal/topo/sink/edgex_sink.go
+++ b/internal/topo/sink/edgex_sink.go
@@ -10,9 +10,9 @@ import (
 	"github.com/edgexfoundry/go-mod-core-contracts/v2/dtos"
 	"github.com/edgexfoundry/go-mod-messaging/v2/messaging"
 	"github.com/edgexfoundry/go-mod-messaging/v2/pkg/types"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 )
 
diff --git a/internal/topo/sink/log_sink.go b/internal/topo/sink/log_sink.go
index 49a634a4..91ae5f7e 100644
--- a/internal/topo/sink/log_sink.go
+++ b/internal/topo/sink/log_sink.go
@@ -2,8 +2,8 @@ package sink
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/topo/collector"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/collector"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync"
 	"time"
 )
diff --git a/internal/topo/sink/mqtt_sink.go b/internal/topo/sink/mqtt_sink.go
index 73253e85..575a62c2 100644
--- a/internal/topo/sink/mqtt_sink.go
+++ b/internal/topo/sink/mqtt_sink.go
@@ -4,10 +4,10 @@ import (
 	"crypto/tls"
 	"fmt"
 	MQTT "github.com/eclipse/paho.mqtt.golang"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/google/uuid"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"strings"
 )
 
diff --git a/internal/topo/sink/nop_sink.go b/internal/topo/sink/nop_sink.go
index 3b5f9d86..d950a05f 100644
--- a/internal/topo/sink/nop_sink.go
+++ b/internal/topo/sink/nop_sink.go
@@ -1,7 +1,7 @@
 package sink
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type NopSink struct {
diff --git a/internal/topo/sink/rest_sink.go b/internal/topo/sink/rest_sink.go
index 5042a956..7bd0b2ed 100644
--- a/internal/topo/sink/rest_sink.go
+++ b/internal/topo/sink/rest_sink.go
@@ -3,8 +3,8 @@ package sink
 import (
 	"crypto/tls"
 	"fmt"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"io/ioutil"
 	"net/http"
 	"net/url"
diff --git a/internal/topo/source/edgex_source.go b/internal/topo/source/edgex_source.go
index 975e86f6..d8d33a0b 100644
--- a/internal/topo/source/edgex_source.go
+++ b/internal/topo/source/edgex_source.go
@@ -9,10 +9,10 @@ import (
 	"github.com/edgexfoundry/go-mod-core-contracts/v2/dtos"
 	"github.com/edgexfoundry/go-mod-messaging/v2/messaging"
 	"github.com/edgexfoundry/go-mod-messaging/v2/pkg/types"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"strconv"
 	"strings"
 )
diff --git a/internal/topo/source/file_source.go b/internal/topo/source/file_source.go
index aca290ba..1ca5c412 100644
--- a/internal/topo/source/file_source.go
+++ b/internal/topo/source/file_source.go
@@ -3,10 +3,10 @@ package source
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"os"
 	"path"
 	"path/filepath"
diff --git a/internal/topo/source/httppull_source.go b/internal/topo/source/httppull_source.go
index 7e355e69..ab5b9b72 100644
--- a/internal/topo/source/httppull_source.go
+++ b/internal/topo/source/httppull_source.go
@@ -4,11 +4,11 @@ import (
 	"crypto/md5"
 	"encoding/hex"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"io/ioutil"
 	"net/http"
 	"net/url"
diff --git a/internal/topo/source/mqtt_source.go b/internal/topo/source/mqtt_source.go
index b969104f..59d4f8d1 100644
--- a/internal/topo/source/mqtt_source.go
+++ b/internal/topo/source/mqtt_source.go
@@ -5,11 +5,11 @@ import (
 	"encoding/json"
 	"fmt"
 	MQTT "github.com/eclipse/paho.mqtt.golang"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
 	"github.com/google/uuid"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"path"
 	"strconv"
 	"strings"
diff --git a/internal/topo/state/kv_store.go b/internal/topo/state/kv_store.go
index d5ea72d8..3e875393 100644
--- a/internal/topo/state/kv_store.go
+++ b/internal/topo/state/kv_store.go
@@ -3,10 +3,10 @@ package state
 import (
 	"encoding/gob"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"path"
 	"sync"
 )
diff --git a/internal/topo/state/store.go b/internal/topo/state/store.go
index 1aab68bd..18a02afe 100644
--- a/internal/topo/state/store.go
+++ b/internal/topo/state/store.go
@@ -1,7 +1,7 @@
 package state
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 const CheckpointListKey = "checkpoints"
diff --git a/internal/topo/topo.go b/internal/topo/topo.go
index 99a9e4fc..7dcfd1b5 100644
--- a/internal/topo/topo.go
+++ b/internal/topo/topo.go
@@ -3,12 +3,12 @@ package topo
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	kctx "github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/topo/node"
-	"github.com/emqx/kuiper/internal/topo/state"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	kctx "github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/topo/node"
+	"github.com/lf-edge/ekuiper/internal/topo/state"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"strconv"
 )
 
diff --git a/internal/xsql/collections.go b/internal/xsql/collections.go
index 537da773..a4c45c58 100644
--- a/internal/xsql/collections.go
+++ b/internal/xsql/collections.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"sort"
 	"strings"
 )
diff --git a/internal/xsql/funcValuer.go b/internal/xsql/funcValuer.go
index 18e1b4f4..e404ea29 100644
--- a/internal/xsql/funcValuer.go
+++ b/internal/xsql/funcValuer.go
@@ -1,9 +1,9 @@
 package xsql
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"strings"
 )
 
diff --git a/internal/xsql/funcsAggregate.go b/internal/xsql/funcsAggregate.go
index a22af033..b5f036a3 100644
--- a/internal/xsql/funcsAggregate.go
+++ b/internal/xsql/funcsAggregate.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"strings"
 )
 
diff --git a/internal/xsql/funcsAstValidator.go b/internal/xsql/funcsAstValidator.go
index 974c8a80..c29df381 100644
--- a/internal/xsql/funcsAstValidator.go
+++ b/internal/xsql/funcsAstValidator.go
@@ -2,7 +2,7 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"strings"
 )
 
diff --git a/internal/xsql/funcsMisc.go b/internal/xsql/funcsMisc.go
index 0173447d..4f721014 100644
--- a/internal/xsql/funcsMisc.go
+++ b/internal/xsql/funcsMisc.go
@@ -11,9 +11,9 @@ import (
 	"fmt"
 	"github.com/PaesslerAG/gval"
 	"github.com/PaesslerAG/jsonpath"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/google/uuid"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"hash"
 	"io"
 	"math"
diff --git a/internal/xsql/funcsStr.go b/internal/xsql/funcsStr.go
index c0486932..619f8d1a 100644
--- a/internal/xsql/funcsStr.go
+++ b/internal/xsql/funcsStr.go
@@ -3,7 +3,7 @@ package xsql
 import (
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"regexp"
 	"strings"
 	"unicode"
diff --git a/internal/xsql/functionRuntime.go b/internal/xsql/functionRuntime.go
index f0ffc6a1..9914400d 100644
--- a/internal/xsql/functionRuntime.go
+++ b/internal/xsql/functionRuntime.go
@@ -1,9 +1,9 @@
 package xsql
 
 import (
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"sync"
 )
 
diff --git a/internal/xsql/lexical.go b/internal/xsql/lexical.go
index 76b5f64b..1044d112 100644
--- a/internal/xsql/lexical.go
+++ b/internal/xsql/lexical.go
@@ -3,7 +3,7 @@ package xsql
 import (
 	"bufio"
 	"bytes"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"io"
 	"strconv"
 	"strings"
diff --git a/internal/xsql/manager.go b/internal/xsql/manager.go
index 49d3e7a0..0c47d2b2 100644
--- a/internal/xsql/manager.go
+++ b/internal/xsql/manager.go
@@ -2,7 +2,7 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 var (
diff --git a/internal/xsql/parser.go b/internal/xsql/parser.go
index 239a7e81..941be86d 100644
--- a/internal/xsql/parser.go
+++ b/internal/xsql/parser.go
@@ -2,9 +2,9 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/message"
 	"github.com/golang-collections/collections/stack"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"io"
 	"math"
 	"reflect"
diff --git a/internal/xsql/sqlValidator.go b/internal/xsql/sqlValidator.go
index 171f4d90..1879061b 100644
--- a/internal/xsql/sqlValidator.go
+++ b/internal/xsql/sqlValidator.go
@@ -2,7 +2,7 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 // Validate validate select statement without context.
diff --git a/internal/xsql/stmtx.go b/internal/xsql/stmtx.go
index 37c62177..6339f6de 100644
--- a/internal/xsql/stmtx.go
+++ b/internal/xsql/stmtx.go
@@ -3,9 +3,9 @@ package xsql
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"strings"
 )
 
diff --git a/internal/xsql/valuer.go b/internal/xsql/valuer.go
index 86ad542e..359a531f 100644
--- a/internal/xsql/valuer.go
+++ b/internal/xsql/valuer.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"math"
 	"reflect"
 	"sort"
diff --git a/pkg/ast/functions.go b/pkg/ast/functions.go
index 653be213..5b3f86f8 100644
--- a/pkg/ast/functions.go
+++ b/pkg/ast/functions.go
@@ -1,7 +1,7 @@
 package ast
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"strings"
 	"sync"
 )
diff --git a/pkg/kv/sqliteKV.go b/pkg/kv/sqliteKV.go
index 0f9e9dd0..18b4f880 100644
--- a/pkg/kv/sqliteKV.go
+++ b/pkg/kv/sqliteKV.go
@@ -5,7 +5,7 @@ import (
 	"database/sql"
 	"encoding/gob"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	_ "github.com/mattn/go-sqlite3"
 	"os"
 	"path"
diff --git a/tools/kubernetes/go.mod b/tools/kubernetes/go.mod
index 127df302..90709b6d 100644
--- a/tools/kubernetes/go.mod
+++ b/tools/kubernetes/go.mod
@@ -1,4 +1,4 @@
-module github.com/emqx/kuiper/tools/kubernetes
+module github.com/lf-edge/ekuiper/tools/kubernetes
 
 require (
 	github.com/sirupsen/logrus v1.4.2
diff --git a/tools/kubernetes/main.go b/tools/kubernetes/main.go
index f62ac713..1e70f9e7 100644
--- a/tools/kubernetes/main.go
+++ b/tools/kubernetes/main.go
@@ -1,7 +1,7 @@
 package main
 
 import (
-	"github.com/emqx/kuiper/tools/kubernetes/util"
+	"github.com/lf-edge/ekuiper/tools/kubernetes/util"
 	"os"
 	"os/signal"
 	"syscall"
diff --git a/tools/kubernetes/util/util.go b/tools/kubernetes/util/util.go
index f61a94aa..a5733f12 100644
--- a/tools/kubernetes/util/util.go
+++ b/tools/kubernetes/util/util.go
@@ -3,7 +3,7 @@ package util
 import (
 	"encoding/json"
 	"fmt"
-	kconf "github.com/emqx/kuiper/tools/kubernetes/conf"
+	kconf "github.com/lf-edge/ekuiper/tools/kubernetes/conf"
 	"io/ioutil"
 	"os"
 	"path"
diff --git a/tools/migration/go.mod b/tools/migration/go.mod
index 6d28d52d..c5354861 100644
--- a/tools/migration/go.mod
+++ b/tools/migration/go.mod
@@ -1,10 +1,10 @@
-module github.com/emqx/kuiper/tools/migration
+module github.com/lf-edge/ekuiper/tools/migration
 
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0
+	github.com/lf-edge/ekuiper v0.0.0
 	github.com/patrickmn/go-cache v2.1.0+incompatible
 )
 
-replace github.com/emqx/kuiper => ../../
+replace github.com/lf-edge/ekuiper => ../../
diff --git a/tools/migration/main.go b/tools/migration/main.go
index 4bff9b42..c1d722b3 100644
--- a/tools/migration/main.go
+++ b/tools/migration/main.go
@@ -1,7 +1,7 @@
 package main
 
 import (
-	"github.com/emqx/kuiper/tools/migration/util"
+	"github.com/lf-edge/ekuiper/tools/migration/util"
 	"log"
 	"os"
 )
diff --git a/tools/migration/util/migration.go b/tools/migration/util/migration.go
index 02995b8d..685d44b2 100644
--- a/tools/migration/util/migration.go
+++ b/tools/migration/util/migration.go
@@ -2,7 +2,7 @@ package util
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/common/kv"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"github.com/patrickmn/go-cache"
 	"io/ioutil"
 	"os"


Test patch:
diff --git a/internal/plugin/manager_test.go b/internal/plugin/manager_test.go
index c2ef596c..dd4505b2 100644
--- a/internal/plugin/manager_test.go
+++ b/internal/plugin/manager_test.go
@@ -3,7 +3,7 @@ package plugin
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"net/http"
 	"net/http/httptest"
 	"os"
diff --git a/internal/processor/rule_test.go b/internal/processor/rule_test.go
index 44645c96..59077a4f 100644
--- a/internal/processor/rule_test.go
+++ b/internal/processor/rule_test.go
@@ -1,7 +1,7 @@
 package processor
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"reflect"
 	"testing"
 )
diff --git a/internal/processor/stream_test.go b/internal/processor/stream_test.go
index 0a224989..ef360c14 100644
--- a/internal/processor/stream_test.go
+++ b/internal/processor/stream_test.go
@@ -2,7 +2,7 @@ package processor
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"path"
 	"reflect"
 	"testing"
diff --git a/internal/service/external_service_rule_test.go b/internal/service/external_service_rule_test.go
index eeef0e2c..55a33914 100644
--- a/internal/service/external_service_rule_test.go
+++ b/internal/service/external_service_rule_test.go
@@ -4,13 +4,13 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	pb "github.com/emqx/kuiper/internal/service/test/schemas/helloworld"
-	"github.com/emqx/kuiper/internal/topo/topotest"
-	"github.com/emqx/kuiper/pkg/api"
 	"github.com/golang/protobuf/ptypes/empty"
 	"github.com/golang/protobuf/ptypes/wrappers"
 	"github.com/gorilla/mux"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	pb "github.com/lf-edge/ekuiper/internal/service/test/schemas/helloworld"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/msgpack-rpc/msgpack-rpc-go/rpc"
 	"google.golang.org/grpc"
 	"io"
diff --git a/internal/service/manager_test.go b/internal/service/manager_test.go
index 78476a44..8990cf57 100644
--- a/internal/service/manager_test.go
+++ b/internal/service/manager_test.go
@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"testing"
 )
diff --git a/internal/service/schemaHttp_test.go b/internal/service/schemaHttp_test.go
index 3e78e286..abb6d8ee 100644
--- a/internal/service/schemaHttp_test.go
+++ b/internal/service/schemaHttp_test.go
@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"net/http"
 	"reflect"
 	"testing"
diff --git a/internal/service/schema_test.go b/internal/service/schema_test.go
index 86210dfb..3c4e550a 100644
--- a/internal/service/schema_test.go
+++ b/internal/service/schema_test.go
@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"reflect"
 	"testing"
 )
diff --git a/internal/template/funcs_test.go b/internal/template/funcs_test.go
index baec5a57..d4fa8557 100644
--- a/internal/template/funcs_test.go
+++ b/internal/template/funcs_test.go
@@ -3,7 +3,7 @@ package template
 import (
 	"encoding/base64"
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"reflect"
 	"testing"
 )
diff --git a/internal/testx/testUtil.go b/internal/testx/testUtil.go
index 77b584e4..3dbecd9c 100644
--- a/internal/testx/testUtil.go
+++ b/internal/testx/testUtil.go
@@ -1,7 +1,7 @@
 package testx
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/conf"
 )
 
 // errstring returns the string representation of an error.
diff --git a/internal/topo/context/default_test.go b/internal/topo/context/default_test.go
index baa91994..12942c88 100644
--- a/internal/topo/context/default_test.go
+++ b/internal/topo/context/default_test.go
@@ -1,9 +1,9 @@
 package context
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/state"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/state"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"log"
 	"os"
 	"path"
diff --git a/internal/topo/node/sink_node_test.go b/internal/topo/node/sink_node_test.go
index 9e9ff4cb..b8b45425 100644
--- a/internal/topo/node/sink_node_test.go
+++ b/internal/topo/node/sink_node_test.go
@@ -2,9 +2,9 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
 	"reflect"
 	"testing"
 	"time"
diff --git a/internal/topo/node/source_node_test.go b/internal/topo/node/source_node_test.go
index 7181baeb..b529e2ec 100644
--- a/internal/topo/node/source_node_test.go
+++ b/internal/topo/node/source_node_test.go
@@ -1,10 +1,10 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"testing"
 )
diff --git a/internal/topo/node/source_pool_test.go b/internal/topo/node/source_pool_test.go
index b525838b..e3d52ba4 100644
--- a/internal/topo/node/source_pool_test.go
+++ b/internal/topo/node/source_pool_test.go
@@ -1,11 +1,11 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/topo/state"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/topo/state"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"testing"
 )
 
diff --git a/internal/topo/node/sources_for_test_with_edgex.go b/internal/topo/node/sources_for_test_with_edgex.go
index 08f25dc6..8f40e6e1 100644
--- a/internal/topo/node/sources_for_test_with_edgex.go
+++ b/internal/topo/node/sources_for_test_with_edgex.go
@@ -4,10 +4,10 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {
diff --git a/internal/topo/node/sources_for_test_without_edgex.go b/internal/topo/node/sources_for_test_without_edgex.go
index 213aaae1..7f4d1d51 100644
--- a/internal/topo/node/sources_for_test_without_edgex.go
+++ b/internal/topo/node/sources_for_test_without_edgex.go
@@ -4,8 +4,8 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {
diff --git a/internal/topo/node/window_op_test.go b/internal/topo/node/window_op_test.go
index 1deaf50d..4b132379 100644
--- a/internal/topo/node/window_op_test.go
+++ b/internal/topo/node/window_op_test.go
@@ -2,7 +2,7 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"testing"
 )
diff --git a/internal/topo/operator/aggregate_test.go b/internal/topo/operator/aggregate_test.go
index 3b43c783..82949bd1 100644
--- a/internal/topo/operator/aggregate_test.go
+++ b/internal/topo/operator/aggregate_test.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/filter_test.go b/internal/topo/operator/filter_test.go
index eb86dabc..a6f3815f 100644
--- a/internal/topo/operator/filter_test.go
+++ b/internal/topo/operator/filter_test.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/having_test.go b/internal/topo/operator/having_test.go
index ade6c07d..b988c893 100644
--- a/internal/topo/operator/having_test.go
+++ b/internal/topo/operator/having_test.go
@@ -3,9 +3,9 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/join_multi_test.go b/internal/topo/operator/join_multi_test.go
index d99754f2..e16d285f 100644
--- a/internal/topo/operator/join_multi_test.go
+++ b/internal/topo/operator/join_multi_test.go
@@ -2,10 +2,10 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/join_test.go b/internal/topo/operator/join_test.go
index e07ce725..4f55326f 100644
--- a/internal/topo/operator/join_test.go
+++ b/internal/topo/operator/join_test.go
@@ -4,11 +4,11 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/math_func_test.go b/internal/topo/operator/math_func_test.go
index 048d42e9..e0335798 100644
--- a/internal/topo/operator/math_func_test.go
+++ b/internal/topo/operator/math_func_test.go
@@ -3,9 +3,9 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/misc_func_test.go b/internal/topo/operator/misc_func_test.go
index 5d4ac141..66f59fac 100644
--- a/internal/topo/operator/misc_func_test.go
+++ b/internal/topo/operator/misc_func_test.go
@@ -3,9 +3,9 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/order_test.go b/internal/topo/operator/order_test.go
index 6a99a48a..d944e2c7 100644
--- a/internal/topo/operator/order_test.go
+++ b/internal/topo/operator/order_test.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/preprocessor_test.go b/internal/topo/operator/preprocessor_test.go
index d4e7792e..0696a084 100644
--- a/internal/topo/operator/preprocessor_test.go
+++ b/internal/topo/operator/preprocessor_test.go
@@ -5,12 +5,12 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"io/ioutil"
 	"log"
 	"path"
diff --git a/internal/topo/operator/project_test.go b/internal/topo/operator/project_test.go
index f6d9a0f1..7111fa74 100644
--- a/internal/topo/operator/project_test.go
+++ b/internal/topo/operator/project_test.go
@@ -4,11 +4,11 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/str_func_test.go b/internal/topo/operator/str_func_test.go
index 0833cab4..f0194d4f 100644
--- a/internal/topo/operator/str_func_test.go
+++ b/internal/topo/operator/str_func_test.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/topo/operator/table_processor_test.go b/internal/topo/operator/table_processor_test.go
index 02cb5e43..9e997c52 100644
--- a/internal/topo/operator/table_processor_test.go
+++ b/internal/topo/operator/table_processor_test.go
@@ -3,10 +3,10 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"testing"
 )
diff --git a/internal/topo/planner/analyzer_test.go b/internal/topo/planner/analyzer_test.go
index 49ebe362..a61939de 100644
--- a/internal/topo/planner/analyzer_test.go
+++ b/internal/topo/planner/analyzer_test.go
@@ -3,11 +3,11 @@ package planner
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"path"
 	"reflect"
 	"strings"
diff --git a/internal/topo/planner/planner_test.go b/internal/topo/planner/planner_test.go
index d56c2838..41b621f7 100644
--- a/internal/topo/planner/planner_test.go
+++ b/internal/topo/planner/planner_test.go
@@ -3,12 +3,12 @@ package planner
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/kv"
 	"github.com/gdexlab/go-render/render"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"path"
 	"reflect"
 	"strings"
diff --git a/internal/topo/sink/edgex_sink_test.go b/internal/topo/sink/edgex_sink_test.go
index 5693cc5f..e6d5f56e 100644
--- a/internal/topo/sink/edgex_sink_test.go
+++ b/internal/topo/sink/edgex_sink_test.go
@@ -6,9 +6,9 @@ import (
 	"fmt"
 	v2 "github.com/edgexfoundry/go-mod-core-contracts/v2/common"
 	"github.com/edgexfoundry/go-mod-core-contracts/v2/dtos"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
 	"reflect"
 	"testing"
 )
diff --git a/internal/topo/sink/rest_sink_test.go b/internal/topo/sink/rest_sink_test.go
index f872ef88..68b20051 100644
--- a/internal/topo/sink/rest_sink_test.go
+++ b/internal/topo/sink/rest_sink_test.go
@@ -3,8 +3,8 @@ package sink
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
 	"io/ioutil"
 	"net/http"
 	"net/http/httptest"
diff --git a/internal/topo/source/edgex_source_test.go b/internal/topo/source/edgex_source_test.go
index f2263b89..d8168b29 100644
--- a/internal/topo/source/edgex_source_test.go
+++ b/internal/topo/source/edgex_source_test.go
@@ -9,7 +9,7 @@ import (
 	"github.com/edgexfoundry/go-mod-core-contracts/v2/dtos"
 	"github.com/edgexfoundry/go-mod-core-contracts/v2/models"
 	"github.com/edgexfoundry/go-mod-messaging/v2/pkg/types"
-	"github.com/emqx/kuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/conf"
 	"math"
 	"reflect"
 	"testing"
diff --git a/internal/topo/state/kv_store_test.go b/internal/topo/state/kv_store_test.go
index 72352d67..d4b3f46c 100644
--- a/internal/topo/state/kv_store_test.go
+++ b/internal/topo/state/kv_store_test.go
@@ -2,8 +2,8 @@ package state
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"log"
 	"os"
 	"path"
diff --git a/internal/topo/topotest/checkpoint_test.go b/internal/topo/topotest/checkpoint_test.go
index bf1f218c..875b8b30 100644
--- a/internal/topo/topotest/checkpoint_test.go
+++ b/internal/topo/topotest/checkpoint_test.go
@@ -1,8 +1,8 @@
 package topotest
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"testing"
 )
 
diff --git a/internal/topo/topotest/mock_topo.go b/internal/topo/topotest/mock_topo.go
index 9d9cc497..7806697e 100644
--- a/internal/topo/topotest/mock_topo.go
+++ b/internal/topo/topotest/mock_topo.go
@@ -3,18 +3,18 @@ package topotest
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/processor"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/node"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/internal/topo/topotest/mockclock"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/processor"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/node"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mockclock"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"path"
 	"reflect"
 	"strings"
diff --git a/internal/topo/topotest/mockclock/clock.go b/internal/topo/topotest/mockclock/clock.go
index 3187422b..70d4bda5 100644
--- a/internal/topo/topotest/mockclock/clock.go
+++ b/internal/topo/topotest/mockclock/clock.go
@@ -2,8 +2,8 @@ package mockclock
 
 import (
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 )
 
 func ResetClock(t int64) {
diff --git a/internal/topo/topotest/mocknode/mock_data.go b/internal/topo/topotest/mocknode/mock_data.go
index b5e6d48b..39b5bd9b 100644
--- a/internal/topo/topotest/mocknode/mock_data.go
+++ b/internal/topo/topotest/mocknode/mock_data.go
@@ -2,8 +2,8 @@ package mocknode
 
 import (
 	"encoding/base64"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"io/ioutil"
 	"path"
 )
diff --git a/internal/topo/topotest/mocknode/mock_sink.go b/internal/topo/topotest/mocknode/mock_sink.go
index 568cdbd0..a46f99e0 100644
--- a/internal/topo/topotest/mocknode/mock_sink.go
+++ b/internal/topo/topotest/mocknode/mock_sink.go
@@ -1,7 +1,7 @@
 package mocknode
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type MockSink struct {
diff --git a/internal/topo/topotest/mocknode/mock_source.go b/internal/topo/topotest/mocknode/mock_source.go
index 2de9d61e..ebe999de 100644
--- a/internal/topo/topotest/mocknode/mock_source.go
+++ b/internal/topo/topotest/mocknode/mock_source.go
@@ -2,11 +2,11 @@ package mocknode
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/topotest/mockclock"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mockclock"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 	"time"
 )
diff --git a/internal/topo/topotest/plugin_rule_test.go b/internal/topo/topotest/plugin_rule_test.go
index ffe0f94d..29000357 100644
--- a/internal/topo/topotest/plugin_rule_test.go
+++ b/internal/topo/topotest/plugin_rule_test.go
@@ -6,12 +6,12 @@ import (
 	"bufio"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/internal/topo/topotest/mockclock"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mockclock"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"os"
 	"testing"
 	"time"
diff --git a/internal/topo/topotest/rule_test.go b/internal/topo/topotest/rule_test.go
index f36dab5e..82f7aa0d 100644
--- a/internal/topo/topotest/rule_test.go
+++ b/internal/topo/topotest/rule_test.go
@@ -2,9 +2,9 @@ package topotest
 
 import (
 	"encoding/json"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"testing"
 )
 
diff --git a/internal/topo/topotest/window_rule_test.go b/internal/topo/topotest/window_rule_test.go
index d268ec57..49021759 100644
--- a/internal/topo/topotest/window_rule_test.go
+++ b/internal/topo/topotest/window_rule_test.go
@@ -1,8 +1,8 @@
 package topotest
 
 import (
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"testing"
 )
 
diff --git a/internal/xsql/ast_test.go b/internal/xsql/ast_test.go
index 38785eca..c79bbe6b 100644
--- a/internal/xsql/ast_test.go
+++ b/internal/xsql/ast_test.go
@@ -3,7 +3,7 @@ package xsql
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"testing"
 )
diff --git a/internal/xsql/funcsAstValidator_test.go b/internal/xsql/funcsAstValidator_test.go
index b6b26f5d..1b2661cb 100644
--- a/internal/xsql/funcsAstValidator_test.go
+++ b/internal/xsql/funcsAstValidator_test.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/xsql/parser_agg_test.go b/internal/xsql/parser_agg_test.go
index 704dd737..adf70acf 100644
--- a/internal/xsql/parser_agg_test.go
+++ b/internal/xsql/parser_agg_test.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/xsql/parser_stream_test.go b/internal/xsql/parser_stream_test.go
index 4e7a52a4..febaf51c 100644
--- a/internal/xsql/parser_stream_test.go
+++ b/internal/xsql/parser_stream_test.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/xsql/parser_test.go b/internal/xsql/parser_test.go
index 306536f2..a49245dc 100644
--- a/internal/xsql/parser_test.go
+++ b/internal/xsql/parser_test.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"math"
 	"reflect"
 	"strings"
diff --git a/internal/xsql/parser_tree_test.go b/internal/xsql/parser_tree_test.go
index b5d84b66..731bd29e 100644
--- a/internal/xsql/parser_tree_test.go
+++ b/internal/xsql/parser_tree_test.go
@@ -2,8 +2,8 @@ package xsql
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/internal/xsql/valuer_test.go b/internal/xsql/valuer_test.go
index 273ba8cb..a0513caf 100644
--- a/internal/xsql/valuer_test.go
+++ b/internal/xsql/valuer_test.go
@@ -3,9 +3,9 @@ package xsql
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"
diff --git a/test/edgex/sub/sub.go b/test/edgex/sub/sub.go
index c96803ec..0d673874 100644
--- a/test/edgex/sub/sub.go
+++ b/test/edgex/sub/sub.go
@@ -6,7 +6,7 @@ import (
 	"fmt"
 	"github.com/edgexfoundry/go-mod-messaging/v2/messaging"
 	"github.com/edgexfoundry/go-mod-messaging/v2/pkg/types"
-	"github.com/emqx/kuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/conf"
 	"os"
 )
 
diff --git a/tools/migration/util/migration_test.go b/tools/migration/util/migration_test.go
index eccd5a75..28c2e8c4 100644
--- a/tools/migration/util/migration_test.go
+++ b/tools/migration/util/migration_test.go
@@ -1,7 +1,7 @@
 package util
 
 import (
-	"github.com/emqx/kuiper/common/kv"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"github.com/patrickmn/go-cache"
 	"os"
 	"path"