[jira] [Commented] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462250#comment-16462250 ] Shashank Agarwal commented on FLINK-8867: - [~aljoscha] Actually bit busy with our releases ...

[jira] [Commented] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390847#comment-16390847 ] Shashank Agarwal commented on FLINK-8867: - [~StephanEwen] [~srichter] You can check full logs at

[jira] [Created] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

Shashank Agarwal created FLINK-8867: --- Summary: Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config Key: FLINK-8867 URL: https://issues.apache.org/jira/browse/FLINK-8867 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal closed FLINK-6321. --- Resolution: Fixed Fix Version/s: 1.4.1 same as :

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal closed FLINK-7756. --- Resolution: Fixed Fix Version/s: 1.4.1 > RocksDB state backend Checkpointing (Async

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386040#comment-16386040 ] Shashank Agarwal commented on FLINK-7756: - [~aljoscha] We found one thing, In our past setup, we

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16378386#comment-16378386 ] Shashank Agarwal commented on FLINK-7756: - [~aljoscha] Is there any info which we can provide to

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362663#comment-16362663 ] Shashank Agarwal commented on FLINK-7756: - I’ll also try with removing Cassandra.. On Tue, 13 Feb

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362657#comment-16362657 ] Shashank Agarwal commented on FLINK-7756: - But this happens only when I choose rocksdb otherwise

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362632#comment-16362632 ] Shashank Agarwal commented on FLINK-7756: - Sure, I will check that. On Tue, 13 Feb 2018 at 10:21

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362610#comment-16362610 ] Shashank Agarwal commented on FLINK-7756: - That was the bug in version 1.3.2 during the build so I

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362595#comment-16362595 ] Shashank Agarwal commented on FLINK-7756: - [~aljoscha] I am building using SBT please find

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-7756: - [~aljoscha] [~kkl0u] I have checked with 1.4.1-rc1 and 1.5.0 snapshot still it's running

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Attachment: jobmanager.log taskmanager.log > RocksDB state backend

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-6321: Attachment: jobmanager.log taskmanager.log > RocksDB state backend

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-6321: - [~aljoscha] [~kkl0u] I have checked with 1.4.1-rc1 and 1.5.0 snapshot still it's running

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16355676#comment-16355676 ] Shashank Agarwal commented on FLINK-7760: - Sure I’ll checkout by weekend. I’ll be back by then.

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354152#comment-16354152 ] Shashank Agarwal commented on FLINK-6321: - Sure I’ll check with 1.5 snapshot, only thing is during

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354136#comment-16354136 ] Shashank Agarwal commented on FLINK-7756: - I m travelling now will send that logs in 1-2 days for

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302523#comment-16302523 ] Shashank Agarwal edited comment on FLINK-6321 at 1/29/18 11:22 AM: ---

[jira] [Commented] (FLINK-6883) Serializer for collection of Scala case classes are generated with different anonymous class names in 1.3

[ https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16335823#comment-16335823 ] Shashank Agarwal commented on FLINK-6883: - I am facing something similar issue in 1.4 where i have

[jira] [Commented] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4

[ https://issues.apache.org/jira/browse/FLINK-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330562#comment-16330562 ] Shashank Agarwal commented on FLINK-8451: - I have taken savepoint from 1.4 and tried to restore on

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7760: Affects Version/s: 1.4.0 > Restore failing from external checkpointing metadata. >

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309634#comment-16309634 ] Shashank Agarwal commented on FLINK-7760: - Hi [~kkl0u] , I have checked again and facing the same

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309626#comment-16309626 ] Shashank Agarwal commented on FLINK-7756: - Hi [~kkl0u] , I have tried this, No this doesn't solve

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16305614#comment-16305614 ] Shashank Agarwal commented on FLINK-7760: - No I have’t changed the version or code. I have done

[jira] [Created] (FLINK-8319) Savepoint restore failing in CEP

Shashank Agarwal created FLINK-8319: --- Summary: Savepoint restore failing in CEP Key: FLINK-8319 URL: https://issues.apache.org/jira/browse/FLINK-8319 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-7760: - Restore failing from savepoint too in 1.4.0 Printing following logs : {code}

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

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7760: Fix Version/s: 1.4.1 1.5.0 > Restore failing from external checkpointing

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-6321: - Still not working in 1.4.2 Refere issue : https://issues.apache.org/jira/browse/FLINK-7756

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-6321: Fix Version/s: 1.4.1 1.5.0 > RocksDB state backend Checkpointing is not

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Fix Version/s: 1.4.1 1.5.0 > RocksDB state backend Checkpointing (Async

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Affects Version/s: 1.4.0 > RocksDB state backend Checkpointing (Async and Incremental) is

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-7756: - Checked with version 1.4.0 still coming this issue, I have checked it's creating files and

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276799#comment-16276799 ] Shashank Agarwal commented on FLINK-8182: - I think it gets stuck in the first directory cause it's

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274262#comment-16274262 ] Shashank Agarwal commented on FLINK-8182: - Actually I have checked it for around 10 mins till 300

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274215#comment-16274215 ] Shashank Agarwal commented on FLINK-8182: - Actually it's unable to access listing after the change

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274195#comment-16274195 ] Shashank Agarwal commented on FLINK-8182: - are you using : import

[jira] [Created] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

Shashank Agarwal created FLINK-8182: --- Summary: Unable to read hdfs file system directory(which contains sub directories) recursively Key: FLINK-8182 URL: https://issues.apache.org/jira/browse/FLINK-8182

[jira] [Closed] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal closed FLINK-8098. --- Resolution: Not A Problem > LeaseExpiredException when using FsStateBackend for checkpointing

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264222#comment-16264222 ] Shashank Agarwal commented on FLINK-8098: - yes, agree with the scenario. About file cleanup, i

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264148#comment-16264148 ] Shashank Agarwal commented on FLINK-8098: - I got the main issue after another crash. I had another

[jira] [Commented] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259659#comment-16259659 ] Shashank Agarwal commented on FLINK-8098: - Actually, we are not running any script on that

[jira] [Updated] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

[ https://issues.apache.org/jira/browse/FLINK-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-8098: Fix Version/s: 1.4.0 > LeaseExpiredException when using FsStateBackend for checkpointing

[jira] [Created] (FLINK-8098) LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file.

Shashank Agarwal created FLINK-8098: --- Summary: LeaseExpiredException when using FsStateBackend for checkpointing due to multiple mappers tries to access the same file. Key: FLINK-8098 URL:

[jira] [Created] (FLINK-7953) Kafka consumer printing error - java.lang.IllegalArgumentException: Invalid offset: -915623761772

Shashank Agarwal created FLINK-7953: --- Summary: Kafka consumer printing error - java.lang.IllegalArgumentException: Invalid offset: -915623761772 Key: FLINK-7953 URL:

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

[ 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-7760) Restore failing from external checkpointing metadata.

[ 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-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ 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-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ 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-7760) Restore failing from external checkpointing metadata.

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

[ 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-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ 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-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ 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] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199946#comment-16199946 ] Shashank Agarwal commented on FLINK-6321: - It's coming in 1.3.2 also. I have used Keyedcep with 2

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199946#comment-16199946 ] Shashank Agarwal edited comment on FLINK-6321 at 10/11/17 8:14 AM: --- It's

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

Shashank Agarwal created FLINK-7760: --- Summary: Restore failing from external checkpointing metadata. Key: FLINK-7760 URL: https://issues.apache.org/jira/browse/FLINK-7760 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189913#comment-16189913 ] Shashank Agarwal commented on FLINK-7756: - [~StephanEwen] Actually my code base is very large

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

Shashank Agarwal created FLINK-7756: --- Summary: RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. Key: FLINK-7756 URL: https://issues.apache.org/jira/browse/FLINK-7756

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

[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140606#comment-16140606 ] Shashank Agarwal commented on FLINK-7484: - Got another crash. I have not used any INR class in

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

[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135101#comment-16135101 ] Shashank Agarwal commented on FLINK-7484: - Hi [~yew1eb] It's very big code base, With lot of

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

Shashank Agarwal created FLINK-7484: --- Summary: com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5 Key: FLINK-7484 URL:

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062257#comment-16062257 ] Shashank Agarwal commented on FLINK-6997: - I have tried savepoint on release-1.3 getting same

[jira] [Created] (FLINK-6993) Not reading recursive files in Batch by using readTextFile when file name contains _ in starting.

Shashank Agarwal created FLINK-6993: --- Summary: Not reading recursive files in Batch by using readTextFile when file name contains _ in starting. Key: FLINK-6993 URL:

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056326#comment-16056326 ] Shashank Agarwal commented on FLINK-6844: - So what is the release date for version 1.3.1 cause i

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055854#comment-16055854 ] Shashank Agarwal commented on FLINK-6844: - [~tzulitai] I am using kafka as source and there's no

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055824#comment-16055824 ] Shashank Agarwal commented on FLINK-6844: - I have cross variefied with source code and flink

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055816#comment-16055816 ] Shashank Agarwal commented on FLINK-6844: - There is no more stack traces it's printing after

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055813#comment-16055813 ] Shashank Agarwal commented on FLINK-6844: - [~tzulitai] I have applied this patch on

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055804#comment-16055804 ] Shashank Agarwal commented on FLINK-6844: - [~tzulitai] Checked with patch not working with

[jira] [Comment Edited] (FLINK-6954) Flink 1.3 checkpointing failing with KeyedCEPPatternOperator

[ https://issues.apache.org/jira/browse/FLINK-6954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055794#comment-16055794 ] Shashank Agarwal edited comment on FLINK-6954 at 6/20/17 1:55 PM: --

[jira] [Reopened] (FLINK-6954) Flink 1.3 checkpointing failing with KeyedCEPPatternOperator

[ https://issues.apache.org/jira/browse/FLINK-6954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-6954: - Checked with patch not working with KeyedCEPPatternOperator. > Flink 1.3 checkpointing

[jira] [Closed] (FLINK-6954) Flink 1.3 checkpointing failing with KeyedCEPPatternOperator

[ https://issues.apache.org/jira/browse/FLINK-6954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal closed FLINK-6954. --- Resolution: Duplicate Fix Version/s: 1.3.1 > Flink 1.3 checkpointing failing with

[jira] [Created] (FLINK-6954) Flink 1.3 checkpointing failing with KeyedCEPPatternOperator

Shashank Agarwal created FLINK-6954: --- Summary: Flink 1.3 checkpointing failing with KeyedCEPPatternOperator Key: FLINK-6954 URL: https://issues.apache.org/jira/browse/FLINK-6954 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013942#comment-16013942 ] Shashank Agarwal commented on FLINK-6321: - Hi [~kkl0u] , Please find SignalDeserializationSchema

[jira] [Commented] (FLINK-6460) Build Fat Jar failed while building with SBT Assembly flink 1.2.1

[ https://issues.apache.org/jira/browse/FLINK-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998033#comment-15998033 ] Shashank Agarwal commented on FLINK-6460: - I have solved this issue by adding following Merge

[jira] [Created] (FLINK-6460) Build Fat Jar failed while building with SBT Assembly flink 1.2.1

Shashank Agarwal created FLINK-6460: --- Summary: Build Fat Jar failed while building with SBT Assembly flink 1.2.1 Key: FLINK-6460 URL: https://issues.apache.org/jira/browse/FLINK-6460 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998019#comment-15998019 ] Shashank Agarwal commented on FLINK-6321: - Hi [~kkl0u] , Actually it's too complicated with kafka

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990738#comment-15990738 ] Shashank Agarwal commented on FLINK-6321: - Hi [~kkl0u] , Thanks, Actually i am bit busy with

[jira] [Comment Edited] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeydCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990738#comment-15990738 ] Shashank Agarwal edited comment on FLINK-6321 at 5/1/17 11:38 AM: -- Hi

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976390#comment-15976390 ] Shashank Agarwal commented on FLINK-6321: - Yes it was failing endlessly, As i had restart policy

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976378#comment-15976378 ] Shashank Agarwal commented on FLINK-6321: - It's not working with RocksDBBackend but it's working

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976345#comment-15976345 ] Shashank Agarwal commented on FLINK-6321: - I have checked This is printing same Logs which i have

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-6321: Description: Checkpointing is not working with RocksDBStateBackend when using CEP. It's

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

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-6321: Description: Checkpointing is not working with RocksDBStateBackend when using CEP. It's

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

Shashank Agarwal created FLINK-6321: --- Summary: RocksDB state backend Checkpointing is not working with KeydCEP. Key: FLINK-6321 URL: https://issues.apache.org/jira/browse/FLINK-6321 Project: Flink

[jira] [Commented] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend

[ https://issues.apache.org/jira/browse/FLINK-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966258#comment-15966258 ] Shashank Agarwal commented on FLINK-4169: - Again getting this error in flink 1.2, Running on yarn