erenavsarogullari opened a new pull request #3262: Refactor Flink Batch Sink Examples URL: https://github.com/apache/pulsar/pull/3262 ### Motivation This PR aims to align Flink Batch Sinks Java and Scala Examples with Streaming ones. ### Modifications 1- Provides a single executable jar by covering all examples. Also, Flink `-c <className>` Class parameter has been enabled to run each example (e.g: `./bin/flink run -c org.apache.flink.batch.connectors.pulsar.example.FlinkPulsarBatchSinkScalaExample`). 2- Adds user-defined arguments support to examples (e.g: `--service-url pulsar://127.0.0.1:6650 --topic test-topic`) instead of harcoded `service-url`and `topic-name`. 3- Aligns existing Batch documentation with Streaming documentation.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on 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
