What issues do you have with these tests? I had the following: 1. KafkaSource hangs in doStart at line 413: it = consumer.poll(1000).iterator(); I fixed that by simply changing HOST in KafkaSourceEmbeddedKafka to localhost.
2. Out of memory exception. I fixed that by properly configuring MAVEN_OPTS. On Wed, Jun 22, 2016 at 9:25 AM, Mike Percy <[email protected]> wrote: > The kafka source tests are extremely flaky. I haven't investigated it. > > Mike > > On Tue, Jun 21, 2016 at 9:23 PM, Lior Zeno <[email protected]> wrote: > > > Hi guys, > > I know that there are a few tests that are problematic, i.e. may fail > > arbitrarily. Please reply here with all tests that are known to be > flaky. I > > will create a jira issue for fixing that. Obviously, we won't fix all > tests > > in the project at this moment, but we can definitely fix that in the > > future. > > Currently, the goal I think we should achieve is stabilizing the tests > and > > make sure that we don't have false build failures. > > > > Thanks > > >
