请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 地址来取消订阅来自
user-zh-unsubscr...@flink.apache.org 邮件组的邮件，你可以参考[1][2] 管理你的邮件订阅。
Best,
Hang
[1]
https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8
[2] https://flink.apache.org/community.html#mailing-lists
王新隆 于2024年3月11日周一
Hi, Xuyang & Daniel.
I have checked this part of code. I think it is an expected behavior.
As marked in code comments, this loop makes sure that the transactions
before this checkpoint id are re-created.
The situation Daniel mentioned will happen only when all checkpoint between
1 and 2
退订
Hi, Danny.
When the problem occurs, can you use flame graph to confirm whether the loop in
this code is causing the busyness?
Since I'm not particularly familiar with kafka connector, I can't give you an
accurate reply. I think Hang Ruan is an expert in this field :).
Hi, Ruan Hang. Can you
hi, 东树
隐藏sql中的敏感信息，这个需要外部的大数据平台来做。
比如：StreamPark 的变量管理，可以提前维护好配置信息，编写sql时引用配置，由平台提交至flink时解析sql并替换变量。
Best,
Zhongqiang Gong
杨东树 于2024年3月10日周日 21:50写道：
> 各位好，
>考虑到数据库用户、密码安全性问题，使用FlinkSQL connector
> jdbc时，请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
> CREATE TABLE wordcount_sink (
>
1. 目前 JDBC connector 本身不支持加密， 我理解可以在提交 SQL 给 SQL 文本来做加解密的操作，或者做一些变量替换来隐藏密码。
2. 可以考虑提前创建好 jdbc catalog，从而避免编写 DDL 暴露密码。
Best,
Feng
On Sun, Mar 10, 2024 at 9:50 PM 杨东树 wrote:
> 各位好，
>考虑到数据库用户、密码安全性问题，使用FlinkSQL connector
> jdbc时，请问如何对数据库的用户密码进行加密/隐藏呢。例如如下常用sql中的password:
> CREATE TABLE
退订
At 2024-02-26 20:55:19, "Salva Alcántara" wrote:
Awesome Andrew, thanks a lot for the info!
On Sun, Feb 25, 2024 at 4:37 PM Andrew Otto wrote:
> the following code generator
Oh, and FWIW we avoid code generation and POJOs, and instead rely on Flink's
Row or RowData
各位好，
考虑到数据库用户、密码安全性问题，使用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',
