在flatMap中使用Flink Table API获取序列化异常
我试图通过将flink env对象传递给flatMap对象来使用flatMap中的表api。但我遇到了序列化异常，这表明我添加了一些无法序列化的字段。
你能解释一下吗？
你好Sajeev
共有1个答案
无法将ExecutionEnvironment传递到函数中。这就像把Flink传给Flink一样。
表API是数据集API之上的抽象。如果要同时使用表API和低级API，可以使用toDataSet/fromdaset在API之间甚至在DataSet操作符之间进行更改。
DataSet<Integer> ds = env.fromElements(1, 2, 3);
BatchTableEnvironment tEnv = TableEnvironment.getTableEnvironment(env);
Table t = tEnv.fromDataSet(ds, "intCol"); // continue in Table API
Table t2 = t.select("intCol.cast(STRING)"); // do something with table
DataSet<String> ds2 = tEnv.toDataSet(t2); // continue in DataSet API
-
ClassCastException：com.google.gson.internal.LinkedTreeMap不能强制转换为java.util.HashMap 提前谢了。
-
问题内容： 我已经尝试过类似的方法，但是它不起作用。 我需要一种能够从我的Serializer类访问request.user的方法。 问题答案： 你不能直接访问。你需要访问请求对象，然后获取用户属性。 像这样： 为了更安全，
-
我有一个用户对象，它被发送到服务器和从服务器发送。当我发出user对象时，我不想将散列密码发送给客户端。因此，我在password属性中添加了，但这也阻止了它反序列化为密码，这使得用户在没有密码时很难注册。 如何才能只让应用于序列化而不应用于反序列化？我使用的是Spring JSONView，所以我对没有太多的控制权。 将添加到属性 仅在getter方法上添加
-
问题内容： 动机： 为了帮助进行远程调试（Java），能够请求远程服务器将任意对象发送到我的本地计算机进行检查是很有用的。但是，这意味着远程服务器必须能够序列化运行时事先未知的任意Java对象。 于是我四处询问，偶然发现了Kryo序列化库。根据Kryo的文档，主要功能是在序列化任意Java对象方面非常强大。对象不必实现，不需要no- arg构造函数就可以反序列化，而且我甚至不需要在序列化之前就了解
-
问题内容： 我将Flask示例Minitwit与MongoDB一起使用，并且在Flask 0.9上运行良好，但是升级到0.10.1后，当我尝试设置会话ID时登录时出现标题错误。 似乎Flask 0.10.1中有与json相关的更改。 程式码片段： 基本上，我将MongoDB中的Flask会话ID设置为用户的_id。 我尝试了这个SO问题的前两个解决方案，但没有成功。 好吧，执行session [‘
-
有没有一种方法让我忽略这些异常并在消费者处移动偏移量？我想，因为我使用手动偏移提交，我有这个问题。有人知道如何配置kafka-avro-serializer-6.0.0.jar来完成我想要的任务吗？ 多谢了。