Hi Canbin, this looks indeed like a bug to me. I'm pulling in Dawid who worked on this part and might be able to tell us more about it.
If he agrees, then I would suggest to open a JIRA issue and to fix it. Cheers, Till On Wed, Apr 1, 2020 at 11:26 AM Canbin Zheng <felixzhen...@gmail.com> wrote: > Hi everyone, > > Recently I failed to run a Flink job when enabling RocksDBStateBackend on > the branch master and 1.10. > > The exception stack trace is: > > The program finished with the following > exception:org.apache.flink.client.program.ProgramInvocationException: > The main method caused an error: The adapter does not support this > method > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335) > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205) > at > org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:143) > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:659) > at > org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:210) > at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:890) > at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:963) > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) > at > org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:963) > Caused by: java.lang.UnsupportedOperationException: The adapter does > not support this method > at > org.apache.flink.configuration.ReadableConfigToConfigurationAdapter.getEnum(ReadableConfigToConfigurationAdapter.java:258) > at > org.apache.flink.contrib.streaming.state.RocksDBStateBackend.<init>(RocksDBStateBackend.java:336) > at > org.apache.flink.contrib.streaming.state.RocksDBStateBackend.configure(RocksDBStateBackend.java:394) > at > org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory.createFromConfig(RocksDBStateBackendFactory.java:47) > at > org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory.createFromConfig(RocksDBStateBackendFactory.java:32) > at > org.apache.flink.runtime.state.StateBackendLoader.loadStateBackendFromConfig(StateBackendLoader.java:154) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.loadStateBackend(StreamExecutionEnvironment.java:792) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.configure(StreamExecutionEnvironment.java:761) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.<init>(StreamExecutionEnvironment.java:217) > at > org.apache.flink.client.program.StreamContextEnvironment.<init>(StreamContextEnvironment.java:53) > at > org.apache.flink.client.program.StreamContextEnvironment.lambda$setAsContext$2(StreamContextEnvironment.java:103) > at java.util.Optional.map(Optional.java:215) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getExecutionEnvironment(StreamExecutionEnvironment.java:1882) > at > org.apache.flink.streaming.examples.socket.SocketWindowWordCount.main(SocketWindowWordCount.java:62) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321) > ... 8 more > > It seems that this is a BUG. Does anyone encounter such a problem? > > I am wondering why we introduce ReadableConfigToConfigurationAdapter > to wrap the Configuration but leave many of the methods in it to throw > UnsupportedOperationException that causes problems. > > Regards, > > Canbin Zheng >
