JustFeng opened a new pull request, #7208:
URL: https://github.com/apache/kyuubi/pull/7208
affected version pypi pyhive package 0.6.5 , 0.7.0
### Why are the changes needed?
using I using pyhive connect to kyuubi 1.7/1.10.0 and submit SQL to
Spark3.2/3.5 in async mode
some times when I fetch_logs() thrift results response columns could be None
assert get length may cause TypeError: object of type 'NoneType' has no len()
traceback is
> File "/root/app/dataverse/operator/sqltask.py", line 225, in
execute_single_hql
for message in cursor.fetch_logs():
File "/usr/local/lib/python3.10/dist-packages/pyhive/hive.py", line 537,
in fetch_logs
assert len(response.results.columns) == 1, response.results.columns
TypeError: object of type 'NoneType' has no len()
### How was this patch tested?
we deploy test env using special build kyuubi server, ensure
FetchResults.results.columns returns null
after this patch fetch_logs() will not cause any Exception
and then we tested in normal release version of kyuubi too , fetch_logs()
works fine
-> finally we tested in production environment for more than 1000 task
instance
### Was this patch authored or co-authored using generative AI tooling?
No
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
