Hi all, In unit tests that use the LocalFilinkMiniCluster, with Flink 1.4, I now get this warning in my logs:
> 18/01/31 13:28:19 WARN query.QueryableStateUtils:76 - Could not load > Queryable State Client Proxy. Probable reason: flink-queryable-state-runtime > is not in the classpath. Please put the corresponding jar from the opt to the > lib folder. > 18/01/31 13:28:19 DEBUG query.QueryableStateUtils:79 - Caught exception > java.lang.ClassNotFoundException: > org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:264) > at > org.apache.flink.runtime.query.QueryableStateUtils.createKvStateClientProxy(QueryableStateUtils.java:67) > at > org.apache.flink.runtime.taskexecutor.TaskManagerServices.createNetworkEnvironment(TaskManagerServices.java:339) > at > org.apache.flink.runtime.taskexecutor.TaskManagerServices.fromConfiguration(TaskManagerServices.java:159) > at > org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster.startTaskManager(LocalFlinkMiniCluster.scala:240) From what I see in the code, this warning will always be triggered, yes? It seems odd, if I’m not explicitly setting up to use queryable state, that this is flagged as a problem. Is there any way in test code to explicitly configure things to avoid it? Thanks, — Ken -------------------------------------------- http://about.me/kkrugler +1 530-210-6378
