Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-12942

Dataflow runner specialization of PubsubIO should validate messages

Details

    • Improvement
    • Status: Triage Needed
    • P2
    • Resolution: Unresolved
    • None
    • 2.34.0
    • runner-dataflow
    • None

    Description

      Currently invalid messages, such as those with attributes exceeding the maximum size are processed by the bundle successfully but fail to commit.

      Throwing an exception when trying to write such a message directly would increase visibility as well as allowing users to catch and handle such exceptions.

      Attachments

        Activity

          People

            scwhittle Sam Whittle
            scwhittle Sam Whittle
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 2.5h
                2.5h