[
https://issues.apache.org/jira/browse/HUDI-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476358#comment-17476358
]
Raymond Xu edited comment on HUDI-3050 at 3/30/22, 3:44 AM:
------------------------------------------------------------
[~kinger0610] On which Hudi version do you hit this? Looking at the code, the
exception is thrown when the write client is trying to start the timeline
service without the hostname so the dummy host is generated, which fails. In
this case, maybe "google.com" cannot be resolved so it failed. There is one
fix around that on master:
[https://github.com/apache/hudi/pull/4355/|https://github.com/apache/hudi/pull/4355/files.]
Could you try it?
was (Author: guoyihua):
[~kinger0610] On which Hudi version do you hit this? Looking at the code, the
exception is thrown when the write client is trying to start the timeline
service without the hostname so the dummy host is generated, which fails. In
this case, maybe "google.com" cannot be resolved so it failed. There is one
fix around that on master: [https://github.com/apache/hudi/pull/4355/files.]
Could you try it?
> Unable to find server port
> --------------------------
>
> Key: HUDI-3050
> URL: https://issues.apache.org/jira/browse/HUDI-3050
> Project: Apache Hudi
> Issue Type: Bug
> Components: kafka-connect
> Reporter: Di Wang
> Assignee: Ethan Guo
> Priority: Critical
> Labels: user-support-issues
> Fix For: 0.11.0
>
>
>
> {code:java}
> // code placeholder
> Caused by: org.apache.hudi.exception.HoodieException: Unable to find server
> port
> at
> org.apache.hudi.common.util.NetworkUtils.getHostname(NetworkUtils.java:41)
> at
> org.apache.hudi.client.embedded.EmbeddedTimelineService.setHostAddr(EmbeddedTimelineService.java:104)
> at
> org.apache.hudi.client.embedded.EmbeddedTimelineService.<init>(EmbeddedTimelineService.java:55)
> at
> org.apache.hudi.client.embedded.EmbeddedTimelineServerHelper.startTimelineService(EmbeddedTimelineServerHelper.java:70)
> at
> org.apache.hudi.client.embedded.EmbeddedTimelineServerHelper.createEmbeddedTimelineService(EmbeddedTimelineServerHelper.java:51)
> at
> org.apache.hudi.client.AbstractHoodieClient.startEmbeddedServerView(AbstractHoodieClient.java:109)
> at
> org.apache.hudi.client.AbstractHoodieClient.<init>(AbstractHoodieClient.java:77)
> at
> org.apache.hudi.client.AbstractHoodieWriteClient.<init>(AbstractHoodieWriteClient.java:139)
> at
> org.apache.hudi.client.AbstractHoodieWriteClient.<init>(AbstractHoodieWriteClient.java:127)
> at
> org.apache.hudi.client.HoodieFlinkWriteClient.<init>(HoodieFlinkWriteClient.java:97)
> at
> org.apache.hudi.util.StreamerUtil.createWriteClient(StreamerUtil.java:402)
> at
> org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:166)
> at
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:198)
> at
> org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:85)
> ... 24 common frames omitted
> Caused by: java.net.ConnectException: Connection timed out (Connection timed
> out)
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
> at
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
> at
> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at java.net.Socket.connect(Socket.java:538)
> at
> org.apache.hudi.common.util.NetworkUtils.getHostname(NetworkUtils.java:38)
> ... 37 common frames omitted
> {code}
> it happens an exception . i think relative code is is below,
> https://issues.apache.org/jira/browse/HUDI-3037
> s = new Socket();
> // see
> https://stackoverflow.com/questions/9481865/getting-the-ip-address-of-the-current-machine-using-java
> // for details.
> s.connect(new InetSocketAddress("google.com", 80));
> return s.getLocalAddress().getHostAddress();
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
