Hi, All: ????????Flink1.10.0??SQL????????????????????
Caused by: java.lang.IllegalArgumentException: Too few memory segments provided. Hash Join needs at least 33 memory segments. at org.apache.flink.runtime.operators.hash.MutableHashTable.<init>(MutableHashTable.java:401) at org.apache.flink.runtime.operators.hash.MutableHashTable.<init>(MutableHashTable.java:387) at org.apache.flink.runtime.operators.hash.HashJoinIteratorBase.getHashJoin(HashJoinIteratorBase.java:51) at org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator.<init>(NonReusingBuildSecondHashJoinIterator.java:89) at org.apache.flink.runtime.operators.JoinDriver.prepare(JoinDriver.java:194) at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:474) ... 4 common frames omitted ????????????????????JDBCInputFormat??MySQL????????????????Flink SQL??????????????????JDBCOutputFormat??????MySQL?? ??????????Flink1.7.2??????????????????????????????????????????????Flink1.10.0??????????????????????????????????????????????????????????Table??????????Table????????????????????????????30??Table,29??left join??????????????????10??left join???????????? ????????????????????????????Thanks??
