[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-629663514 Manually merged in 939625f2c84bdce6872548d3df672f492e33a704 This is an automated message from the Apache Git

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-629631846 Thanks! Merging this now... This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-629338934 @becketqin This is based on the changes we discussed before. This is an automated message from the Apache Gi

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-628880625 The test failure looks unrelated to these changes (Kafka 0.11 ExactlyOnceProducer Test) This is an automate