This is an automated email from the ASF dual-hosted git repository. peacewong pushed a commit to branch dev-1.3.2 in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit ad43ed3264dddb474f3b8599f69a231db2644326 Author: Jack Xu <[email protected]> AuthorDate: Tue Nov 15 15:13:11 2022 +0800 fix: fix rpc test case --- .../org/apache/linkis/rpc/conf/RPCConfigurationTest.scala | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/conf/RPCConfigurationTest.scala b/linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/conf/RPCConfigurationTest.scala index 6a5ab1e38..5aaadd133 100644 --- a/linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/conf/RPCConfigurationTest.scala +++ b/linkis-commons/linkis-rpc/src/test/scala/org/apache/linkis/rpc/conf/RPCConfigurationTest.scala @@ -26,8 +26,6 @@ class RPCConfigurationTest { def constTest(): Unit = { val bdprpcbroadcastthreadsize = RPCConfiguration.BDP_RPC_BROADCAST_THREAD_SIZE.getValue - val bdprpceurekaservicerefreshinterval = - RPCConfiguration.BDP_RPC_EUREKA_SERVICE_REFRESH_INTERVAL.getValue.toLong val bdprpcreceiverasynconsumerthreadmax = RPCConfiguration.BDP_RPC_RECEIVER_ASYN_CONSUMER_THREAD_MAX.getValue val bdprpcreceiverasynqueuecapacity = @@ -39,14 +37,9 @@ class RPCConfigurationTest { val enablepublicservice = RPCConfiguration.ENABLE_PUBLIC_SERVICE.getValue val publicserviceapplicationname = RPCConfiguration.PUBLIC_SERVICE_APPLICATION_NAME.getValue val publicservicelist = RPCConfiguration.PUBLIC_SERVICE_LIST - val computationgovernanceappprefix = RPCConfiguration.COMPUTATION_GOVERNANCE_APP_PREFIX - val linkismanagerservicemerged = RPCConfiguration.LINKIS_MANAGER_SERVICE_MERGED.getValue - val linkismanagerapplicationname = RPCConfiguration.LINKIS_MANAGER_APPLICATION_NAME.getValue - val linkismanagerservicelist = RPCConfiguration.LINKIS_MANAGER_SERVICE_LIST val metadataqueryservicelist = RPCConfiguration.METADATAQUERY_SERVICE_LIST Assertions.assertTrue(25 == bdprpcbroadcastthreadsize.intValue()) - Assertions.assertTrue(1000L == bdprpceurekaservicerefreshinterval.longValue()) Assertions.assertTrue(400 == bdprpcreceiverasynconsumerthreadmax.intValue()) Assertions.assertTrue(5000 == bdprpcreceiverasynqueuecapacity.intValue()) Assertions.assertTrue(100 == bdprpcsenderasynconsumerthreadmax.intValue()) @@ -55,10 +48,6 @@ class RPCConfigurationTest { Assertions.assertTrue(enablepublicservice) Assertions.assertEquals("linkis-ps-publicservice", publicserviceapplicationname) Assertions.assertTrue(publicservicelist.size > 0) - Assertions.assertEquals("linkis-cg-", computationgovernanceappprefix) - Assertions.assertTrue(linkismanagerservicemerged) - Assertions.assertEquals("linkis-cg-linkismanager", linkismanagerapplicationname) - Assertions.assertTrue(linkismanagerservicelist.size > 0) Assertions.assertTrue(metadataqueryservicelist.size > 0) } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
