admin管理员组

文章数量:1130349

一.场景

当在Flink中使用POJO时，经常会出现该异常，代码如下：
1.POJO类：

class WordWithCount(word : String, count : Int){
   
   
  def this(){
   
   
    this(null, 0)
  }
}

2.逻辑代码

  val input = execution.fromElements(
      new WordWithCount("hello", 1),
      new WordWithCount("word", 2))

    val result = input
      .groupBy("word")
      .sum("count") // 分组求和

一.场景

当在Flink中使用POJO时，经常会出现该异常，代码如下：
1.POJO类：

class WordWithCount(word : String, count : Int){
   
   
  def this(){
   
   
    this(null, 0)
  }
}

2.逻辑代码

  val input = execution.fromElements(
      new WordWithCount("hello", 1),
      new WordWithCount("word", 2))

    val result = input
      .groupBy("word")
      .sum("count") // 分组求和

本文标签： 解决方案原因orgFlinkobjenesis

版权声明：本文标题：Flink报org.objenesis.strategy.InstantiatorStrategy原因及解决方案 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://it.en369.cn/jiaocheng/1754915086a2741259.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。