Cham. Thank you for the advice. It worked ! I see it now !
beam:transform:org.apache.beam:elasticsearch_write:v1: org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$1@5f049ea1 Thanks, Yu On Thu, Aug 18, 2022 at 6:28 AM Chamikara Jayalath via user <[email protected]> wrote: > > > > On Wed, Aug 17, 2022 at 3:05 AM Yu Watanabe <[email protected]> wrote: >> >> Hello. >> >> I am trying to write code for cross language transform for >> ElasticsearchIO but having trouble with it. >> I would appreciate it if I could get help. >> >> As describe in doc and also referencing KafkaIO , >> >> https://beam.apache.org/documentation/programming-guide/#1311-creating-cross-language-java-transforms >> >> I have annotated the code with @AutoService but the >> 'elasticsearch_write' does not appear when starting Expansion Service. >> >> https://github.com/yuwtennis/beam/blob/feat/elasticsearch-io-cross-lang/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java#L1991 >> >> Below is the snippet of command line operation. >> >> https://gist.github.com/yuwtennis/3c55ca45b31f9a302daf7b827a842ef6 >> >> I have built jar files with the below command in advance . >> >> ./gradlew :sdks:java [jar] >> >> Would there be any other instructions I should be referencing ? > > > It's because io-expansion-service currently does not include ElasticSearch > module as a dependency: > https://github.com/apache/beam/blob/master/sdks/java/io/expansion-service/build.gradle > Can you try adding it there and re-building the jar ? > > Thanks, > Cham > > >> >> >> Best Regards, >> Yu Watanabe >> >> -- >> Yu Watanabe >> >> linkedin: www.linkedin.com/in/yuwatanabe1/ >> twitter: twitter.com/yuwtennis -- Yu Watanabe linkedin: www.linkedin.com/in/yuwatanabe1/ twitter: twitter.com/yuwtennis
