申请退订邮件通知,谢谢!
各位好,
考虑到数据库用户、密码安全性问题,使用FlinkSQL connector
jdbc时,请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
CREATE TABLE wordcount_sink (
word String,
cnt BIGINT,
primary key (word) not enforced
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://localhost:3306/flink',
'username' = 'root',
各位好,
目前使用sql-client查询hbase数据时,无法查询成功,麻烦指导下,谢谢。
复现方法:
1、hbase操作:
hbase(main):005:0> create 'flink_to_hbase','cf1'
0 row(s) in 2.2900 seconds
hbase(main):006:0> put 'flink_to_hbase', 'rk0001', 'cf1:username', 'zhangsan'
0 row(s) in 0.0510 seconds
2、flink操作:
./start-cluster.sh
; 写道:
>Hi,
>
>邮件里的图片看不到
>
>Best,
>Shammon FY
>
>On Sun, Jul 9, 2023 at 7:30 PM 杨东树 wrote:
>
>> 各位好,
>>目前我在使用flink1.14.5版本的sql-client on
>> yarn-session模式时,发现无法正常执行sql任务,日志报如下错误,希望能得到指导,谢谢:
>>背景信息:
>>1、当flink配置executio
各位好,
目前我在使用flink1.14.5版本的sql-client on
yarn-session模式时,发现无法正常执行sql任务,日志报如下错误,希望能得到指导,谢谢:
背景信息:
1、当flink配置execution.target: yarn-per-job时,随后进入sql-client执行sql任务,可正常执行。
2、当flink配置execution.target: yarn-session,并启动flink
yarn-session集群,随后进入sql-client执行同样的sql任务,报上图中的错误。