Skip to content

Instantly share code, notes, and snippets.

@yuwtennis

yuwtennis/log

Created August 17, 2022 10:00
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save yuwtennis/3c55ca45b31f9a302daf7b827a842ef6 to your computer and use it in GitHub Desktop.
Save yuwtennis/3c55ca45b31f9a302daf7b827a842ef6 to your computer and use it in GitHub Desktop.
Download ZIP
No expansion service for ElasticsearchIO
Raw
log
[ywatanabe@laptop-archlinux beam]$ ./gradlew :sdks:java:io:expansion-service:runExpansionService -PconstructionService.port=18089
Configuration on demand is an incubating feature.
> Task :sdks:java:io:expansion-service:runExpansionService
Starting expansion service at localhost:18089
Aug 17, 2022 6:49:19 PM org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms
beam:transform:org.apache.beam:kafka_read_with_metadata:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@663c9e7a
INFO: Registering external transforms: [beam:transform:org.apache.beam:kafka_read_with_metadata:v1, beam:transform:org.apache.beam:kafka_read_without_metadata:v1, beam:transform:org.apache.beam:kafka_write:v1, beam:external:java:generate_sequence:v1]
beam:transform:org.apache.beam:kafka_read_without_metadata:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@19e4653c
beam:transform:org.apache.beam:kafka_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@795509d9
beam:external:java:generate_sequence:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@53045c6c
<============-> 98% EXECUTING [10m 34s]
> IDLE
> :sdks:java:io:expansion-service:runExpansionService
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment