The following exception was thrown in the MiniCluster.executeJobBlocking method
via the debug source code.
akka.pattern.AskTimeoutException: Ask timed out on
[Actor[akka://flink/user/dispatcher#997865675]] after [1 ms]. Sender[null]
sent message of type
I am using the HBaseTableSource class for SQL query errors.No error outside
Flink using HBase demo.
My flink version is 1.8.1,use flink table SQL API
flink code show as below:
// environment configuration
ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
