Re: [I] [Bug]: Java expansion service does not respect the namespace for all environments. [beam]

[via GitHub]

robertwb commented on issue #30876:
URL: https://github.com/apache/beam/issues/30876#issuecomment-2040555076

   This was uncovered by https://github.com/apache/beam/pull/30864
   
   It can be reproduced with 
   
   ```
   import apache_beam as beam
   from apache_beam.transforms import external
   import logging
   
   from apache_beam.utils import subprocess_server
   
   logging.getLogger().setLevel(logging.INFO)
   
   with beam.Pipeline('DirectRunner') as p:
     i1 = p | "i1" >> beam.Create([beam.Row(name='john', id=1)])
     i2 = p | "i2" >> beam.Create([beam.Row(name='jane', id=1)])
     result = {'i1': i1, 'i2': i2} | 'Sql1' >> external.ExternalTransform(
           'beam:external:java:sql:v1',
           external.ImplicitSchemaPayloadBuilder(
             {'query': 'SELECT * FROM i1 INNER JOIN i2 ON i1.id = i2.id'}
           ).payload(),
       external.JavaJarExpansionService(
         subprocess_server.JavaJarServer.path_to_beam_jar(
           gradle_target='sdks:java:extensions:sql:expansion-service:shadowJar',
           artifact_id=None
         )
       )) | 'LogForTesting' >> external.SchemaAwareExternalTransform(
           'beam:schematransform:org.apache.beam:yaml:log_for_testing:v1',
       external.JavaJarExpansionService(
         subprocess_server.JavaJarServer.path_to_beam_jar(
           gradle_target='sdks:java:extensions:sql:expansion-service:shadowJar',
           artifact_id=None
         )
       ), rearrange_based_on_discovery=True)
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@beam.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org