【Flink】Specifying keys via field positions is only valid for tuple data types.

写代码的时候遇到如下问题

Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: Specifying keys via field positions is only valid for tuple data types. Type: GenericType<scala.Tuple2>
   at org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>(Keys.java:239)
   at org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>(Keys.java:232)
   at org.apache.flink.api.java.DataSet.groupBy(DataSet.java:739)
   at com.batch.FlinkBatch.main(FlinkBatch.java:26)

代码如下，报错位置已标红

package com.batch;import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.util.Collector;
import org.apache.flink.util.Preconditions;
import scala.Tuple2;public class FlinkBatch {public stati

【Flink】Specifying keys via field positions is only valid for tuple data types.相关推荐

【Flink】Flink状态的缩放（rescale）与键组（Key Group）设计
1.概述转载:Flink状态的缩放(rescale)与键组(Key Group)设计这个东东还没了解过.来看一下. 在之前那篇讲解Flink Timer的文章里,我曾经用三言两语简单解释了Key ...
【Flink】Flink 不支持部分 task 结束后进行 checkpoint
纪念一波,九师兄博客热门订阅专栏时常名列前茅,我飘了,哈哈哈哈,得意的笑 1.概述以前遇到一个问题,这个问题是这样的,一个FLink job,然后部分是离线任务,数据读取完毕了,就结束了.然后发现就 ...
【Flink】Flink 源码阅读笔记（20）- Flink 基于 Mailbox 的线程模型
1.概述转载:Flink 源码阅读笔记(20)- Flink 基于 Mailbox 的线程模型相似文章:[Flink]Flink 基于 MailBox 实现的 StreamTask 线程模型 Fl ...
【Flink】Flink 源码之Buffer Debloating
1.概述转载:[Flink]Flink 源码之Buffer Debloating 2.什么是Buffer debloating Buffer Debloating是Flink 1.14新增的优化方式 ...
【Flink】Metrics运作机制
1.概述转载并且补充:Flink源码剖析:Metrics运作机制 1. Metrics简介 1.1 什么是 Metrics? Flink 提供的 Metrics 可以在 Flink 内部收集一些指标 ...
【Flink】FLink PipelineExecutorFactory 基于工厂模式的任务提交与SPI机制
1.概述转载: Flink1.10基于工厂模式的任务提交与SPI机制 Flink任务执行模式包含了yarn-session.standalone.per-job.local, 在1.10中又增加k8 ...
【Flink】Zookeeper connection loss leads to Flink job restart
1.概述转载:添Zookeeper connection loss leads to Flink job restart 看这个之前可以先看看:[Flink]Flink 报错 ResourceMan ...
【Flink】Flink 没有keyBy 某个 subTask 没有数据
文章目录 1.概述 M.扩展 1.概述一个flink程序,如下,但是总共100多个task,然后只有一个没有数据. 第一怀疑是不是keyBy问题,上述看错了,然后以为有keyBy 然后参考文章:[F ...
【Flink】Flink SQL 报错 ClassCastException: VarCharType cannot be cast to RowType
文章目录 1.概述 1.1 实体类 1.概述背景参考:[Flink]FLink SQL 如何使用嵌套格式的Schema 我想要实现通过flink table api来实现: select * fro ...

【Flink】Specifying keys via field positions is only valid for tuple data types.

【Flink】Specifying keys via field positions is only valid for tuple data types.相关推荐

最新文章

热门文章