????Flink????????????????
      ??????Flink SQL (Flink 1.8.1),??hadoop 
????????????????yarn-site.xml????????????????
        <property>
                <name>yarn.nodemanager.resource.memory-mb</name>
                <value>16384</value>
        </property>
        <property>
                <name>yarn.scheduler.minimum-allocation-mb</name>
                <value>1024</value>
        </property>
        <property>
                <name>yarn.scheduler.maximum-allocation-mb</name>
                <value>8192</value>
        </property>



????????????flink on yarn????????????????./flink-1.8.1/bin/flink run -m 
yarn-cluster -p 4 -d -c streaming.StreamKafkaMain -yn 4 -ys 2 -yjm 2048 -ytm 
8192  -ynm bigdata6 ./flink_bigdata6.jar
????????????????????????????????10??????????????????????????????????????????????????????????

回复