fix test

Author: loserwang1024

fluss-client/src/test/java/com/alibaba/fluss/client/security/acl/FlussAuthorizationITCase.java

@@ -445,6 +445,8 @@ void testProduceAndConsumer() throws Exception {
                                                 PermissionType.ALLOW))))
                 .all()
                 .get();
+        FLUSS_CLUSTER_EXTENSION.waitUtilTableReady(
+                rootAdmin.getTableInfo(DATA1_TABLE_PATH).get().getTableId());
         try (Table table = guestConn.getTable(DATA1_TABLE_PATH)) {
             AppendWriter appendWriter = table.newAppend().createWriter();
             appendWriter.append(row(1, "a")).get();

fluss-rpc/src/test/java/com/alibaba/fluss/rpc/netty/authenticate/AuthenticationTest.java

@@ -208,8 +208,7 @@ private void buildNettyServer() throws Exception {
         configuration.setString(
                 ConfigOptions.SERVER_SECURITY_PROTOCOL_MAP.key(),
                 "CLIENT1:mutual,CLIENT2:username_password");
-        configuration.setString("security.username_password.username", "root");
-        configuration.setString("security.username_password.password", "password");
+        configuration.setString("security.username_password.credentials", "root:password");
         // 3 worker threads is enough for this test
         configuration.setString(ConfigOptions.NETTY_SERVER_NUM_WORKER_THREADS.key(), "3");
         MetricGroup metricGroup = NOPMetricsGroup.newInstance();

fluss-rpc/src/test/java/com/alibaba/fluss/rpc/protocol/MessageCodecTest.java

@@ -41,6 +41,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
+import java.net.InetSocketAddress;
 import java.util.Collections;
 
 import static com.alibaba.fluss.testutils.ByteBufChannel.toByteBuf;
@@ -195,6 +196,7 @@ private static ChannelHandlerContext mockChannelHandlerContext() {
         when(channelId.asLongText()).thenReturn("long_text");
         Channel channel = mock(Channel.class);
         when(channel.id()).thenReturn(channelId);
+        when(channel.remoteAddress()).thenReturn(new InetSocketAddress("localhost", 8080));
         ChannelHandlerContext ctx = mock(ChannelHandlerContext.class);
         when(ctx.channel()).thenReturn(channel);
         EventExecutor eventExecutor = mock(EventExecutor.class);

fluss-server/src/test/java/com/alibaba/fluss/server/zk/data/ResourceAclJsonSerdeTest.java

@@ -24,7 +24,7 @@
 
 import java.util.Arrays;
 import java.util.Collections;
-import java.util.HashSet;
+import java.util.LinkedHashSet;
 
 /** Test for {@link ResourceAclJsonSerde}. */
 public class ResourceAclJsonSerdeTest extends JsonSerdeTestBase<ResourceAcl> {
@@ -44,7 +44,8 @@ protected ResourceAcl[] createObjects() {
                                     OperationType.ALL,
                                     PermissionType.ALLOW))),
             new ResourceAcl(
-                    new HashSet<>(
+                    // use LinkedHashSet to ensure the order of the acls is preserved
+                    new LinkedHashSet<>(
                             Arrays.asList(
                                     new AccessControlEntry(
                                             new FlussPrincipal("John", "ROLE"),
@@ -62,9 +63,9 @@ protected ResourceAcl[] createObjects() {
     @Override
     protected String[] expectedJsons() {
         return new String[] {
-            "{\"version\":1,\"acls\":[{\"principal_type\":\"USER\",\"principal_name\":\"Mike\",\"permission_type\":\"ALLOW\",\"host\":\"*\",\"host\":\"*\",\"operation\":\"ALL\"}]}",
-            "{\"version\":1,\"acls\":[{\"principal_type\":\"ROLE\",\"principal_name\":\"John\",\"permission_type\":\"ALLOW\",\"host\":\"127.0.0.1\",\"host\":\"127.0.0.1\",\"operation\":\"ALTER\"}"
-                    + ",{\"principal_type\":\"ROLE\",\"principal_name\":\"Mike1233\",\"permission_type\":\"ALLOW\",\"host\":\"1*\",\"host\":\"1*\",\"operation\":\"READ\"}]}"
+            "{\"version\":1,\"acls\":[{\"principal_type\":\"USER\",\"principal_name\":\"Mike\",\"permission_type\":\"ALLOW\",\"host\":\"*\",\"operation\":\"ALL\"}]}",
+            "{\"version\":1,\"acls\":[{\"principal_type\":\"ROLE\",\"principal_name\":\"John\",\"permission_type\":\"ALLOW\",\"host\":\"127.0.0.1\",\"operation\":\"ALTER\"}"
+                    + ",{\"principal_type\":\"ROLE\",\"principal_name\":\"Mike1233\",\"permission_type\":\"ALLOW\",\"host\":\"1*\",\"operation\":\"READ\"}]}"
         };
     }
 }