问题一:Flink sql怎么进行数据加密 之后怎么解密?
Flink sql怎么进行数据加密 之后怎么解密?
参考答案:
自定义个function
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/618754
问题二:咨询一个问题:flink CDC 支持 KingBase(人大金仓)的CDC吗?
咨询一个问题:flink CDC 支持 KingBase(人大金仓)的CDC吗?
参考答案:
应该是不支持的
这是官方的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/618752
问题三:背压的具体计算公式
目前收集到的说法有
- 阿里论坛的回答:计算公式主要是通过计算上下游的允许发送的数据量(backlog)除以申请的buffer大小
- Flink官网:作业管理器每 50 毫秒为每个任务触发 100 个堆栈跟踪,以确定背压。您在 Web 界面中看到的比率告诉您有多少堆栈跟踪被卡在内部方法调用中,例如 表示只有 1/100 被困在该方法中。0.01。
参考答案:
按最新官网说法,根据下游输入缓冲区是否满来判断背压情况,若一次检查中,下游的输入缓存区已满,记为一次背压
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/618581
问题四:在Flink想实时汇总数据,类似 数据大屏功能,应该用阿里云Flink的什么功能服务?
在Flink想实时汇总数据,类似 数据大屏功能,应该用阿里云Flink的什么功能服务?
参考答案:
实时就是要用flink,要实现这个,要用flinksql吧 ,比如说,实时查询某个用户出现了多少次,那就可以group by username ,就可以了。 你可以做个测试,用一张表,然后一条一条往里面插入数据,就能看到count变化
select count(*) from tablename group by 分组条件;
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/617651
问题五:flink cdc 在连接数据源的时候是要打快照的吧?
flink cdc 在连接数据源的时候是要打快照的吧?
参考答案:
阿里flink是通过catalog连接的, 可以通过catalog进行管理mysql,不需要快照的。
关于本问题的更多回答可点击进行查看: