小编Car*_*l H的帖子

使用phoenix sqlline连接hbase.在SecureCRT终端上,我只能看到有三列超过10列的表.我想显示表的所有列以测试数据是否正常.是否应该设置任何配置？

0: jdbc:phoenix:10.35.66.72:2181:/hbase> select * from WL.MSGCENTER_PUSHMESSAGE;
+--------------+---------+---------------------------------------------------------------------------------------------------------------------------------------------+
|    PLANID    | BATCHID |                                                                                                                                                 |
+--------------+---------+---------------------------------------------------------------------------------------------------------------------------------------------+
| 520          | 1       | C285995F-AB23-4CF0-A9A4-F29175E9CD36                                                                                                           |
+--------------+---------+---------------------------------------------------------------------------------------------------------------------------------------------+

选择1行(0.805秒)

起初集群中的所有代理都可以正常启动和工作，但有时其中一个代理会遇到问题。并且会出现一些现象：

• 整个集群挂了，生产者和消费者也不工作，因此网络流量从监视器降为零；
• 使用kafka-topic.sh描述topic消息，每个副本都可以，即使是异常brokerid，zk中的信息也正常；
• 从/proc/sys/fs/file-nr读取的异常broker上的文件描述编号逐渐增加
• netstat 代理监听端口 9092 显示大量“CLOSE_WAIT”状态

以下是其他broker的错误日志，异常broker日志看不到任何异常。

[2019-04-15 18:10:25,243] INFO [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error sending fetch request (sessionId=289971597, epoch=1254343) t
o node 1: java.io.IOException: Connection to 1 was disconnected before the response was read. (org.apache.kafka.clients.FetchSessionHandler)
[2019-04-15 18:10:25,244] WARN [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error in response for fetch request (type=FetchRequest, replicaId=
0, maxWait=500, minBytes=1, maxBytes=10485760, fetchData={atm_error_intf-7=(offset=538244, logStartOffset=5319, maxBytes=1048576, currentLeaderEpoch=Op
tional[13])}, isolationLevel=READ_UNCOMMITTED, toForget=, metadata=(sessionId=289971597, epoch=1254343)) (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to 1 was disconnected before the response was read
        at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:97) …

在我看来，随着密钥的发展，“哈希冲突”会越来越频繁地发生。我不知道同一个槽上的那些键是否存储在单链表中，那么读取性能会受到影响，尤其是陈旧的记录？

运行follow命令向yarn提交作业，但不期望分配任务管理器的数量。集群有足够的资源<220vcores, 720G mem>

/data/clusterserver/flink-1.7.2/bin/flink run -m yarn-cluster -yn 4 -ys 2  /data/clusterserver/flink-1.7.2/examples/batch/WordCount.jar --input hdfs:///tmp/wordcount.txt --output hdfs:///tmp/count.result

2019-04-10 15:04:57,397 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2019-04-10 15:04:57,397 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
2019-04-10 15:04:57,405 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - The argument yn is deprecated in will be ignored.
2019-04-10 15:04:57,405 INFO  org.apache.flink.yarn.cli.FlinkYarnSessionCli                 - The …

我不得不说官方网站提供的信息很少，无法清楚地了解rabbitmq。

官方网站建议使用三个节点来构建集群。这样做的原因是什么？我想它不喜欢Zookeeper，它需要奇数节点进行法定人数和选举主人。

此外，使用非HA集群，提高性能的优势是什么？如果该队列所在的节点驻留下来，则该队列不起作用。因此，对于所有情况，都需要将群集设置为镜像队列并自动同步吗？