Merge remote-tracking branch 'origin/dev-1.7.0-webank' into dev-1.7.0…

…-webank
WeDataSphere · Aug 19, 2024 · b08057c · b08057c
2 parents cf3f410 + 28d9c31
commit b08057c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/transform/RPCConsumer.scala b/linkis-commons/linkis-rpc/src/main/scala/org/apache/linkis/rpc/transform/RPCConsumer.scala
@@ -52,9 +52,12 @@ private[linkis] object RPCConsumer {
           if (data.isEmpty) return BoxedUnit.UNIT
           val objectStr = data.get(OBJECT_VALUE).toString
           val objectClass = data.get(CLASS_VALUE).toString
+          val isRequestProtocol = data.get(IS_REQUEST_PROTOCOL_CLASS).toString
           logger.debug("The corresponding anti-sequence is class {}", objectClass)
           if (
-              RPCConfiguration.ENABLE_RPC_OBJECT_PREFIX_WHITE_LIST_CHECK && !RPCConfiguration.RPC_OBJECT_PREFIX_WHITE_LIST
+              RPCConfiguration.ENABLE_RPC_OBJECT_PREFIX_WHITE_LIST_CHECK && "true".equals(
+                isRequestProtocol
+              ) && !RPCConfiguration.RPC_OBJECT_PREFIX_WHITE_LIST
                 .exists(prefix => objectClass.startsWith(prefix))
           ) {
             throw new DWCURIException(