Jeffrey(Xilang) Yan

[LIVY-621]add dynamic service discovery for thrift server

12

## What changes were proposed in this pull request? Add config and implementation to allow publish livy thrift server to zookeeper. Configuration information are consistent with hiveserver2 for convenience. Publish...

## What changes were proposed in this pull request? When impersonation is disabled, hadoop UGI user will always be livy server user, there is no way to get actually owner...

MetaQ接收数据客户端进入死循环

2

情况偶现，症状就是程序不退出，进入死循环，CPU使用率100%，关键的堆栈如下： "Thread-48" daemon prio=10 tid=0x00007f47a8048000 nid=0x73d2 in Object.wait() [0x00007f4796dec000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.Thread.join(Thread.java:1289) - locked (a java.lang.Thread) at com.taobao.metamorphosis.client.consumer.SimpleFetchManager.interruptRunners(SimpleFetchManager.java:146) at com.taobao.metamorphosis.client.consumer.SimpleFetchManager.stopFetchRunner(SimpleFetchManager.java:128) at com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.shutdown(SimpleMessageConsumer.java:162) -...

SelectorManager增加stopped状态

1

在stopped状态，await应该异常退出，否则则进入是死循环

### Description Hi Team, I am here to ask for a feature to decommission a worker node, which means shutdown worker node gracefully, by 1, stop accept new task request,...