liferoad commented on issue #35666:
URL: https://github.com/apache/beam/issues/35666#issuecomment-3109803276

   The workaround is to use the same schema:
   ```
   pipeline:
     transforms:
       - type: Create
         name: Create1
         config:
           elements:
             - {'ride_id': '1',
                'passenger_count': 1}
             - {'ride_id': '2',
                'passenger_count': 2}
   
       - type: Create
         name: Create2
         config:
             elements:
               - {'ride_id': '3', 'passenger_count':null}
               - {'ride_id': '4', 'passenger_count':null}
   
       - type: Flatten
         name: Flatten1
         input:
           - Create2
           - Create1
   
       - type: LogForTesting
         name: LogForTesting
         input: Flatten1
   ```


-- 
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

Reply via email to