Build #1,115

Build: #1115 was successful Child of CDAP-DRC-4894

Code commits

caskdata/cdap

  • Terence Yim <885032+chtyim@users.noreply.github.com>

    Terence Yim <885032+chtyim@users.noreply.github.com> 5b68f4cc85fe314881bae97a34bad0a0a24f3aee

    Merge pull request #12164 from cdapio/feature/CDAP-16673-tms-compression
    (CDAP-16673) Handle large TMS publish request

  • Terence Yim

    Terence Yim 3fb2bf3d0013944be1f343b114058b67530bbfa2

    (CDAP-16673) Added a SpillableBodyConsumer
    This allows handling large HTTP requests with a memory bound

    • cdap-common/src/main/java/io/cdap/cdap/common/http/CombineInputStream.java (version 3fb2bf3d0013944be1f343b114058b67530bbfa2)
    • cdap-common/src/main/java/io/cdap/cdap/common/http/SpillableBodyConsumer.java (version 3fb2bf3d0013944be1f343b114058b67530bbfa2)
    • cdap-common/src/main/java/io/cdap/cdap/common/io/FileSeekableInputStream.java (version 3fb2bf3d0013944be1f343b114058b67530bbfa2)
    • cdap-common/src/test/java/io/cdap/cdap/common/http/CombineInputStreamTest.java (version 3fb2bf3d0013944be1f343b114058b67530bbfa2)
    • cdap-common/src/test/java/io/cdap/cdap/common/http/SpillableBodyConsumerTest.java (version 3fb2bf3d0013944be1f343b114058b67530bbfa2)
  • Terence Yim

    Terence Yim 392b42a2a5a7f5298e913c73e6740c97ce92171f

    (CDAP-16673) Enable message fetching compression

    • cdap-tms/src/main/java/io/cdap/cdap/messaging/client/ClientMessagingService.java (version 392b42a2a5a7f5298e913c73e6740c97ce92171f)
  • Terence Yim

    Terence Yim 8b937b1640b94578ed5fc23c3df08d0d7a036a69

    (CDAP-16673) Handle arbitrary large TMS publish request
    - Use the SpillableBodyConsumer to spill large requests to temp file

    • cdap-tms/src/main/java/io/cdap/cdap/messaging/server/StoreHandler.java (version 8b937b1640b94578ed5fc23c3df08d0d7a036a69)
    • cdap-tms/src/test/java/io/cdap/cdap/messaging/server/MessagingHttpServiceTest.java (version 8b937b1640b94578ed5fc23c3df08d0d7a036a69)