See 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/3395/display/redirect?page=changes>

Changes:

[noreply] ML notebook formatting and text updates (#24437)

[noreply] lint fixes (#24455)

[noreply] Bump cloud.google.com/go/pubsub from 1.26.0 to 1.27.0 in /sdks 
(#24450)

[noreply] Install venv dependencies in local env setup (#24461)

[noreply] Don't set BigQuery services in schema transform configuration (#24316)

[noreply] Apache playground blog (#24431)

[noreply] Sort SchemaTransform configuration schema fields by name to establish


------------------------------------------
[...truncated 905.36 KB...]
        heartbeat.interval.ms = 3000
        interceptor.classes = []
        internal.leave.group.on.close = true
        isolation.level = read_uncommitted
        key.deserializer = class 
org.apache.kafka.common.serialization.ByteArrayDeserializer
        max.partition.fetch.bytes = 1048576
        max.poll.interval.ms = 300000
        max.poll.records = 500
        metadata.max.age.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        partition.assignment.strategy = [class 
org.apache.kafka.clients.consumer.RangeAssignor]
        receive.buffer.bytes = 524288
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        request.timeout.ms = 30000
        retry.backoff.ms = 100
        sasl.client.callback.handler.class = null
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.mechanism = GSSAPI
        security.protocol = PLAINTEXT
        security.providers = null
        send.buffer.bytes = 131072
        session.timeout.ms = 10000
        ssl.cipher.suites = null
        ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
        ssl.endpoint.identification.algorithm = https
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.protocol = TLS
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        value.deserializer = class 
org.apache.kafka.common.serialization.ByteArrayDeserializer

    Dec 01, 2022 6:48:41 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo 
<init>
    INFO: Kafka version: 2.4.1
    Dec 01, 2022 6:48:41 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo 
<init>
    INFO: Kafka commitId: c57222ae8cd7866b
    Dec 01, 2022 6:48:41 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo 
<init>
    INFO: Kafka startTimeMs: 1669920521734
    Dec 01, 2022 6:48:42 PM org.apache.kafka.clients.Metadata update
    INFO: [Consumer clientId=consumer-1, groupId=null] Cluster ID: 
ILv8o3eZTKCZl6IeCA9lQQ
    Dec 01, 2022 6:48:42 PM org.apache.beam.sdk.io.kafka.KafkaUnboundedSource 
split
    INFO: Partitions assigned to split 0 (total 1): beam-sdf-0
    Dec 01, 2022 6:48:42 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
    INFO: Adding Read from unbounded 
Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/Read(KafkaUnboundedSource)/StripIds as 
step s2
    Dec 01, 2022 6:48:42 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
    INFO: Adding Measure read time as step s3
    Dec 01, 2022 6:48:42 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
    INFO: Adding Map records to strings/Map as step s4
    Dec 01, 2022 6:48:42 PM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
    INFO: Adding Counting element as step s5
    Dec 01, 2022 6:48:42 PM org.apache.beam.runners.dataflow.DataflowRunner run
    INFO: Dataflow SDK version: 2.44.0-SNAPSHOT
    Dec 01, 2022 6:48:42 PM org.apache.beam.runners.dataflow.DataflowRunner run
    INFO: To access the Dataflow monitoring console, please navigate to 
https://console.cloud.google.com/dataflow/jobs/us-central1/2022-12-01_10_48_42-3079188003942206995?project=apache-beam-testing
    Dec 01, 2022 6:48:42 PM org.apache.beam.runners.dataflow.DataflowRunner run
    INFO: Submitted job: 2022-12-01_10_48_42-3079188003942206995
    Dec 01, 2022 6:48:42 PM org.apache.beam.runners.dataflow.DataflowRunner run
    INFO: To cancel the job using the 'gcloud' tool, run:
    > gcloud dataflow jobs --project=apache-beam-testing cancel 
--region=us-central1 2022-12-01_10_48_42-3079188003942206995
    Dec 01, 2022 6:48:49 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    WARNING: 2022-12-01T18:48:48.133Z: The workflow name is not a valid Cloud 
Label. Labels applied to Cloud resources (such as GCE Instances) for monitoring 
will be labeled with this modified job name: 
kafkaioit0testkafkaioreadsandwritescorrectlyinstreaming-je-iq13. For the best 
monitoring experience, please name your job with a valid Cloud Label. For 
details, see: 
https://cloud.google.com/compute/docs/labeling-resources#restrictions
    Dec 01, 2022 6:49:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:00.329Z: Your project already contains 100 
Dataflow-created metric descriptors, so new user metrics of the form 
custom.googleapis.com/* will not be created. However, all user metrics are also 
available in the metric dataflow.googleapis.com/job/user_counter. If you rely 
on the custom metrics, you can delete old / unused metric descriptors. See 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.list
 and 
https://developers.google.com/apis-explorer/#p/monitoring/v3/monitoring.projects.metricDescriptors.delete
    Dec 01, 2022 6:49:04 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:03.619Z: Worker configuration: e2-standard-2 in 
us-central1-a.
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:04.932Z: Expanding SplittableParDo operations into 
optimizable parts.
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:04.970Z: Expanding CollectionToSingleton operations 
into optimizable parts.
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.016Z: Expanding CoGroupByKey operations into 
optimizable parts.
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.042Z: Expanding SplittableProcessKeyed operations 
into optimizable parts.
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.070Z: Expanding GroupByKey operations into 
streaming Read/Write steps
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.093Z: Lifting ValueCombiningMappingFns into 
MergeBucketsMappingFns
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.158Z: Fusing adjacent ParDo, Read, Write, and 
Flatten operations
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.226Z: Fusing consumer Read from unbounded 
Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/ParDo(GenerateKafkaSourceDescriptor)/ParMultiDo(GenerateKafkaSourceDescriptor)
 into Read from unbounded Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/Impulse
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.249Z: Fusing consumer 
Read-from-unbounded-Kafka-KafkaIO-Read-ReadFromKafkaViaSDF-KafkaIO-ReadSourceDescriptors-ParDo-Unbou/PairWithRestriction
 into Read from unbounded 
Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/ParDo(GenerateKafkaSourceDescriptor)/ParMultiDo(GenerateKafkaSourceDescriptor)
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.282Z: Fusing consumer 
Read-from-unbounded-Kafka-KafkaIO-Read-ReadFromKafkaViaSDF-KafkaIO-ReadSourceDescriptors-ParDo-Unbou/SplitWithSizing
 into 
Read-from-unbounded-Kafka-KafkaIO-Read-ReadFromKafkaViaSDF-KafkaIO-ReadSourceDescriptors-ParDo-Unbou/PairWithRestriction
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.316Z: Fusing consumer Read from unbounded 
Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/KafkaIO.ReadSourceDescriptors/MapElements/Map/ParMultiDo(Anonymous)
 into 
Read-from-unbounded-Kafka-KafkaIO-Read-ReadFromKafkaViaSDF-KafkaIO-ReadSourceDescriptors-ParDo-Unbou/ProcessElementAndRestrictionWithSizing
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.340Z: Fusing consumer Measure read 
time/ParMultiDo(TimeMonitor) into Read from unbounded 
Kafka/KafkaIO.Read.ReadFromKafkaViaSDF/KafkaIO.ReadSourceDescriptors/MapElements/Map/ParMultiDo(Anonymous)
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.375Z: Fusing consumer Map records to 
strings/Map/ParMultiDo(Anonymous) into Measure read time/ParMultiDo(TimeMonitor)
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.398Z: Fusing consumer Counting 
element/ParMultiDo(Counting) into Map records to 
strings/Map/ParMultiDo(Anonymous)
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:05.469Z: Running job using Streaming Engine
    Dec 01, 2022 6:49:07 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:49:06.698Z: Starting 5 ****s in us-central1-a...
    Dec 01, 2022 6:50:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:50:00.195Z: Autoscaling: Raised the number of ****s to 
3 so that the pipeline can catch up with its backlog and keep up with its input 
rate.
    Dec 01, 2022 6:50:00 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:50:00.225Z: Autoscaling: Resized **** pool to 3, though 
goal was 5.  This could be a quota issue.
    Dec 01, 2022 6:50:12 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:50:10.805Z: Autoscaling: Raised the number of ****s to 
5 so that the pipeline can catch up with its backlog and keep up with its input 
rate.
    Dec 01, 2022 6:51:06 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:51:05.765Z: All ****s have finished the startup 
processes and began to receive work requests.
    Dec 01, 2022 6:51:09 PM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
    INFO: 2022-12-01T18:51:06.424Z: Workers have started successfully.
    Dec 01, 2022 7:03:42 PM 
org.apache.beam.runners.dataflow.DataflowPipelineJob waitUntilFinish
    WARNING: No terminal state was returned within allotted timeout. State 
value RUNNING

Gradle Test Executor 2 finished executing tests.

> Task :sdks:java:io:kafka:integrationTest FAILED

org.apache.beam.sdk.io.kafka.KafkaIOIT > 
testKafkaIOReadsAndWritesCorrectlyInStreaming FAILED
    java.lang.AssertionError: expected:<100000> but was:<132815>
        at org.junit.Assert.fail(Assert.java:89)
        at org.junit.Assert.failNotEquals(Assert.java:835)
        at org.junit.Assert.assertEquals(Assert.java:647)
        at org.junit.Assert.assertEquals(Assert.java:633)
        at 
org.apache.beam.sdk.io.kafka.KafkaIOIT.testKafkaIOReadsAndWritesCorrectlyInStreaming(KafkaIOIT.java:207)

1 test completed, 1 failed
Finished generating test XML results (0.029 secs) into: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/sdks/java/io/kafka/build/test-results/integrationTest>
Generating HTML test report...
Finished generating test html results (0.034 secs) into: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/sdks/java/io/kafka/build/reports/tests/integrationTest>
:sdks:java:io:kafka:integrationTest (Thread[Execution **** Thread 5,5,main]) 
completed. Took 20 mins 22.732 secs.
Resolve mutations for 
:runners:google-cloud-dataflow-java:cleanUpDockerJavaImages (Thread[Execution 
**** Thread 6,5,main]) started.
Resolve mutations for 
:runners:google-cloud-dataflow-java:cleanUpDockerJavaImages (Thread[Execution 
**** Thread 6,5,main]) completed. Took 0.0 secs.
:runners:google-cloud-dataflow-java:cleanUpDockerJavaImages (Thread[Execution 
**** Thread 2,5,main]) started.

> Task :runners:google-cloud-dataflow-java:cleanUpDockerJavaImages
Custom actions are attached to task 
':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages'.
Caching disabled for task 
':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages' because:
  Gradle would require more information to cache this task
Task ':runners:google-cloud-dataflow-java:cleanUpDockerJavaImages' is not 
up-to-date because:
  Task has not declared any outputs despite executing actions.
Starting process 'command 'docker''. Working directory: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/runners/google-cloud-dataflow-java>
 Command: docker rmi --force 
us.gcr.io/apache-beam-testing/java-postcommit-it/java:20221201183621
Successfully started process 'command 'docker''
Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20221201183621
Untagged: 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95
Deleted: sha256:3b03368e5a32a25c7cb8db4461393889302d7bd29c65c3ffc416d4f4f7cfdfbf
Deleted: sha256:0801ff3cdc88693aecf9cbdd65ddd670725f7c092affe7534adf7c83b982bd6e
Deleted: sha256:398ac99753fe46cdc29150c5f8a058146fd09ca60ffa061a400c819d691cdf21
Deleted: sha256:8f5b18c516c92809e69fe8fb810c8d12f9add4d84dd6fa4b31050e43100123e4
Deleted: sha256:5d225429ad69b5bdcfbab355e4edcb685f1e677f8b179436b1714aac6d608132
Deleted: sha256:7c2da05d93e7b50f91f9a34acd7e2981437d7cab67b6c9172b287c78eaebfda8
Deleted: sha256:909489a27889e1efdf753dff01b8dcc43c95f5e59470045b8674722f725b8bd8
Deleted: sha256:8113e1a6458b041ed19a190e77cde608fa53f6fba23e08f8e41d6aa220b9ea21
Deleted: sha256:f22b929413fc5a370e32d68c333e6eae1d663a0a1d9927cc055c19c28a298bed
Deleted: sha256:8183734d8145ffd32fb0cb93a742c763126a115dfe6bf44570231da4e1894d7b
Deleted: sha256:1d524c75cc20fd254fbe6f754f1e8b815401d21040557b7adced97a5622d99e4
Deleted: sha256:c87ed5e16afc59d7f190e2c179cfd20c07eed9ba2180ff010e54ddeb2d298875
Deleted: sha256:276f77dcee3a36d02728080e70da78cc4a67d8452bde0e3f5336df9d708fb827
Deleted: sha256:fe815877d69c6dabba9694610790008416213629fcaa99c359ba756d5fb5e472
Deleted: sha256:926b2b0e82a23c4d33515cc458c676cdd4061c2e26b965ecc974a26a173ea054
Deleted: sha256:1af305e8b0a76eaf8b390fcd8a755936c5ec555db89afb2db5dfee83d52be80c
Deleted: sha256:5fd5a30783343733faa609f6575931ec0b5c71fddd5d1fa42aa69578bb44ad3c
Deleted: sha256:f0ebec446ceac808bb33c0f3bc7eeeab4444689d09a63f5d63e1a7eca036315d
Deleted: sha256:c29fa159870a115ec25e7a318401ee23c06e1aa16603dc70534905707ab5f1ef
Deleted: sha256:3ca16e3037c7a9c93b79b0bbd44d26a2dafbe6b3b97c8cd741927ac85d088459
Deleted: sha256:28a337283742c41b104afc4971eeac67c91690ddd28c02fcec7636f60d6857d0
Deleted: sha256:32a2e5949affba4aadb27bd654b05ae8d2e679182e01019466d2d3e06e7f9c89
Deleted: sha256:317e1ecbd0c250f6f17d2474d4916a3174c9f8811449ac740b1af47e83108e6b
Deleted: sha256:7f68ecbf760d8a6dc1611f31d603e859e68dbc4ac5655b3afda9b0a8353a7789
Deleted: sha256:f7586fbe4bfbf2997fdb694b13a3f3da495c74c822608536a6a6934a84442b74
Deleted: sha256:91ca6333ce038693dd6e34ed3aff1b22ad7be1f88d9bfc58174c5c7e28439f7f
Deleted: sha256:9f7ed167602fb56eba1a734c731ae6a3eccafa4b1c55b6f805908aefb56fa717
Deleted: sha256:c934e1a01b9427c8591058e926f0da57dea2fcb8cf6e97a53503d38971d4438f
Deleted: sha256:629eadb0a17045182c314e89f9cd61d9bad8528bea32ffe2e30d3653e3687b1a
Deleted: sha256:6fd2de2f74f6036c08d8d25e1f744c01af4d376afbed9d7a75a925e6691435ad
Deleted: sha256:6a7d9b26d637c79d59b01325f3afc49d7d5532a5da967f8c414559e45c542f79
Deleted: sha256:dc80215f020b1888bcbd7a72957273941bc3dd193edbfbc1211376341c3eeb19
Deleted: sha256:8524477778a005f53a218f175b3288459af96bd4d879c5848fdf6f5f163ab598
Deleted: sha256:476726dba66085e3412a6f0a13c5772f0dd882767bd77aab4d09ec37f9e87280
Starting process 'command 'gcloud''. Working directory: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/runners/google-cloud-dataflow-java>
 Command: gcloud --quiet container images untag 
us.gcr.io/apache-beam-testing/java-postcommit-it/java:20221201183621
Successfully started process 'command 'gcloud''
WARNING: Successfully resolved tag to sha256, but it is recommended to use 
sha256 directly.
Tag: [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20221201183621]
- referencing digest: 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95]

Deleted [[us.gcr.io/apache-beam-testing/java-postcommit-it/java:20221201183621] 
(referencing 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95])].
Starting process 'command './scripts/cleanup_untagged_gcr_images.sh''. Working 
directory: 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/runners/google-cloud-dataflow-java>
 Command: ./scripts/cleanup_untagged_gcr_images.sh 
us.gcr.io/apache-beam-testing/java-postcommit-it/java
Successfully started process 'command 
'./scripts/cleanup_untagged_gcr_images.sh''
Removing untagged image 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95
Digests:
- 
us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95
Deleted 
[us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:f2bda4a32704a02a51b63fb5926c901f14df5ca2e6a83b3192d272f6590a9b95].
:runners:google-cloud-dataflow-java:cleanUpDockerJavaImages (Thread[Execution 
**** Thread 2,5,main]) completed. Took 5.883 secs.
Resolve mutations for :sdks:java:io:kafka:cleanUp (Thread[included 
builds,5,main]) started.
Resolve mutations for :sdks:java:io:kafka:cleanUp (Thread[included 
builds,5,main]) completed. Took 0.0 secs.
:sdks:java:io:kafka:cleanUp (Thread[Execution **** Thread 7,5,main]) started.

> Task :sdks:java:io:kafka:cleanUp
Skipping task ':sdks:java:io:kafka:cleanUp' as it has no actions.
:sdks:java:io:kafka:cleanUp (Thread[Execution **** Thread 7,5,main]) completed. 
Took 0.0 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':sdks:java:io:kafka:integrationTest'.
> There were failing tests. See the report at: 
> file://<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/sdks/java/io/kafka/build/reports/tests/integrationTest/index.html>

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --debug option to get more log output.

* 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.5.1/userguide/command_line_interface.html#sec:command_line_warnings

Execution optimizations have been disabled for 1 invalid unit(s) of work during 
this build to ensure correctness.
Please consult deprecation warnings for more details.

BUILD FAILED in 28m 48s
156 actionable tasks: 100 executed, 52 from cache, 4 up-to-date

Publishing build scan...
https://gradle.com/s/2x6iue6cym5xq

Stopped 1 **** daemon(s).
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