See
<https://ci-beam.apache.org/job/beam_PreCommit_GoPortable_Cron/1348/display/redirect?page=changes>
Changes:
[noreply] Minor: Add 2.38.0 section to CHANGES.md (#16804)
------------------------------------------
[...truncated 411.38 KB...]
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e7)+(e8))+(n8/Write)
INFO:root:severity: INFO
timestamp {
seconds: 1644516907
nanos: 588087553
}
message: "Connecting via grpc @ localhost:43489 ..."
instruction_id: "bundle_155"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e1)+(e2))+(n2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Created
Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f1fb3543fa0> for environment JfcrZfqpFYbeam:env:docker:v1
(beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.38.0.dev')
INFO:apache_beam.runners.portability.local_job_service:Successfully completed
job in 11.468457698822021 seconds.
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Attempting
to pull image apache/beam_java8_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.local_job_service:Successfully completed
job in 11.521981954574585 seconds.
Error response from daemon: manifest for apache/beam_java8_sdk:2.38.0.dev not
found
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Unable to
pull image apache/beam_java8_sdk:2.38.0.dev, defaulting to local image if it
exists
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Waiting for
docker to start up. Current status is running
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Docker
container is running. container_id =
b'72ac7d8bc32adff5a6ffaa99d1554b02a704b39c4a0ee6e2a2c434627f0dd2e4', worker_id
= worker_34
INFO:apache_beam.runners.portability.abstract_job_service:Running job
'go-testwindowsums_gbk-21a40162-e64c-43c3-ba04-243ac00389c5'
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.8 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.8_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function annotate_downstream_side_inputs at 0x7f1fb317de50>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f1fb317df70> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f1fb31804c0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f1fb3180550> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f1fb3180700> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f1fb3180790> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f1fb31808b0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f1fb3180940> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f1fb31809d0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f1fb3180a60> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f1fb3180ca0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f1fb3180c10> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f1fb3180d30> ====================
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
control server on port 40429
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
data server on port 40513
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
state server on port 45813
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
logging server on port 34131
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Created
Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f1fd0782cd0> for environment go (beam:env:docker:v1,
b'\n\x16apache/beam_go_sdk:dev')
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Attempting
to pull image apache/beam_go_sdk:dev
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
(n2/Read)+(JfcrZfqpFYExternal/Write/1)
Error response from daemon: manifest for apache/beam_go_sdk:dev not found
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Unable to
pull image apache/beam_go_sdk:dev, defaulting to local image if it exists
INFO:root:severity: INFO
timestamp {
seconds: 1644516912
nanos: 649000000
}
message: "Fn Harness started"
log_location: "org.apache.beam.fn.harness.FnHarness"
thread: "1"
INFO:root:severity: INFO
timestamp {
seconds: 1644516912
nanos: 815000000
}
message: "Entering instruction processing loop"
log_location: "org.apache.beam.fn.harness.FnHarness"
thread: "1"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e3)+(e4))+(n4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
(n4/Read)+(JfcrZfqpFYExternal/Write/0)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
(JfcrZfqpFYExternal/Read)+(JfcrZfqpFYExternal.out/Write)
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Waiting for
docker to start up. Current status is running
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Docker
container is running. container_id =
b'6b21407ab16dbf8235838b029ec231b012d31a034285d89c9d79040636893ff8', worker_id
= worker_35
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((JfcrZfqpFYExternal.out/Read)+(e6))+(n6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((e9)+(e10))+(n10/Write))+(n11/Write))+(n12/Write)
INFO:root:severity: INFO
timestamp {
seconds: 1644516913
nanos: 435285219
}
message: "Connecting via grpc @ localhost:33839 ..."
instruction_id: "bundle_162"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running (e11)+(e12)
WARNING:root:severity: WARN
timestamp {
seconds: 1644516913
nanos: 450397031
}
message: "forcing DataChannel[localhost:43489] reconnection on port
{localhost:43489} due to EOF"
instruction_id: "bundle_155"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go:118"
WARNING:root:severity: WARN
timestamp {
seconds: 1644516913
nanos: 450422432
}
message: "DataChannel.read localhost:43489 closed"
instruction_id: "bundle_155"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go:258"
INFO:root:severity: INFO
timestamp {
seconds: 1644516913
nanos: 526404263
}
message: "Connecting via grpc @ localhost:40429 ..."
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:root:severity: INFO
timestamp {
seconds: 1644516913
nanos: 526604560
}
message: "Connecting via grpc @ localhost:34131 ..."
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
(((((((((e1)+(e2))+(e36))+(e25))+(e14))+(e3))+(GBK/Session/CoGBK/Write))+(GBK/Sliding/CoGBK/Write))+(GBK/SlidingFixed/CoGBK/Write))+(GBK/Fixed/CoGBK/Write)
INFO:root:severity: INFO
timestamp {
seconds: 1644516914
nanos: 433279765
}
message: "Connecting via grpc @ localhost:40513 ..."
instruction_id: "bundle_164"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((GBK/Session/CoGBK/Read)+(e38))+(e39))+(e40))+(n43/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((GBK/Sliding/CoGBK/Read)+(e27))+(e28))+(e29))+(n31/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((GBK/Fixed/CoGBK/Read)+(e5))+(e6))+(e7))+(n7/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e8)+(e9))+(n9/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((e10)+(e11))+(n13/Write))+(n11/Write))+(n12/Write)
INFO:root:severity: INFO
timestamp {
seconds: 1644516914
nanos: 485991349
}
message: "Connecting via grpc @ localhost:45813 ..."
instruction_id: "bundle_169"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/harness.go:539"
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e30)+(e31))+(n33/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((e32)+(e33))+(n37/Write))+(n35/Write))+(n36/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running (e12)+(e13)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((GBK/SlidingFixed/CoGBK/Read)+(e16))+(e17))+(e18))+(n19/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e19)+(e20))+(n21/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((e21)+(e22))+(n24/Write))+(n25/Write))+(n23/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running (e23)+(e24)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((e41)+(e42))+(n45/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((e43)+(e44))+(n49/Write))+(n48/Write))+(n47/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running (e45)+(e46)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running (e34)+(e35)
WARNING:root:severity: WARN
timestamp {
seconds: 1644516914
nanos: 577319146
}
message: "forcing DataChannel[localhost:40513] reconnection on port
{localhost:40513} due to EOF"
instruction_id: "bundle_164"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go:118"
WARNING:root:severity: WARN
timestamp {
seconds: 1644516914
nanos: 577332192
}
message: "DataChannel.read localhost:40513 closed"
instruction_id: "bundle_164"
log_location:
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Cron/src/sdks/go/pkg/beam/core/runtime/harness/datamgr.go:258"
INFO:apache_beam.runners.portability.local_job_service:Successfully completed
job in 5.140087842941284 seconds.
INFO:apache_beam.runners.portability.local_job_service:Successfully completed
job in 16.488825798034668 seconds.
Feb 10, 2022 6:15:15 PM org.apache.beam.sdk.expansion.service.ExpansionService
expand
INFO: Expanding 'External' with URN 'beam:transforms:xlang:test:gbk'
Feb 10, 2022 6:15:15 PM
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
payloadToConfig
WARNING: Configuration class
'org.apache.beam.sdk.testing.expansion.TestExpansionService$TestTransformRegistrar$EmptyConfiguration'
has no schema registered. Attempting to construct with setter approach.
Feb 10, 2022 6:15:15 PM
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
payloadToConfig
WARNING: Configuration class
'org.apache.beam.sdk.testing.expansion.TestExpansionService$TestTransformRegistrar$EmptyConfiguration'
has no schema registered. Attempting to construct with setter approach.
INFO:apache_beam.runners.portability.abstract_job_service:Running job
'go-testvalidatewindowedsideinputs-0d7fa9cd-9b3f-49f4-8853-0a45821e5c2d'
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.8 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.8_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function annotate_downstream_side_inputs at 0x7f1fb317de50>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f1fb317df70> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f1fb31804c0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f1fb3180550> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f1fb3180700> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f1fb3180790> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f1fb31808b0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f1fb3180940> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f1fb31809d0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f1fb3180a60> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f1fb3180ca0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f1fb3180c10> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f1fb3180d30> ====================
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
control server on port 45115
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
data server on port 42471
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
state server on port 42543
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
logging server on port 41727
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Created
Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f1fb36d0730> for environment go (beam:env:docker:v1,
b'\n\x16apache/beam_go_sdk:dev')
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Attempting
to pull image apache/beam_go_sdk:dev
Error response from daemon: manifest for apache/beam_go_sdk:dev not found
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Unable to
pull image apache/beam_go_sdk:dev, defaulting to local image if it exists
INFO:apache_beam.runners.portability.abstract_job_service:Running job
'go-testxlang_groupby-eb4c7b17-42ba-46cc-b2dc-80ab3ef1a82e'
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.8 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.8_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function annotate_downstream_side_inputs at 0x7f1fb317de50>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f1fb317df70> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f1fb31804c0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f1fb3180550> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f1fb3180700> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f1fb3180790> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f1fb31808b0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f1fb3180940> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f1fb31809d0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f1fb3180a60> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f1fb3180ca0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f1fb3180c10> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f1fb3180d30> ====================
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
control server on port 45081
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
data server on port 42443
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
state server on port 41361
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:starting
logging server on port 40213
INFO:apache_beam.runners.portability.fn_api_runner.worker_handlers:Created
Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler
object at 0x7f1fd0749a90> for environment go (beam:env:docker:v1,
b'\n\x16apache/beam_go_sdk:dev')
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-8' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy133.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1211)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1203)
at hudson.Launcher$ProcStarter.join(Launcher.java:523)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:803)
at hudson.model.Build$BuildExecution.build(Build.java:197)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:513)
at hudson.model.Run.execute(Run.java:1906)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:97)
at hudson.model.Executor.run(Executor.java:429)
Caused by: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:118)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:101)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:93)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:74)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:104)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-8 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
