Skip to content

Commit 40f5bb5

Browse files
committed
fix test
1 parent c366b21 commit 40f5bb5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/security/acl/FlinkAuthorizationITCase.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -414,7 +414,10 @@ List<String> listAcl(Resource resource, OperationType operationType) {
414414
TableResult tableResult =
415415
tEnv.executeSql(
416416
String.format(
417-
"CALL %s.sys.acl( action => 'LIST', resource => '%s', permission => 'ALLOW', principal => '%s', operation => '%s')",
417+
// Flink 1.18 not support index argument.
418+
// "CALL %s.sys.acl( action => 'LIST', resource => '%s', permission
419+
// => 'ALLOW', principal => '%s', operation => '%s')",
420+
"CALL %s.sys.acl('LIST', '%s', 'ALLOW', '%s', '%s')",
418421
ADMIN_CATALOG_NAME,
419422
getProcedureResourceString(resource),
420423
String.format("%s:%s", guest.getType(), guest.getName()),

0 commit comments

Comments
 (0)