[jira] [Updated] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode

2017-10-12 Thread John Fang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated FLINK-7833: - Description: {code:java} Caused by: java.lang.ClassCastException: java.util.GregorianCalendar cannot be

[jira] [Updated] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode

2017-10-12 Thread John Fang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated FLINK-7833: - Description: {code:java} Caused by: java.lang.ClassCastException: java.util.GregorianCalendar cannot be

[jira] [Commented] (FLINK-7502) PrometheusReporter improvements

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203067#comment-16203067 ] ASF GitHub Bot commented on FLINK-7502: --- Github user mbode commented on the issue:

[jira] [Created] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode

2017-10-12 Thread John Fang (JIRA)
John Fang created FLINK-7833: Summary: Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode Key: FLINK-7833 URL: https://issues.apache.org/jira/browse/FLINK-7833 Project: Flink

[GitHub] flink issue #4586: [FLINK-7502] [metrics] Improve PrometheusReporter

2017-10-12 Thread mbode
Github user mbode commented on the issue: https://github.com/apache/flink/pull/4586 @zentol *ping* ---

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203018#comment-16203018 ] ASF GitHub Bot commented on FLINK-7764: --- Github user xccui commented on the issue:

[GitHub] flink issue #4790: [FLINK-7764] [kafka] Enable the operator settings for Fli...

2017-10-12 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/4790 Hi @aljoscha, I've created another PR #4819 for the `release-1.3` branch. ---

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203017#comment-16203017 ] ASF GitHub Bot commented on FLINK-7764: --- GitHub user xccui opened a pull request:

[GitHub] flink pull request #4819: [FLINK-7764] [kafka] Fix the operator setting prob...

2017-10-12 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/4819 [FLINK-7764] [kafka] Fix the operator setting problem of FlinkKafkaProducer010(1.3) ## What is the purpose of the change This PR fixes the operator setting (name, uid, parallelism, etc.)

[jira] [Updated] (FLINK-7827) creating and starting a NetCat in test cases programmatically

2017-10-12 Thread bluejoe (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bluejoe updated FLINK-7827: --- Description: hi, all I have written a MockNetCat class, which help developers start a netcat

[jira] [Commented] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc

2017-10-12 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202918#comment-16202918 ] Bowen Li commented on FLINK-7820: - [~aljoscha] I was thinking that keeping examples of deprecated APIs in

[jira] [Commented] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202829#comment-16202829 ] ASF GitHub Bot commented on FLINK-7660: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202830#comment-16202830 ] ASF GitHub Bot commented on FLINK-7660: --- Github user bowenli86 closed the pull request at:

[GitHub] flink issue #4740: [FLINK-7660][DataStream API/Scala API] Support sideOutput...

2017-10-12 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4740 @aljoscha Thank you! ---

[GitHub] flink pull request #4740: [FLINK-7660][DataStream API/Scala API] Support sid...

2017-10-12 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4740 ---

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:44 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:44 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:52 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:47 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:48 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:50 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:48 PM:

[jira] [Comment Edited] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos edited comment on FLINK-7771 at 10/12/17 10:40 PM:

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-12 Thread Ryan Hobbs (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202700#comment-16202700 ] Ryan Hobbs commented on FLINK-7737: --- In our case we are using a hadoop compatible file system (HCFS)

[jira] [Commented] (FLINK-7771) Make the operator state queryable

2017-10-12 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202692#comment-16202692 ] Stavros Kontopoulos commented on FLINK-7771: We could overcome some problems by allowing Flink

[jira] [Commented] (FLINK-7738) Create WebSocket handler (server)

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202661#comment-16202661 ] ASF GitHub Bot commented on FLINK-7738: --- Github user EronWright commented on the issue:

[GitHub] flink issue #4767: [FLINK-7738] [flip-6] Create WebSocket handler (server, c...

2017-10-12 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4767 I don't much like the use of `RequestBody` and `ResponseBody` here, or even that the WebSocket distinguishes between client and server messages. Honestly a `MessageBody` marker interface may

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202513#comment-16202513 ] Aljoscha Krettek commented on FLINK-7830: - I think [~kkl0u]'s discovery in the {{NFASerializer}}

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202510#comment-16202510 ] Aljoscha Krettek commented on FLINK-7756: - I think the symptom could be the same as for the other

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202509#comment-16202509 ] Aljoscha Krettek commented on FLINK-6321: - It's probably the same underlying problem as for the

[jira] [Commented] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202503#comment-16202503 ] Aljoscha Krettek commented on FLINK-7435: - In addition to the {{NFASerializer}} there is a bug

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202501#comment-16202501 ] Aljoscha Krettek commented on FLINK-7484: - The problem is this change:

[GitHub] flink pull request #4767: [FLINK-7738] [flip-6] Create WebSocket handler (se...

2017-10-12 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/4767#discussion_r144381682 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractWebSocketHandler.java --- @@ -0,0 +1,301 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7738) Create WebSocket handler (server)

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202468#comment-16202468 ] ASF GitHub Bot commented on FLINK-7738: --- Github user EronWright commented on a diff in the pull

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202425#comment-16202425 ] ASF GitHub Bot commented on FLINK-5706: --- Github user steveloughran commented on the issue:

[GitHub] flink issue #4818: [FLINK-5706] [file systems] Add S3 file systems without H...

2017-10-12 Thread steveloughran
Github user steveloughran commented on the issue: https://github.com/apache/flink/pull/4818 1. I hope you pick up Hadoop 2.8.1 for this, as it's got a lot of the optimisations 1. And equally importantly: a later SDK 1. Though not one of the more recent 1.11 SDKs, where support

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202403#comment-16202403 ] ASF GitHub Bot commented on FLINK-5706: --- Github user steveloughran commented on a diff in the pull

[GitHub] flink pull request #4818: [FLINK-5706] [file systems] Add S3 file systems wi...

2017-10-12 Thread steveloughran
Github user steveloughran commented on a diff in the pull request: https://github.com/apache/flink/pull/4818#discussion_r144372829 --- Diff: flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/S3FileSystemFactory.java --- @@ -0,0 +1,145 @@ +/*

[GitHub] flink pull request #4818: [FLINK-5706] [file systems] Add S3 file systems wi...

2017-10-12 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/4818 [FLINK-5706] [file systems] Add S3 file systems without Hadoop dependencies ## What is the purpose of the change This adds two implementations of a file system that write to S3 so that

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202332#comment-16202332 ] ASF GitHub Bot commented on FLINK-5706: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink issue #4809: [FLINK-7803][Documentation] Add missing savepoint informa...

2017-10-12 Thread razvan100
Github user razvan100 commented on the issue: https://github.com/apache/flink/pull/4809 Okay, so if you account for it in the review then I don't need to make another empty commit. Thanks! ---

[jira] [Commented] (FLINK-7803) Update savepoint Documentation

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202327#comment-16202327 ] ASF GitHub Bot commented on FLINK-7803: --- Github user razvan100 commented on the issue:

[jira] [Assigned] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-12 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5706: --- Assignee: Stephan Ewen > Implement Flink's own S3 filesystem >

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202238#comment-16202238 ] Kostas Kloudas commented on FLINK-7760: --- No [~shashank734] it shouldn't. I am just saying this as a

[jira] [Created] (FLINK-7832) SlotManager should return number of registered slots

2017-10-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7832: Summary: SlotManager should return number of registered slots Key: FLINK-7832 URL: https://issues.apache.org/jira/browse/FLINK-7832 Project: Flink Issue

[jira] [Commented] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202233#comment-16202233 ] ASF GitHub Bot commented on FLINK-7653: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4793: [FLINK-7653] Properly implement Dispatcher#request...

2017-10-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4793 ---

[jira] [Resolved] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

2017-10-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7653. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

2017-10-12 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202221#comment-16202221 ] ramkrishna.s.vasudevan commented on FLINK-4808: --- I can try working on it next week? I raised

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

2017-10-12 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202223#comment-16202223 ] ramkrishna.s.vasudevan commented on FLINK-4808: --- Thanks once again. > Allow skipping failed

[jira] [Commented] (FLINK-7831) Retrieve last received heartbeat from HeartbeatManager

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202217#comment-16202217 ] ASF GitHub Bot commented on FLINK-7831: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4817: [FLINK-7831] Make last received heartbeat retrieva...

2017-10-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4817 [FLINK-7831] Make last received heartbeat retrievable ## What is the purpose of the change This commit adds functionality to retrieve the last received heartbeat from the

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202187#comment-16202187 ] Shashank Agarwal commented on FLINK-7830: - [~aljoscha] I think you have covered all reported by

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202172#comment-16202172 ] Kostas Kloudas commented on FLINK-7830: --- Thanks [~aljoscha] for creating this. As for the serialize

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202173#comment-16202173 ] Shashank Agarwal commented on FLINK-7760: - [~kkl0u] Yes that is redundent. Actually i am using

[jira] [Created] (FLINK-7831) Retrieve last received heartbeat from HeartbeatManager

2017-10-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7831: Summary: Retrieve last received heartbeat from HeartbeatManager Key: FLINK-7831 URL: https://issues.apache.org/jira/browse/FLINK-7831 Project: Flink Issue

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202162#comment-16202162 ] Shashank Agarwal commented on FLINK-6321: - [~kkl0u] I am using 4-5 CEP's and around 20-22 map,

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202159#comment-16202159 ] Aljoscha Krettek commented on FLINK-7830: - I suspect that there is some issue with asynchronicity

[jira] [Updated] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6318: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7830 > NFA serialisation

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202154#comment-16202154 ] Aljoscha Krettek commented on FLINK-7830: - [~shashank734] and [~lidaiqing1993]: I created this as

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6321: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > RocksDB state backend

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > RocksDB state backend

[jira] [Updated] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 >

[jira] [Updated] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7760: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > Restore failing from external

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Issue Type: Sub-task (was: Bug) Parent: FLINK-7830 > FsStateBackend with

[jira] [Created] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7830: --- Summary: Problematic interaction of CEP and asynchronous snapshots Key: FLINK-7830 URL: https://issues.apache.org/jira/browse/FLINK-7830 Project: Flink

[jira] [Commented] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202139#comment-16202139 ] Aljoscha Krettek commented on FLINK-7435: - [~lidaiqing1993] When you say incremental, did you mean

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Priority: Blocker (was: Major) > FsStateBackend with incremental backup enable does not

[jira] [Updated] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7435: Fix Version/s: 1.4.0 > FsStateBackend with incremental backup enable does not work with

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Fix Version/s: 1.4.0 > RocksDB state backend Checkpointing (Async and Incremental) is not

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7756: Priority: Blocker (was: Major) > RocksDB state backend Checkpointing (Async and

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202112#comment-16202112 ] Aljoscha Krettek commented on FLINK-7760: - Are you using exactly the same jar when trying to

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202111#comment-16202111 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144326685 --- Diff: docs/start/building.md --- @@ -115,19 +115,7 @@ The `-Pvendor-repos` activates a Maven [build profile](http://maven.apache.org/g Flink

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202107#comment-16202107 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144325824 --- Diff: docs/start/building.md --- @@ -115,19 +115,7 @@ The `-Pvendor-repos` activates a Maven [build profile](http://maven.apache.org/g Flink

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202086#comment-16202086 ] ASF GitHub Bot commented on FLINK-7810: --- Github user EronWright commented on the issue:

[GitHub] flink issue #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4.x

2017-10-12 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4807 Thanks for doing this, we need Akka 2.4 badly for improved SSL support. ---

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-12 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144320740 --- Diff: docs/start/building.md --- @@ -115,19 +115,7 @@ The `-Pvendor-repos` activates a Maven [build profile](http://maven.apache.org/g

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202084#comment-16202084 ] ASF GitHub Bot commented on FLINK-7810: --- Github user EronWright commented on a diff in the pull

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202083#comment-16202083 ] Kostas Kloudas commented on FLINK-6321: --- [~shashank734] And you may be able to also run it locally

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202073#comment-16202073 ] Kostas Kloudas commented on FLINK-7760: --- Btw, although this may not be a problem, you {{keyBy}}

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202054#comment-16202054 ] Kostas Kloudas commented on FLINK-6321: --- Thanks, in the meantime I will try to see what is happening

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202035#comment-16202035 ] Shashank Agarwal commented on FLINK-6321: - I will try to run that in next week. > RocksDB state

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202029#comment-16202029 ] Kostas Kloudas commented on FLINK-6321: --- Well the failure message is similar to this one

[jira] [Commented] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202030#comment-16202030 ] ASF GitHub Bot commented on FLINK-7818: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4811: [FLINK-7818] Synchronize MetricStore access in Tas...

2017-10-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4811 ---

[jira] [Closed] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7818. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 742e4a0ffd2fb244654e97098d0b23100789d4e9 >

[jira] [Commented] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202024#comment-16202024 ] ASF GitHub Bot commented on FLINK-7818: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4811: [FLINK-7818] Synchronize MetricStore access in TaskManage...

2017-10-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4811 Thanks for the review @zentol. Merging this PR. ---

[jira] [Commented] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202019#comment-16202019 ] ASF GitHub Bot commented on FLINK-7806: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202018#comment-16202018 ] Shashank Agarwal commented on FLINK-7760: - Ho [~kkl0u], Hi [~kkl0u] , Actually it's too

[jira] [Comment Edited] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202018#comment-16202018 ] Shashank Agarwal edited comment on FLINK-7760 at 10/12/17 2:31 PM: --- Ho

[GitHub] flink issue #4805: [FLINK-7806] [flip6] Register CurrentJobsOverviewHandler ...

2017-10-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4805 I'm not entirely sure, but I think we cannot put the `JobsOverviewHandler` under `/jobs/overview`. The problem is that it collides with `/jobs/:jobid`. If I access

[jira] [Comment Edited] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202007#comment-16202007 ] Kostas Kloudas edited comment on FLINK-7435 at 10/12/17 2:28 PM: - Hi

[jira] [Commented] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202007#comment-16202007 ] Kostas Kloudas commented on FLINK-7435: --- Hi [~lidaiqing]. I am looking into this issue, and the

[GitHub] flink issue #4805: [FLINK-7806] [flip6] Register CurrentJobsOverviewHandler ...

2017-10-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4805 I reverted the changes to `vendor.css` and `vendor.js` and updated the `rest_api.md`. ---

[jira] [Commented] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

2017-10-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202001#comment-16202001 ] ASF GitHub Bot commented on FLINK-7806: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201999#comment-16201999 ] Shashank Agarwal commented on FLINK-6321: - Hi, [~kkl0u] , My program is in Scala, But before

[jira] [Comment Edited] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124875#comment-16124875 ] Kostas Kloudas edited comment on FLINK-7435 at 10/12/17 2:15 PM: - The

  1   2   3   >