This is an automated email from the ASF dual-hosted git repository.

chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from f42d4375e18 [BEAM-13857] Switched Go IT script to using Go flags for 
expansion services (#17161)
     add b4b0025acd6 [BEAM-10529] add java and generic components of nullable 
xlang tests
     add 798fd532832 [BEAM-10529] fix test case
     add 87435496681 [BEAM-10529] add coders and typehints to support nullable 
xlang coders
     add 1ce66059a97 [BEAM-10529] update external builder to support nullable 
coder
     add 04868d6a76a Merge remote-tracking branch 'origin/master' into 
feature/BEAM-10529-nullable-Xlang-Coder
     add a6a38d0ccc9 [BEAM-10529] clean up coders.py
     add e3e02235a5a [BEAM-10529] add coder translation test
     add 30f06d69dfd [BEAM-10529] add additional check to typecoder to not 
accidentally misidentify coders as nullable
     add 24dd8767553 [BEAM-10529] add test to retrieve nullable coder from 
typehint
     add 3e93b56c886 [BEAM-10529] improve comments, clean up python
     add e642e7c437a [BEAM-10529] run spotless
     add f55074c7aed Merge remote-tracking branch 
'origin/feature/BEAM-10529-nullable-Xlang-Coder' into 
feature/BEAM-10529-nullable-Xlang-Coder
     add 4dd1c548139 [BEAM-10529] add go nullable coder
     add 43c84e62b5b [BEAM-10529] cleanup extra println
     add 48b6f34fe70 Merge remote-tracking branch 
'origin/feature/BEAM-10529-nullable-Xlang-Coder' into 
feature/BEAM-10529-nullable-Xlang-Coder
     add 5be0e94b5e5 Merge remote-tracking branch 'origin/master' into 
feature/BEAM-10529-enable-nullable-for-kafka
     new e9afde092c1 Merge pull request #17268: [BEAM-10529] enable nullable 
for kafkaIO xlang

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

Reply via email to