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&gt;(MutableHashTable.java:401)

 at 
org.apache.flink.runtime.operators.hash.MutableHashTable.<init&gt;(MutableHashTable.java:387)

 at 
org.apache.flink.runtime.operators.hash.HashJoinIteratorBase.getHashJoin(HashJoinIteratorBase.java:51)

 at 
org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator.<init&gt;(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??

回复