Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/791
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabl
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109802550
... merged (github mirror broken?!)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109802171
Merging ...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
en
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109370682
+1 , good addition
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109296590
Hi, this `KafkaITCase` is known to be unstable and I have actually a fix
that disables the test for now. Since only 1 out of 5 jobs failed, your change
doesn't break any
Github user peedeeX21 commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109249506
Travis fails executing this test:
`KafkaITCase.testPersistentSourceWithOffsetUpdates`. Unfortunately I have no
idea what the problem is. I am not even sure if this is r
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/791#issuecomment-109205245
Thank you for the contribution.
+1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
GitHub user peedeeX21 opened a pull request:
https://github.com/apache/flink/pull/791
Added member currentSplit for FileInputFormat.java
According to [this stackoverflow discussion]
(http://stackoverflow.com/questions/30599616/create-objects-from-input-files-in-apache-flink/30600148
