[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] [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] [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] [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-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: --- Labels: httpstreaming netcat streaming (was: ) > creating and starting a NetCat in test cases

[jira] [Updated] (FLINK-5627) Allow job specific externalized checkpoint dir

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5627: Priority: Blocker (was: Major) > Allow job specific externalized checkpoint dir >

[jira] [Updated] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6584: - Priority: Blocker (was: Major) > Support multiple consecutive windows in SQL >

[jira] [Closed] (FLINK-5905) Add user-defined aggregation functions to documentation.

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5905. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.x with

[jira] [Updated] (FLINK-7426) Table API does not support null values in keys

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7426: - Priority: Blocker (was: Major) > Table API does not support null values in keys >

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

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201881#comment-16201881 ] Aljoscha Krettek commented on FLINK-7820: - They are only deprecated, not removed yet, though. >

[jira] [Updated] (FLINK-6697) Add batch multi-window support

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6697: - Priority: Blocker (was: Major) > Add batch multi-window support > --

[jira] [Closed] (FLINK-5564) Add User Defined Aggregates in Table API

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5564. Resolution: Implemented Fix Version/s: 1.3.0 UDAGGs were added with Flink 1.3.0 > Add User

[jira] [Created] (FLINK-7828) Improve object copying/reuse mode for streaming runtime

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7828: --- Summary: Improve object copying/reuse mode for streaming runtime Key: FLINK-7828 URL: https://issues.apache.org/jira/browse/FLINK-7828 Project: Flink

[jira] [Updated] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6173: - Priority: Blocker (was: Major) > flink-table not pack-in com.fasterxml.jackson.* in after

[jira] [Updated] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7342: - Issue Type: New Feature (was: Bug) > Add support for Regular Expression Operators (RLIKE) >

[jira] [Updated] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5015: Priority: Blocker (was: Critical) > Add Tests/ITCase for Kafka Per-Partition Watermarks >

[jira] [Updated] (FLINK-5564) Add User Defined Aggregates in Table API

2017-10-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5564: Summary: Add User Defined Aggregates in Table API (was: User Defined Aggregates) > Add

[GitHub] flink pull request #4804: [hotfix] [kafka] Fix the config parameter names in...

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

[jira] [Updated] (FLINK-7798) Add support for windowed joins to Table API

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7798: - Priority: Blocker (was: Critical) > Add support for windowed joins to Table API >

[jira] [Created] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7829: --- Summary: Remove (or at least deprecate) DataStream.writeToFile/Csv Key: FLINK-7829 URL: https://issues.apache.org/jira/browse/FLINK-7829 Project: Flink

[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

[GitHub] flink issue #4802: [FLINK-7791] [REST][client] Integrate LIST command into R...

2017-10-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4802 True, you're right. I guess I overlooked it. But it also includes the `trigger` prefix which indicates that it does not take a savepoint but only triggers it. If we want to be consistent, then

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

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

[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 Alright. I'm wondering whether it would be possible to somehow fix these things because this is bound to be changed. ---

[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=16201956#comment-16201956 ] ASF GitHub Bot commented on FLINK-7806: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #4816: [hotfix][docs] CEP docs review to remove weasel wo...

2017-10-12 Thread ChrisChinchilla
GitHub user ChrisChinchilla opened a pull request: https://github.com/apache/flink/pull/4816 [hotfix][docs] CEP docs review to remove weasel words, fix passive voice, typos an… I was reading through the CEP and made a quick sweep of tidying up docs for improved readability. I

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

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201969#comment-16201969 ] Kostas Kloudas commented on FLINK-7756: --- Hi [~shashank734]. This does not seem to be the original

[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=16201972#comment-16201972 ] ASF GitHub Bot commented on FLINK-7803: --- Github user zentol commented on the issue:

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

2017-10-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4809 @razvan100 You can re-trigger the build by adding a new commit (even en empty one). However, please don't do this for the sake of achieving a picture perfect build (in particular for documentation

[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=16201973#comment-16201973 ] Kostas Kloudas commented on FLINK-6321: --- Hi, [~shashank734]. In this last message you are using

[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: Priority: Blocker (was: Major) > com.esotericsoftware.kryo.KryoException:

[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=16201974#comment-16201974 ] Aljoscha Krettek commented on FLINK-7484: - There has been an ML thread with another user where the

[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=16201975#comment-16201975 ] Aljoscha Krettek commented on FLINK-7484: - If somehow the serialiser is not properly duplicated,

[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: Fix Version/s: 1.4.0 > com.esotericsoftware.kryo.KryoException:

[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=16201976#comment-16201976 ] Kostas Kloudas commented on FLINK-7760: --- Hi [~shashank734] Could you provide the code for your

[GitHub] flink issue #4816: [hotfix][docs] CEP docs review to remove weasel words, fi...

2017-10-12 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/4816 +1 ---

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

2017-10-12 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201992#comment-16201992 ] Shashank Agarwal commented on FLINK-7756: - Hi [~kkl0u] I have checked all the logs. These are the

[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

[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] [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:

[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-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

[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

[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] [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

[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:

[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-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:

[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 >

[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] [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:

[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-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=16202054#comment-16202054 ] Kostas Kloudas commented on FLINK-6321: --- Thanks, in the meantime I will try to see what is happening

[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=16202083#comment-16202083 ] Kostas Kloudas commented on FLINK-6321: --- [~shashank734] And you may be able to also run it locally

[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

[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

[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. ---

[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 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=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_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=16202111#comment-16202111 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[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] [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] [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-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-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] [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] [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] [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] [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-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-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-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] [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] [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-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] [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-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] [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-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

[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-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:

[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-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] [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

[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] [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:

[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-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

  1   2   3   >