diff --git a/pkg/ccr/meta.go b/pkg/ccr/meta.go
index 6abbf771..1109fe67 100644
--- a/pkg/ccr/meta.go
+++ b/pkg/ccr/meta.go
@@ -541,6 +541,14 @@ func (m *Meta) UpdateBackends() error {
 		return xerror.Wrap(err, xerror.Normal, query)
 	}
 
+	// Compatibility fix: Replace with remote IP address
+	for i := range backends {
+		backend := backends[i]
+		if backend.Host == "127.0.0.1" {
+			backend.Host = m.Host
+		}
+	}
+
 	for _, backend := range backends {
 		m.Backends[backend.Id] = backend
 
diff --git a/pkg/ccr/thrift_meta.go b/pkg/ccr/thrift_meta.go
index 7478e3b1..39b6cda0 100644
--- a/pkg/ccr/thrift_meta.go
+++ b/pkg/ccr/thrift_meta.go
@@ -61,9 +61,14 @@ func NewThriftMeta(spec *base.Spec, rpcFactory rpc.IRpcFactory, tableIds []int64
 	}
 
 	for _, backend := range backendMetaResp.GetBackends() {
+		// Compatibility fix: Replace with remote IP address
+		host := backend.GetHost()
+		if host == "127.0.0.1" {
+			host = spec.Host
+		}
 		backendMeta := &base.Backend{
 			Id:       backend.GetId(),
-			Host:     backend.GetHost(),
+			Host:     host,
 			BePort:   uint16(backend.GetBePort()),
 			HttpPort: uint16(backend.GetHttpPort()),
 			BrpcPort: uint16(backend.GetBrpcPort()),