-
Notifications
You must be signed in to change notification settings - Fork 594
Add support for SSH sock proxying to scheduler #1456
Conversation
|
||
# SSH tunnel host | ||
heron.scheduler.tunnel.host: "my.tunnel.host" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add a new line at the end?
heron.statemgr.tunnel.verify.count: 10 | ||
|
||
# SSH tunnel host | ||
heron.statemgr.tunnel.host: "my.tunnel.host" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Add a new line at the end?
private NetworkUtils() { | ||
} | ||
|
||
public static class TunnelConfig { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we make it separate class or a nested class?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I could go either way on this. I made it an inner class since it's tightly couple to, and only intended for, NetworkUtils
but if we think it should stand on it's own I'm ok with it.
looks good to me. 👍 |
* Add newlines at the end of configs * Fix unit test
In #1412 we ran into a need for socks proxying from the scheduler to TMaster. This patch fixes that by creating two tunneling approaches: port forwarding (existing behavior required for ZK since ZK client doesn't support proxies) and sock proxy (preferred approach for tunneling HTTP).
The previous tunneling approach was written specifically for ZK. This pulls the tunneling configs out of ZK and into it's own config loader that can be used by state manager, scheduler, etc. See
NetworkUtils
andShellUtils
for the bulk of the changes.Also removed a few occurances of
verbose
flags, which were not used and should be replaces by the logging level controls that now handle that.Related to #1292.