admin管理员组

文章数量:1639191

一、问题描述

flink侧输出报错 The program finished with the following exception

 The program finished with the following exception:

Could not determine TypeInformation for the OutputTag type. The most common reas                                                                                                                   on is forgetting to make the OutputTag an anonymous inner class. It is also not                                                                                                                    possible to use generic type variables with OutputTags, such as 'Tuple2<A, B>'.
        org.apache.flink.util.OutputTag.<init>(OutputTag.java:68)

二、问题原因

因为代码中new OutputTag(“test”)后面少写了大括号{}

private static OutputTag<String> outputTag = new OutputTag<String>("test");

对于scala是可以少些的，但是java不能少些，这个使用java编写的时候需要注意。

三、解决办法

最后加一个大括号 “{}”

private static OutputTag<String> outputTag = new OutputTag<String>("test"){};

四、参考文章

1.https://blog.csdn/YongDaiMe/article/details/108593102

本文标签： 报错determineFlinktypeOutputTag

版权声明：本文标题：Flink 侧输出报错：Could not determine TypeInformation for the OutputTag type. 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/dianzi/1729278735a1193812.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。