Hi！
这看起来像一个 bug，我已经记了一个 issue [1]，可以在那里关注问题进展。
如 issue 中所描述，目前看来如果常量字符串一样长，或者都 cast 成 varchar 可以绕过该问题。可以先这样绕过一下。
[1] https://issues.apache.org/jira/browse/FLINK-24537
kcz <573693...@qq.com.invalid> 于2021年10月13日周三 下午5:29写道：
> 因为select出多个sum的值，每一个sum的值都是一个type类型的数据，最后我将它插入到MySQL表里面，MySQL表结构为
>
Hi！
从报错信息来看 client 在尝试链接位于 http://127.0.0.1:8081/ 的集群。你的 yarn session
应该不在本地吧？所以很可能是 sql client 对应的 flink 配置出错，检查一下对应的 flink 配置文件看看。
maker_d...@foxmail.com 于2021年10月14日周四 上午9:18写道：
> 各位大家好：
> 紧急求助！
> 我之前一直用sql-client提交SQL任务，今天突然不能提交了，报错如下：
>
> Exception in thread "main"
>
你可以把使用反向条件把脏数据输出到另外一张表去。source会复用的。其实和side output效果是一致的
On Oct 13, 2021 at 16:28:57, Ada Luna wrote:
> 这个没有支持的打算是因为，目前我们假定Flink SQL处理的数据都是干净的经过清洗的是吧。
>
> Ada Luna 于2021年9月19日周日 下午7:43写道：
>
>
> 主要是脏数据，Source、Sink或者其他算子产生的脏数据，向把这些数据侧向输出到外部数据库里存起来。
>
>
> Caizhi Weng 于2021年9月16日周四 下午1:52写道：
>
> >
各位大家好：
紧急求助！
我之前一直用sql-client提交SQL任务，今天突然不能提交了，报错如下：
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:215)
Caused by:
是不是加了 'lookup.async' = 'true'，当 rowkey 为 null 的时候会出现这个问题
https://issues.apache.org/jira/browse/FLINK-24528
Michael Ran 于2021年7月23日周五 上午10:44写道：
> java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError:
> org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtils缺jar
> 在
旭晨,你好。
关于你描述的问题，当前的MySQLCatalog的实现是不支持的，如果需要此功能，则需要重写对应的方法。https://github.com/apache/flink/pull/16962
中 twalthr 老师与 jark 老师提及后续会重构这一部分。你可以在对应的JIRA或者PR上直接进行留言做进一步的讨论。
目前基于AbstractJdbcCatalog实现的XXXCatalog,
包括PostgresCatalog和正在实现的MySQLCatalog都是不支持创建和更改表的。GenericInMemoryCatalog与HiveCatalog是支持的。
select??sumsumtypeMySQLMySQL
(id,type,value)
SQL??
CREATE TABLE kafka_table (
vin STRING,
speed DOUBLE,
brake DOUBLE,
hard_to
@Roc Marshal 你好：
我大致翻了下你的FLINK-15352分支上的关于mysqlcatalog的测试代码，想问一个问题：
目前的mysql实现，tabelenvironment通过jdbc驱动，去加载mysql元数据，那么，反过来，通过flink java
api或者sqlclient，执行DDL建表语句create
catalog.database.table，将元数据写入mysql，之后当我第二次要调用相关表的时候就不需要再建表了，因为mysql已经有相关元数据了，这个能支持吗？
在
这个没有支持的打算是因为，目前我们假定Flink SQL处理的数据都是干净的经过清洗的是吧。
Ada Luna 于2021年9月19日周日 下午7:43写道：
>
> 主要是脏数据，Source、Sink或者其他算子产生的脏数据，向把这些数据侧向输出到外部数据库里存起来。
>
> Caizhi Weng 于2021年9月16日周四 下午1:52写道：
> >
> > Hi！
> >
> > 就我所知目前暂时没有支持 side output 的打算。可以描述一下需求和场景吗？
> >
> > Ada Luna 于2021年9月15日周三 下午8:38写道：
> >
> > >
目前我遇到的问题是不同Job的日志无法再一个Session中区分。
看了京东写的文章。
https://www.infoq.cn/article/1nvlduu82ihmusxxqruq
未来社区在这方面有什么规划吗。
https://issues.apache.org/jira/browse/FLINK-17969
这个Ticket的PR也被关了。
退订
| |
宋京昌
|
|
邮箱：sjc999...@126.com
|
签名由 网易邮箱大师 定制
退订
13 matches
Mail list logo
