??
flink1.12.1
hive2.1.0
CDH6.2.0
Kerberoshive??
Kerberos
hive metastore??
??sql-client.sh embedded??
Flink SQL> show tables;
dimension_table
dimension_table1
test
Flink SQL> select * fr
您好!
hive.metastore.sasl.enabled 是true
启动sql client的时候,可以正常读取到认证信息,并读取metastore的表名。
读和写,认证就失败了。
---原始邮件---
发件人: "Rui Li"
好的,谢谢!
---原始邮件---
发件人: "Rui Li"https://issues.apache.org/jira/browse/FLINK-20913
有关了,这个issue是1.12.2修复的,可以升级一下试试。
On Mon, Mar 8, 2021 at 2:15 PM guoyb <861277...@qq.com> wrote:
> 您好!
> hive.metastore.sasl.enabled 是true
>
>
> 启动sql client的时候,可以正常读取到认证信息,并读
版本1.12.1
请问,支持事件时间吗?应该设置为哪种时间类型。
as_of_time time
group by xx
, tumble( as_of_time, interval "5" second)
sql client报错,
window aggregate can only be defined over a time attribute column, but time(0)
encountered
这个问题换种写法解决了,从MySQL数据库表里取时间戳字段再转timestamp,可以实现滚动窗口,没报错。
从MySQL表里直接取datetime类型,jdbc表flink设置timestamp类型,会报错,直接取source的时间类型字段是不是转换有点问题。
---原始邮件---
发件人: "guoyb"<861277...@qq.com>
发送时间: 2021年3月17日(周三) 下午5:43
收件人: "user-zh"
mysql cdc表 和kafka表关联,应该怎么写,有对应示例吗?
请问,MySQLcdc的数据,后续要聚合,应该放到upsertkafka吗?还是有其他方法。
如果我的需求需要写入明细数据,还要根据明细数据做聚合,然后再把汇总数据入库。
这种数据加工的流程应该怎么设计比较好!
可以读取的,还有内置flink cdc
select得用query方法,看看是不是用错了execute。
---原始邮件---
发件人: "air23"https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/jdbc.html
这边读取mysql jdbc数据报错Exception in thread "main"
org.apache.flink.table.api.TableException: Only insert statement is supported
不是replace,用的是insert into duplicate key update
---Original---
From: "liujian"<13597820...@qq.com>
Date: Thu, Apr 1, 2021 16:02 PM
To: "user-zh"
比如jdbc connector MySQL
create table xxx
()
with(
" user name"=" root"
," password"="123456"
)
;
用户密码可以怎么配置,可以不用明文这种方式。
加下测试看看,你这很明显没找到包
---原始邮件---
发件人:
"user-zh-return-12015-861277329=qq.com"https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/formats/parquet.html
添加的依赖,
是需要把 flink-parquet_2.11 文件手动添加到 lib 目录才可以的吗?
-- 原始邮件 --
发件人:
To remove your address from the list, send a message to:
1.12.0的也可以,大版本一样就行了
---原始邮件---
发件人: "张锴"
本地模式可以执行成功
提交到yarn,报错
java.lang.ClassNotFoundException:org.apache.kafka.clients.consumer.ConsumerRecord
lib包里有sql-connector-kafka,请问这是什么情况导致的?可以怎么排查,yarn上有哪些jar包呢。
可以看看这个demo
https://github.com/bingoguo93/flink-1.12-sql-demo/blob/main/src/main/java/org/example/mysql/tableQueryMysql.java
---原始邮件---
发件人: "张锴"
您好!请问遇到如下格式的该如何用SQL解析。
string {name=string} {id : 1, name : abram}
eg:
2021-04-03x {name=aa} {id : 1, name : abram}
最重要为第三个字段 JSON,里面包含了data
第一和第二个字段可要可不要
请问,有思路可以参考吗?或者demo
SQL能实现吗?
---原始邮件---
发件人: "19971028...@163.com"<19971028...@163.com>
发送时间: 2021年4月27日(周二) 晚上6:51
收件人: "user-zh"
好的,谢谢!我都试试看
---原始邮件---
发件人: "JasonLee"<17610775...@163.com>
发送时间: 2021年4月27日(周二) 晚上7:14
收件人: "user-zh"http://apache-flink.147419.n8.nabble.com/
我的也有这种问题,没解决,kerberos认证的hive导致的。
---原始邮件---
发件人: "张锴"
看看yarn session是不是被kill掉了。
---原始邮件---
发件人: "Rui Li"
去yarn后台,看看am落在哪个机器上面,地址就是那个。
---原始邮件---
发件人: "maker_d...@foxmail.com"
tumble() 开窗,需要的事件时间到底需要什么时间类型?一直报时间不对
timestamp(3)
datetime
time
都试过了,没有一个对的。
是的。
大神能否指条明路解决这问题。
---原始邮件---
发件人: "MOBIN"<18814118...@163.com>
发送时间: 2021年6月1日(周二) 晚上7:09
收件人: "user-zh@flink.apache.org"
好的,谢谢!
我试试
---原始邮件---
发件人: "Shuo Cheng"
谢谢!明天回公司再调试。
---原始邮件---
发件人: "MOBIN"<18814118...@163.com>
发送时间: 2021年6月1日(周二) 晚上7:41
收件人: "user-zh@flink.apache.org"https://help.aliyun.com/document_detail/62512.html?spm=a2c4g.11186623.6.827.49531b09XfgsU7
| |
MOBIN
|
签名由网易邮箱大师定制
在2021年06月1日 19:37,guoyb<86127
??
-- --
??:
"user-zh"
select的问题,排查一下,单独查表是否有数据,关联条件。
---Original---
From: "赵旭晨"
28 matches
Mail list logo