Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-783

Unable to connect to Job coordinator server

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 0.10.0
    • Fix Version/s: None
    • Component/s: container
    • Labels:
      None
    • Environment:

      Linux 2.6.32-504.el6.x86_64
      redhat-release-server-6Server-6.6.0.2.el6.x86_64
      Oracle Java 1.8
      Yarn 2.7.1
      Kafka 0.8.2
      Samza 0.10

      Description

      The following repeats for every container launched until the job is failed:

      LogType:samza-container-2.log
      Log Upload Time:Wed Sep 30 18:41:45 +0000 2015
      LogLength:3465
      Log Contents:
      2015-09-30 18:26:40 SamzaContainer$ [INFO] Got container ID: 2
      2015-09-30 18:26:40 SamzaContainer$ [INFO] Got coordinator URL: http://10.49.215.34:38484/
      2015-09-30 18:26:40 SamzaContainer$ [INFO] Fetching configuration from: http://10.49.215.34:38484/
      2015-09-30 18:27:41 Util$ [ERROR] Unable to connect to Job coordinator server, received exception
      java.net.SocketTimeoutException: Read timed out
      at java.net.SocketInputStream.socketRead0(Native Method)
      at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
      at java.net.SocketInputStream.read(SocketInputStream.java:170)
      at java.net.SocketInputStream.read(SocketInputStream.java:141)
      at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
      at java.io.BufferedInputStream.read1(BufferedInputStream.java:286)
      at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
      at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:704)
      at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:647)
      at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1535)
      at sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1440)
      at java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:480)
      at org.apache.samza.util.Util$$anonfun$read$1.apply(Util.scala:131)
      at org.apache.samza.util.Util$$anonfun$read$1.apply(Util.scala:130)
      at org.apache.samza.util.ExponentialSleepStrategy.run(ExponentialSleepStrategy.scala:82)
      at org.apache.samza.util.Util$.read(Util.scala:130)
      at org.apache.samza.container.SamzaContainer$.readJobModel(SamzaContainer.scala:112)
      at org.apache.samza.container.SamzaContainer$.safeMain(SamzaContainer.scala:86)
      at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:69)
      at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala)

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              edi_bice@yahoo.com Edi Bice
            • Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated: