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 t
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
Comparing the state backend configurations between Flink 1.4 and 1.5, I
have a question:
In Flink 1.5, we have a *state.checkpoints.dir* location and a
*state.backend.rocksdb.localdir*. It was the same in Flink 1.4.
However, in the case of filesystem backends, we have
