See 
<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/4665/display/redirect>

Changes:


------------------------------------------
[...truncated 179.28 KB...]

Traceback (most recent call last):
  File "<string>", line 31, in <module>
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 573, in run
    return self.runner.run_pipeline(self, self._options)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner.py";,>
 line 45, in run_pipeline
    return super().run_pipeline(pipeline, options)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 440, in run_pipeline
    job_service_handle.submit(proto_pipeline)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 115, in submit
    return self.run(prepare_response.preparation_id)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 242, in run
    beam_job_api_pb2.RunJobRequest(preparation_id=preparation_id))
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/abstract_job_service.py";,>
 line 120, in Run
    self._jobs[job_id].run()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 154, in run
    files={'jarfile': ('beam.jar', jar_file)})['filename'].split('/')[-1]
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 142, in post
    return self.request(requests.post, path, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 130, in request
    response = method(url, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/requests/api.py";,>
 line 117, in post
    return request('post', url, data=data, json=json, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/requests/api.py";,>
 line 61, in request
    return session.request(method=method, url=url, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/requests/sessions.py";,>
 line 529, in request
    resp = self.send(prep, **send_kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/requests/sessions.py";,>
 line 645, in send
    r = adapter.send(request, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/requests/adapters.py";,>
 line 519, in send
    raise ConnectionError(e, request=request)
requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', 
port=51461): Max retries exceeded with url: /v1/jars/upload (Caused by 
NewConnectionError('<urllib3.connection.HTTPConnection object at 
0x7fa13416d310>: Failed to establish a new connection: [Errno 111] Connection 
refused'))

kill %1 || echo "Failed to shut down Flink mini cluster"

rm -rf "$ENV_DIR"
Feb 05, 2022 6:37:55 PM org.apache.flink.runtime.blob.AbstractBlobCache close
INFO: Shutting down BLOB cache
Feb 05, 2022 6:37:55 PM 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager shutdown
INFO: Shutting down TaskExecutorLocalStateStoresManager.

if [[ "$TEST_EXIT_CODE" -eq 0 ]]; then
  echo ">>> SUCCESS"
>>> FAILURE
else
  echo ">>> FAILURE"
fi
exit $TEST_EXIT_CODE

> Task 
> :sdks:python:test-suites:portable:py36:testUberJarFlinkRunnerSaveMainSession 
> FAILED
Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connection.py";,>
 line 175, in _new_conn
    (self._dns_host, self.port), self.timeout, **extra_kw
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/util/connection.py";,>
 line 95, in create_connection
    raise err
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/util/connection.py";,>
 line 85, in create_connection
    sock.connect(sa)
ConnectionRefusedError: [Errno 111] Connection refused

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connectionpool.py";,>
 line 710, in urlopen
    chunked=chunked,
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connectionpool.py";,>
 line 398, in _make_request
    conn.request(method, url, **httplib_request_kw)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connection.py";,>
 line 239, in request
    super(HTTPConnection, self).request(method, url, body=body, headers=headers)
  File "/usr/lib/python3.6/http/client.py", line 1291, in request
    self._send_request(method, url, body, headers, encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1337, in _send_request
    self.endheaders(body, encode_chunked=encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1286, in endheaders
    self._send_output(message_body, encode_chunked=encode_chunked)
  File "/usr/lib/python3.6/http/client.py", line 1046, in _send_output
    self.send(msg)
  File "/usr/lib/python3.6/http/client.py", line 984, in send
    self.connect()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connection.py";,>
 line 205, in connect
    conn = self._new_conn()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connection.py";,>
 line 187, in _new_conn
    self, "Failed to establish a new connection: %s" % e
urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection 
object at 0x7fccbaab5cf8>: Failed to establish a new connection: [Errno 111] 
Connection refused

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/adapters.py";,>
 line 450, in send
    timeout=timeout
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/connectionpool.py";,>
 line 786, in urlopen
    method, url, error=e, _pool=self, _stacktrace=sys.exc_info()[2]
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/urllib3/util/retry.py";,>
 line 592, in increment
    raise MaxRetryError(_pool, url, error or ResponseError(cause))
urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='localhost', 
port=41045): Max retries exceeded with url: /v1/jars/upload (Caused by 
NewConnectionError('<urllib3.connection.HTTPConnection object at 
0x7fccbaab5cf8>: Failed to establish a new connection: [Errno 111] Connection 
refused',))

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "<string>", line 31, in <module>
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/pipeline.py";,>
 line 573, in run
    return self.runner.run_pipeline(self, self._options)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner.py";,>
 line 45, in run_pipeline
    return super().run_pipeline(pipeline, options)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 440, in run_pipeline
    job_service_handle.submit(proto_pipeline)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 115, in submit
    return self.run(prepare_response.preparation_id)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
 line 242, in run
    beam_job_api_pb2.RunJobRequest(preparation_id=preparation_id))
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/abstract_job_service.py";,>
 line 120, in Run
    self._jobs[job_id].run()
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 154, in run
    files={'jarfile': ('beam.jar', jar_file)})['filename'].split('/')[-1]
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 142, in post
    return self.request(requests.post, path, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py";,>
 line 130, in request
    response = method(url, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/api.py";,>
 line 117, in post
    return request('post', url, data=data, json=json, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/api.py";,>
 line 61, in request
    return session.request(method=method, url=url, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/sessions.py";,>
 line 529, in request
    resp = self.send(prep, **send_kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/sessions.py";,>
 line 645, in send
    r = adapter.send(request, **kwargs)
  File 
"<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/build/gradleenv/2022703440/lib/python3.6/site-packages/requests/adapters.py";,>
 line 519, in send
    raise ConnectionError(e, request=request)
requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', 
port=41045): Max retries exceeded with url: /v1/jars/upload (Caused by 
NewConnectionError('<urllib3.connection.HTTPConnection object at 
0x7fccbaab5cf8>: Failed to establish a new connection: [Errno 111] Connection 
refused',))

kill %1 || echo "Failed to shut down Flink mini cluster"

rm -rf "$ENV_DIR"

>>> FAILURE
if [[ "$TEST_EXIT_CODE" -eq 0 ]]; then
  echo ">>> SUCCESS"
else
  echo ">>> FAILURE"
fi
exit $TEST_EXIT_CODE

FAILURE: Build completed with 6 failures.

1: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 335

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py36:testJavaJarCreatorFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

2: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 335

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:testJavaJarCreatorFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

3: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 363

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:testUberJarFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

4: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 363

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py36:testUberJarFlinkRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

5: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 363

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py37:testUberJarFlinkRunnerSaveMainSession'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

6: Task failed with an exception.
-----------
* Where:
Script 
'<https://ci-beam.apache.org/job/beam_PostCommit_PortableJar_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
 line: 363

* What went wrong:
Execution failed for task 
':sdks:python:test-suites:portable:py36:testUberJarFlinkRunnerSaveMainSession'.
> Process 'command 'sh'' finished with non-zero exit value 1

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 8.0.

You can use '--warning-mode all' to show the individual deprecation warnings 
and determine if they come from your own scripts or plugins.

See 
https://docs.gradle.org/7.3.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 37m 22s
156 actionable tasks: 107 executed, 44 from cache, 5 up-to-date

Publishing build scan...
https://gradle.com/s/qxxa2542s32m6

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to