New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Flink实时同步到需要密码的es失败，401 Unauthorized #76

Closed

JanCong opened this issue Dec 30, 2021 · 5 comments

Labels

enhancement v3.4.0

JanCong commented Dec 30, 2021

baisui1981 added enhancement v3.4.0 labels

Member

baisui1981 commented Dec 30, 2021

兄弟有两点需要确认一下

这个flink使用的是 tis定制过的tis-flink?
所谓的用户名密码应该就是accessKeyId和accessKeySecret 吧？

Author

JanCong commented Dec 30, 2021 •

edited

Loading

兄弟有两点需要确认一下

这个flink使用的是 tis定制过的tis-flink?

所谓的用户名密码应该就是accessKeyId和accessKeySecret 吧？

1.使用的是tis定制过的tis-flink
2. 用户名密码是accessKeyId和accessKeySecret

用的是阿里云的es，试了自建的不用验证的es是没问题的

Member

baisui1981 commented Dec 30, 2021

嗯现在的确没有把 accessKeyId和accessKeySecret 加入到认证的流程中去，下个版本v3.4.0 会把这个功能加入进去的

Member

baisui1981 commented Dec 30, 2021

其他还有啥建议或者需求都一并提过来

Member

baisui1981 commented Jan 6, 2022

修改了https://github.com/qlangtech/plugins/blob/8f62200ba7f85d33d64308ab02ccefa96989f376/tis-incr/tis-sink-elasticsearch7-plugin/src/main/java/com/qlangtech/tis/plugins/incr/flink/connector/elasticsearch7/ElasticSearchSinkFactory.java#L176 ，当用户设置了用户名和密码之后，会在这里将用户认证信息加入的http的报头中去，明天再测试一下

baisui1981 closed this as completed

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment