Flink 侧输出报错：Could not determine TypeInformation for the OutputTag type.

本文主要是介绍Flink 侧输出报错：Could not determine TypeInformation for the OutputTag type.，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、问题描述

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.net/YongDaiMe/article/details/108593102

这篇关于Flink 侧输出报错：Could not determine TypeInformation for the OutputTag type.的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---