Re: [PR] [Feature][Connector Hive] support hive savemode [seatunnel]

Mon, 03 Jun 2024 02:31:09 -0700 


liunaijie commented on PR #6842:
URL: https://github.com/apache/seatunnel/pull/6842#issuecomment-2144727147

   > > 
![image](https://private-user-images.githubusercontent.com/73467479/333069983-b89e6671-cfad-4c66-80dc-a67f8b659d7d.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MTY0NDk0ODgsIm5iZiI6MTcxNjQ0OTE4OCwicGF0aCI6Ii83MzQ2NzQ3OS8zMzMwNjk5ODMtYjg5ZTY2NzEtY2ZhZC00YzY2LTgwZGMtYTY3ZjhiNjU5ZDdkLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA1MjMlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNTIzVDA3MjYyOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTYxZTIyODJlYzJmNzRmNWNiMjNmNjhjMDlkY2EzYWFlNzgwMzFmMWFlMTMwY2U4MzlmZjljZmI4YTFmN2Q4MDkmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.nr-bHLGE7JIRRP3559w9Yv0II-sNniUQR1aYHSY2CHc)
 老哥稳，我试过了。 
![image](https://private-user-images.githubusercontent.com/73467479/333070136-4d2ccc41-8377-45b8-98fa-59c733ee7277.png?jwt=eyJhbGciOiJ
 
IUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MTY0NDk0ODgsIm5iZiI6MTcxNjQ0OTE4OCwicGF0aCI6Ii83MzQ2NzQ3OS8zMzMwNzAxMzYtNGQyY2NjNDEtODM3Ny00NWI4LTk4ZmEtNTljNzMzZWU3Mjc3LnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA1MjMlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNTIzVDA3MjYyOFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPThhNTQ0ODkyZGVkZTUzOWI1M2E3YzE2NDQ5ZDkxOTI0YWE2YmNkNGVjNDRlMGI4MWVjY2MwZGZmZjZhMGNlMzImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.YFxkhflS4hb1j6TWEmL2vKKIwUJqZ9YGYzA6X1nobzk)
   > 
   > 目前的代码还有几个问题:
   > 
   > 1. 你上面的语句 没有指定分隔符, 如果指定了类似于 `\t` 这样的分割符, 写入Config后会变成 `\\t`, 导致文件写入有问题.
   > 2. 由于查询hive表结构是通过`desc formatted <table_name>`的方式 然后解析sql结果. 目前发现在不同的版本中  
返回语句会略有不同, 3.1.3 版本 在 `# col_name`与真正的字段名直接没有空行, 而在`2.1.1`版本中 发现会多一个空行. 
目前的代码这块的处理逻辑需要兼容 以及优化.
   > 3. 不确定开启kerberos认证后 是否可以连通, 我这边是使用用户名密码, 可以通过在jdbc url中设置完成这个认证.
   
   problem 1, 2 solved
   problem 3, i don't have this env, can't verify about this. 
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to