Re: How to test new sink

2017-10-24 Thread Timo Walther
Yes, if you think you need better public test utilities. Feel free to open an issue for it. Timo Am 10/23/17 um 5:32 PM schrieb Rinat: Timo, thx for your reply. I’m using gradle instead of maven, but I’ll look through the existing similar plugins for it. I don’t think, that sharing of

Re: How to test new sink

2017-10-23 Thread Rinat
Timo, thx for your reply. I’m using gradle instead of maven, but I’ll look through the existing similar plugins for it. I don’t think, that sharing of external tests between other projects is a good idea, but it’s out of scope of current discussion. The main purpose of my request is to

Re: How to test new sink

2017-10-23 Thread Timo Walther
Hi Rinat, using one of the Flink test utilities is a good approach to test your custom operators. But of course these classes might change in the future. First of all, Flink is a open source project so you can just copy the required classes. However, it should be possible to use the Flink

How to test new sink

2017-10-23 Thread Rinat
Hi !!! I’ve just implemented a new sink, that extends functionality of existing BucketingSink, currently I’m trying to test functionality, that is related with timing. My sink implements ProcessingTimeCallback, similarly with the original BucketingSink. I’m trying to inject