Weijie Guo created FLINK-28448:
----------------------------------
Summary: BoundedDataTestBase has potential problem when
compression is enable
Key: FLINK-28448
URL: https://issues.apache.org/jira/browse/FLINK-28448
Project: Flink
Issue Type: Bug
Components: Runtime / Network
Reporter: Weijie Guo
Fix For: 1.16.0
BoundedDataTestBase has potential problem when compression is enable, I'm sure
there is a bug in this part of the code. But unfortunately, the test can pass
now, because the generated data used in the test cannot be compressed by LZ4
(i.e. the compressed size is larger than the original size), which causes the
branch of enable compression actually the same as disable compression, So the
bug didn't surface.
I think there are two steps of work that need to be done:
1. Fix incorrect code
2. Generate data that can be properly compressed
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
