admin管理员组

文章数量:1579929

一.场景

当在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://www.elefans.com/dianzi/1725700578a1037419.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。