From 983376fe3e68f3c397dde53d73dfa5940be7e4d1 Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Fri, 6 Nov 2026 15:00:03 +0800
Subject: [PATCH] Use column header constants in pipe authentication assertions
 (#19131)

* Use column header constants in pipe user assertions

* Use canonical column names in pipe privilege assertions

(cherry picked from commit 0ed7549b9b9c9512f0f5a8b1ba7bfd042456fa31)
---
 .../iotdb/pipe/it/manual/IoTDBPipePermissionIT.java       | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipePermissionIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipePermissionIT.java
index 55c8877cb028e..25235fdb91fd3 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipePermissionIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipePermissionIT.java
@@ -24,6 +24,7 @@
 import org.apache.iotdb.confignode.rpc.thrift.TCreatePipeReq;
 import org.apache.iotdb.consensus.ConsensusFactory;
 import org.apache.iotdb.db.it.utils.TestUtils;
+import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
 import org.apache.iotdb.it.env.MultiEnvFactory;
 import org.apache.iotdb.it.env.cluster.node.DataNodeWrapper;
 import org.apache.iotdb.it.framework.IoTDBTestRunner;
@@ -148,7 +149,7 @@ private void testWithConnector(final String connector) throws Exception {
       TestUtils.assertDataEventuallyOnEnv(
           receiverEnv,
           "list user",
-          "User,",
+          ColumnHeaderConstant.USER + ",",
           new HashSet<>(Arrays.asList("root,", "user,", "thulab,")));
       final Set<String> expectedResSet = new HashSet<>();
       expectedResSet.add(
@@ -228,7 +229,10 @@ public void testNoPermission() throws Exception {
           "Timeseries,Alias,Database,DataType,Encoding,Compression,Tags,Attributes,Deadband,DeadbandParameters,ViewType,",
           Collections.emptySet());
       TestUtils.assertDataAlwaysOnEnv(
-          receiverEnv, "list user", "User,", Collections.singleton("root,"));
+          receiverEnv,
+          "list user",
+          ColumnHeaderConstant.USER + ",",
+          Collections.singleton("root,"));
     }
   }
 }