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 >
