I'm using flink 1.5.0. The test gives the same error even with flink-1.6.0.
Also, I introduced a Thread.sleep(3); before the assert statement. That
didn't help either.
Regards,
James
On Thu, Oct 11, 2018 at 11:11 AM James Isaac
wrote:
> Hi,
>
> I'm trying to run an integration test of my
Hi,
I'm trying to run an integration test of my flink application. My test code
looks like this:
public class HttpsCsvIngestorTest extends AbstractTestBase {
private final static Logger LOG =
LoggerFactory.getLogger(HttpsCsvIngestorTest.class);
@Test
public void
