[GitHub] flink issue #2083: [FLINK-3713] [clients, runtime] Use user code class loade...

2016-06-11 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2083 Full ack, but the problem is not just RocksDB, but also savepoints, which reference a user class in the state descriptor, including FS snapshots. So if you configure a file backend and use folding or

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15325771#comment-15325771 ] ASF GitHub Bot commented on FLINK-3713: --- Github user uce commented on the issue:

[jira] [Assigned] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis

2016-06-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4056: -- Assignee: Ufuk Celebi > SavepointITCase.testCheckpointHasBeenRemoved failed on Travis >

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

2016-06-11 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2093 [FLINK-3714] Add Support for "Allowed Lateness" Allows the user to specify an "allowed lateness" for elements, before they are dropped as late arrivals. In addition, it defines a "clean up" time

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

2016-06-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15326055#comment-15326055 ] ASF GitHub Bot commented on FLINK-3714: --- GitHub user kl0u opened a pull request: