在PHP中通过Hive / Thrift查询数据库不起作用

我正在尝试通过PHP中的Hive / Thrift查询数据库.但是,我经常收到一个错误:

TSocket: timed out reading 4 bytes from XYZ

我正在使用来自的代码

https://cwiki.apache.org/Hive/hiveclient.html#HiveClient-PHP

以及这个PHP Thrift客户端

https://github.com/garamon/php-thrift-hive-client

我的代码:

<?php

$socket    = new TSocket( 'XYZ', 12345 );

$socket->setSendTimeout(30 * 1000);
$socket->setRecvTimeout(30 * 1000);

$transport = new TBufferedTransport( $socket, 1024, 1024 );
$protocol  = new TBinaryProtocol( $transport );

$client    = new ThriftHiveClientEx( $protocol );

$transport->open();

$client->execute("my query");

?>

注意 – 我可以通过控制台(telnet命令)连接XYZ.

我会赞美任何帮助.谢谢.

解决方法:

当从那些完全相同的资源开始时,我遇到了类似的问题.事实证明,代码无法识别它是否已超时或是否阻塞端口.我发现这篇文章对我有所帮助:

https://issues.apache.org/jira/browse/THRIFT-347

在您的TSocket.php代码(garamon_base_dir / lib / transport)中,您必须编辑大约223到236行.

在哪里说:

if( $buf === FALSE || $buf === '' ) { ...
and
if( $md['timed_out'] ) { ...
and then again
if( $md[timed_out'] ) { ...

改为(分别):

if( $buf === FALSE ) { ...
and
if( true === $md['timed_out'] && false === $md['blocked'] )
and finally 
if( true === $md['timed_out'] && false === $md['blocked'] )

然后它在此修复后开始工作.祝好运!

上一篇:如何使用python thrift客户端用maxversions扫描hbase表?


下一篇:php – UUID cassandra排序?