diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipeDataNodePluginAgentTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipeDataNodePluginAgentTest.java
index ae4d595ee0c1..1fbb615ef7a6 100644
--- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipeDataNodePluginAgentTest.java
+++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/PipeDataNodePluginAgentTest.java
@@ -151,17 +151,17 @@ public void testPipePluginAgent() {
                     }))
             .getClass());
     Assert.assertEquals(
-        IoTDBDataRegionSyncSink.class,
+        IoTDBDataRegionAsyncSink.class,
         agent.dataRegion().reflectSink(new PipeParameters(new HashMap<>())).getClass());
     Assert.assertEquals(
-        IoTDBDataRegionAsyncSink.class,
+        IoTDBDataRegionSyncSink.class,
         agent
             .dataRegion()
             .reflectSink(
                 new PipeParameters(
                     new HashMap<String, String>() {
                       {
-                        put(PipeSinkConstant.CONNECTOR_SERIALIZE_BY_REGION_KEY, "false");
+                        put(PipeSinkConstant.CONNECTOR_SERIALIZE_BY_REGION_KEY, "true");
                       }
                     }))
             .getClass());
diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
index 9545d71d9656..dad190442513 100644
--- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
+++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
@@ -33,20 +33,20 @@
 public class PipeSinkSubtaskManagerTest {
 
   @Test
-  public void testGenerateAttributeSortedStringAddsRegionPrefixAndIgnoresRestartFlag() {
+  public void testGenerateAttributeSortedStringUsesSerializeByRegionAndIgnoresRestartFlag() {
     final Map<String, String> attributes = new HashMap<>();
     attributes.put("z", "1");
     attributes.put("a", "2");
     attributes.put(SystemConstant.RESTART_OR_NEWLY_ADDED_KEY, Boolean.TRUE.toString());
 
     Assert.assertEquals(
-        "data_region_-1_{a=2, z=1}",
+        "data_{a=2, z=1}",
         PipeSinkSubtaskManager.generateAttributeSortedString(
             new PipeParameters(new HashMap<>(attributes)), -1));
 
-    attributes.put(PipeSinkConstant.CONNECTOR_SERIALIZE_BY_REGION_KEY, Boolean.FALSE.toString());
+    attributes.put(PipeSinkConstant.CONNECTOR_SERIALIZE_BY_REGION_KEY, Boolean.TRUE.toString());
     Assert.assertEquals(
-        "data_{a=2, connector.serialize-by-region=false, z=1}",
+        "data_region_-1_{a=2, connector.serialize-by-region=true, z=1}",
         PipeSinkSubtaskManager.generateAttributeSortedString(
             new PipeParameters(new HashMap<>(attributes)), -1));
   }
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeSinkConstant.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeSinkConstant.java
index 39be064f09a4..3f88ecb431bf 100644
--- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeSinkConstant.java
+++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeSinkConstant.java
@@ -72,7 +72,7 @@ public class PipeSinkConstant {
 
   public static final String CONNECTOR_SERIALIZE_BY_REGION_KEY = "connector.serialize-by-region";
   public static final String SINK_SERIALIZE_BY_REGION_KEY = "sink.serialize-by-region";
-  public static final boolean CONNECTOR_SERIALIZE_BY_REGION_DEFAULT_VALUE = true;
+  public static final boolean CONNECTOR_SERIALIZE_BY_REGION_DEFAULT_VALUE = false;
 
   public static boolean isSerializeByRegionEnabled(final PipeParameters parameters) {
     return parameters.getBooleanOrDefault(