Hello, I am following along with this tutorial: https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/try-flink/datastream/ .
I am deploying this to the latest binary downloaded from: https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/try-flink/local_installation/ , which is the 2.0.0 binary. When running the Fraud Detection code, I am getting this error: Caused by: java.lang.IllegalStateException: Current operator integrates the async processing logic, thus only supports state v2 APIs. Please use StateDescriptor under 'org.apache.flink.runtime.state.v2'. So, two questions about this error message. 1. Following along with the code, it's not clear to me which part of the operator is using async . If it's possible to mix v2 and v1 APIs in synchronous mode, that would also work. 2. Looking at the Javadocs for 'org.apache.flink.runtime.state.v2', I can't seem to see a StateDescriptor class there: https://javadoc.io/doc/org.apache.flink/flink-runtime/2.0.0/org/apache/flink/runtime/state/v2/package-summary.html . So I'm not sure what is the correct import to use here? Appreciate any help in this matter! Thank You Sincerely, Shikhar Raje -- Disclaimer: This message and its attachments contain confidential and legally privileged information. Dream Sports Group, including all its affiliates and subsidiaries, provides no warranties with respect to the contents of this communication and disclaims any and all liability for reliance thereon.
