Re: Jar availability after cluster restart

2018-09-12 Thread Till Rohrmann
Hi Ricardo, you're right. The uploaded jars are not persisted. However, if you enable HA mode and start a job, then they will be persisted as part of the job information. If you need to resubmit the job from the web ui, however, you still need to reupload them after a failover. Cheers, Till On W

[jira] [Created] (FLINK-10323) A single backslash cannot be successfully parsed in Java Table API

2018-09-12 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-10323: --- Summary: A single backslash cannot be successfully parsed in Java Table API Key: FLINK-10323 URL: https://issues.apache.org/jira/browse/FLINK-10323 Project: Flink

[jira] [Created] (FLINK-10324) Replace ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock

2018-09-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10324: - Summary: Replace ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock Key: FLINK-10324 URL: https://issues.apache.org/jira/browse/FLINK-10324 Projec

[jira] [Created] (FLINK-10325) [State TTL] Refactor TtlListState to use only loops, no java stream API for performance

2018-09-12 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10325: --- Summary: [State TTL] Refactor TtlListState to use only loops, no java stream API for performance Key: FLINK-10325 URL: https://issues.apache.org/jira/browse/FLINK-10325

[jira] [Created] (FLINK-10326) Simplify ZooKeeperSubmittedJobGraphStore constructor

2018-09-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10326: - Summary: Simplify ZooKeeperSubmittedJobGraphStore constructor Key: FLINK-10326 URL: https://issues.apache.org/jira/browse/FLINK-10326 Project: Flink Issue

[jira] [Created] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

2018-09-12 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10327: -- Summary: Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction Key: FLINK-10327 URL: https://issues.apache.org/jira/browse/FLINK-10327 Proje

[jira] [Created] (FLINK-10328) Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks

2018-09-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10328: - Summary: Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks Key: FLINK-10328 URL: https://issues.apache.org/jira/browse/FLINK-10328

[jira] [Created] (FLINK-10329) Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph

2018-09-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10329: - Summary: Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph Key: FLINK-10329 URL: https://issues.apache.org/jira/browse/FLINK-10329