java19980212 2021-12-03 15:48
浏览 21
已结题

Scala版本flink在idea中打包报错

这是我的代码
import org.apache.flink.streaming.api.scala._
import org.apache.flink.api.java.utils.ParameterTool

object Demo03WCStream {
def main(args: Array[String]): Unit = {

// 从外部命令中获取参数
val params: ParameterTool = ParameterTool.fromArgs(args)
val host: String = params.get("host")
val port: Int = params.getInt("port")

//创建流式处理API
val env = StreamExecutionEnvironment.getExecutionEnvironment
//设置全局并行度为1
env.setParallelism(1)

//禁用job chain
env.disableOperatorChaining()

val ds: DataStream[String] = env.socketTextStream(host, port)
val ds01: DataStream[(String, Int)] =
  ds.flatMap(_.split(" ")).setParallelism(2)
    .map((_, 1)).setParallelism(2).disableChaining()
    .keyBy(0)
    .sum(1).setParallelism(2)

ds01.print("wc")

env.execute("wc job")

}
}
这是报错
Failed to execute goal org.apache.maven.plugins:maven-clean-plugin:2.5:clean (default-clean) on project flink1.12: Failed to clean project: Failed to delete E:\IDEA\flink1.12\target

img

  • 写回答

0条回答 默认 最新

    报告相同问题?

    问题事件

    • 系统已结题 12月11日
    • 创建了问题 12月3日

    悬赏问题

    • ¥20 yolov5自定义Prune报错,如何解决?
    • ¥15 电磁场的matlab仿真
    • ¥15 mars2d在vue3中的引入问题
    • ¥50 h5唤醒支付宝并跳转至向小荷包转账界面
    • ¥15 算法题:数的划分,用记忆化DFS做WA求调
    • ¥15 chatglm-6b应用到django项目中,模型加载失败
    • ¥15 CreateBitmapFromWicBitmap内存释放问题。
    • ¥30 win c++ socket
    • ¥15 C# datagridview 栏位进度
    • ¥15 vue3页面el-table页面数据过多