Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7170

ExpansionServer throws exception when port is retrieved after close

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      The ExpansionServer can throw the following exception after shutdown because the port getter retrieves the port dynamically from the underlying service:

      [Test worker] ERROR org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver - Error while closing the Expansion Service.
      java.lang.IllegalStateException: Already terminated
      	at org.apache.beam.vendor.grpc.v1p13p1.com.google.common.base.Preconditions.checkState(Preconditions.java:444)
      	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl.getPort(ServerImpl.java:174)
      	at org.apache.beam.runners.core.construction.expansion.ExpansionServer.getPort(ExpansionServer.java:66)
      	at org.apache.beam.runners.fnexecution.jobsubmission.JobServerDriver.stop(JobServerDriver.java:200)
      	at sun.reflect.GeneratedMethodAccessor173.invoke(Unknown Source)
      	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.lang.reflect.Method.invoke(Method.java:498)
      	at 

        Attachments

          Activity

            People

            • Assignee:
              mxm Maximilian Michels
              Reporter:
              mxm Maximilian Michels

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 0.5h
                0.5h

                  Issue deployment