📌 📄 内容摘要:
Yuengh 在 Flink背压，该如何优化呢？ 中发帖
背景：在阿里云的Flink全托管一个flink作业
链路是业务库RDS → kafka → Analysisdb Mysql
建表为：
– CREATE TABLE dw.dwi_oms_sku_price_newest
– (
– channel_sku string
– ,unit_price DECIMAL(20, 4)
– ,bi_last_update_time TIMESTAMP(3)
– ,currency string
– ,db_name STRING, – 读取库名。
– table_name STRING , – 读取表名。
– operation_ts TIMESTAMP(3), – 读取变更时间。
– op_type ...
────────── 链接信息 ──────────
🔗 论坛链接: linux.do
📎 访问地址: https://linux.do/t/topic/718749/1
─────────────────────────────
📢 来源：LINUX DO
