| commit | afde244da33c015ea0bac6f95dd3a1f72ec36c40 | [log] [tgz] |
|---|---|---|
| author | Cristian <me@cristian.io> | Mon Apr 01 21:15:44 2019 -0700 |
| committer | Sijie Guo <guosijie@gmail.com> | Mon Apr 01 21:15:44 2019 -0700 |
| tree | 774185f2121d8607a2f9cfeff58c9120b72159ac | |
| parent | f4d6c82e5af72d2c399522a9fcaf3168adbdd90a [diff] |
[Flink] Allow to customize PulsarProducer (#3955) This is an improvement over #3894. Because of how Flink instantiates functions, instead of passing a custom `PulsarProducer` client we need to pass an object that is serializable. The current implementation will default to always call `createProducer()` because `producer` is `transient`, so it will always be null when Flink creates new instances of the sink.