flink 1.6 sql gateway 测试记录

flink 1.16 sql gateway 测试简单记录

总结

• 从能搜索到的文档看，一次只能执行一条sql或者set 之类的命令
• 本质就是flink sql的 proxy ，文档也是如此描述
• 通过curl 直接使用还是不方便，应该考虑使用代码进行封装
• 执行失败会返回后台堆栈，但不自行格式化很难阅读，同时还是建议去看后台log
• 虽然是proxy性质，单独部署时候配置和lib需要和cluster其它节点保持一致，否则会有class找不到之类的错误
• 执行结果有点奇怪，有点难阅读，比如select 输出没有column name

执行记录

curl --request POST http://localhost:8083/v1/sessions |jq |grep sessionHandle|awk -F\" '{print $4}'


curl 
1
2
3