ysn2233 opened a new pull request #7991: [FLINK-11928][Connectors / FileSystem]Create a Compression string writer for flink-connectors-filesystem URL: https://github.com/apache/flink/pull/7991 ## What is the purpose of the change This pull request is to create a CompressedStringWriter which allows user to use it or its subclass to compressed the stream to filesystem. ## Brief change log *(for example:)* - A new compressed string writer is created to write compressed stream to file system ## Verifying this change This change added tests and can be verified as follows: - *Manually verified the change by running a compressed streaming job which sinks to HDFS by using 10-node flink on yarn. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): no - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no - The serializers: no - The runtime per-record code paths (performance sensitive): no - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: no - The S3 file system connector: no ## Documentation - Does this pull request introduce a new feature? yes - If yes, how is the feature documented? JavaDocs
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
