2.1.7，flink使用ldap账号访问doris失败

Viewed 34
2.1 ingestion

doris版本：2.1.7， 集成了ldap与ranger
在dbeaver中能使用ldap账号进行连接，但如下，使用flink-sql时存在问题：

create table dim_city(
  `city` STRING,
  `level` INT ,
  `province` STRING,
  `country` STRING
) WITH (
  'connector' = 'doris',
  'fenodes' = '	doriscluster-fe-service.doris:8030',
  'jdbc-url' = 'jdbc:mysql://doriscluster-fe-service.doris:8030/?authenticationPlugins=DorisLdapPasswordPlugin&defaultAuthenticationPlugin=DorisLdapPasswordPlugin&disabledAuthenticationPlugins=com.mysql.jdbc.authentication.MysqlClearPasswordPlugin',
  'table.identifier' = 'aic.dim_city',
  'username' = 'doris',
  'password' = 'xxx'
);
select * from dim_city;

当使用doris内置的账号,能正常工作，当切换为ldap账号后，报null，打断点后，看到：
image.png

断点调试flink-doris-connector,发现它是使用的http,而不是jdbc
image.png

跟doris-ui上使用ldap账号登录的问题一样，请问一下该如何解决

seawenc3
2 Answers

这看着是账号权限的问题，可是试试ldap账号能通过MySQLClient的方式链接吗？

JNSimba306

采用以下jdbc的方式是可以的,我就先用jdbc方式连接了，不知道官方提供的connector=doris有啥优势

CREATE TABLE IF NOT EXISTS dim_city (
  `city` STRING,
  `level` INT ,
  `province` STRING,
  `country` STRING
)
 WITH(
  'connector'  = 'jdbc' ,
  'table-name'  = 'dim_city' ,
  'url'  = 'jdbc:mysql://doriscluster-fe-service.doris:9030/dim?authenticationPlugins=DorisLdapPasswordPlugin' ,
  'username' = 'ldapuser',
  'password' = 'xxx'
) ;
seawenc3