Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-33374

Execute REMOVE JAR command failed via SQL gateway

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • 1.18.0
    • None
    • Table SQL / Gateway
    • None

    Description

      Execute the below steps could reproduce the exception:

      At first, I added a specified jar to the classloader via the ADD JAR command, and using the SHOW JARS command also displayed the jars. 

      But the REMOVE JAR command is not supported right now.

       

      Caused by: java.lang.UnsupportedOperationException: SQL Gateway doesn't support REMOVE JAR syntax now.
              at org.apache.flink.table.gateway.service.operation.OperationExecutor.callRemoveJar(OperationExecutor.java:550) ~[flink-sql-gateway-1.18.0.jar:1.18.0]
              at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:442) ~[flink-sql-gateway-1.18.0.jar:1.18.0]
              at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.0.jar:1.18.0]
              at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.0.jar:1.18.0]
              at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.0.jar:1.18.0] 

      It seems the RemoveJarOperation is ignored.

      https://github.com/apache/flink/blob/release-1.18.0/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java#L550

      Attachments

        Activity

          People

            Unassigned Unassigned
            yesorno Xianxun Ye
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: