在使用Flink廣播變量broadcast時遇到的坑

在使用Flink廣播變量遇到的坑 以下代碼中須要特別注意： （1）須要手動導入org.apache.flink.api.scala._ （2）須要手動導入scala.collection.JavaConverters._ 【若是不手動導入該包，致使asScala使用隱式轉換失敗】java package testbrocast import org.apache.flink.api.common

>>阅读原文<<