[jira] [Comment Edited] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

2018-12-17 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723279#comment-16723279 ] Sayat Satybaldiyev edited comment on FLINK-11171 at 12/17/18 7:11 PM:

[jira] [Commented] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

2018-12-17 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723279#comment-16723279 ] Sayat Satybaldiyev commented on FLINK-11171: [~yunta] agrees, the exception

[jira] [Commented] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

2018-12-16 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722462#comment-16722462 ] Sayat Satybaldiyev commented on FLINK-11171: cc: [~azagrebin], [~srichter]

[jira] [Created] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

2018-12-16 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-11171: -- Summary: Unexpected timestamp deserialization failure in RocksDB state backend Key: FLINK-11171 URL: https://issues.apache.org/jira/browse/FLINK-11171 Pro

[jira] [Created] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

2018-09-20 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-10380: -- Summary: Check if key is not nul before assign to group in KeyedStream Key: FLINK-10380 URL: https://issues.apache.org/jira/browse/FLINK-10380 Project: Fl

[jira] [Commented] (FLINK-10287) Flink HA Persist Cancelled Job in Zookeeper

2018-09-05 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604505#comment-16604505 ] Sayat Satybaldiyev commented on FLINK-10287: Might be related to https://iss

[jira] [Created] (FLINK-10287) Flink HA Persist Cancelled Job in Zookeeper

2018-09-05 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-10287: -- Summary: Flink HA Persist Cancelled Job in Zookeeper Key: FLINK-10287 URL: https://issues.apache.org/jira/browse/FLINK-10287 Project: Flink Issue

[jira] [Commented] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

2018-09-05 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604477#comment-16604477 ] Sayat Satybaldiyev commented on FLINK-10286: [~GJL] I believe it causes the

[jira] [Updated] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

2018-09-05 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayat Satybaldiyev updated FLINK-10286: --- Description: In HA mode Flink 1.6, Flink persist job graph in Zookpeer even if the j

[jira] [Created] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

2018-09-05 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-10286: -- Summary: Flink Persist Invalid Job Graph in Zookeeper Key: FLINK-10286 URL: https://issues.apache.org/jira/browse/FLINK-10286 Project: Flink Issu

[jira] [Commented] (FLINK-9831) Too many open files for RocksDB

2018-08-14 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579888#comment-16579888 ] Sayat Satybaldiyev commented on FLINK-9831: --- I've setup PredefinedOptions.SPINN

[jira] [Commented] (FLINK-9831) Too many open files for RocksDB

2018-07-12 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541610#comment-16541610 ] Sayat Satybaldiyev commented on FLINK-9831: --- [~srichter] I think I found an iss

[jira] [Created] (FLINK-9831) Too many open files for RocksDB

2018-07-12 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-9831: - Summary: Too many open files for RocksDB Key: FLINK-9831 URL: https://issues.apache.org/jira/browse/FLINK-9831 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

2018-07-12 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541363#comment-16541363 ] Sayat Satybaldiyev commented on FLINK-9805: --- Is there anything like "debug" mod

[jira] [Commented] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

2018-07-11 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16540048#comment-16540048 ] Sayat Satybaldiyev commented on FLINK-9805: --- Flink cluster setup in HA mode. It

[jira] [Comment Edited] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

2018-07-11 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16540011#comment-16540011 ] Sayat Satybaldiyev edited comment on FLINK-9805 at 7/11/18 12:45 PM: --

[jira] [Commented] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

2018-07-11 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16540011#comment-16540011 ] Sayat Satybaldiyev commented on FLINK-9805: --- [~Zentol] But shouldn't a client a

[jira] [Created] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

2018-07-11 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-9805: - Summary: HTTP Redirect to Active JM in Flink CLI Key: FLINK-9805 URL: https://issues.apache.org/jira/browse/FLINK-9805 Project: Flink Issue Type: I

[jira] [Created] (FLINK-9711) Flink CLI does not filter RUNNING only jobs

2018-07-03 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-9711: - Summary: Flink CLI does not filter RUNNING only jobs Key: FLINK-9711 URL: https://issues.apache.org/jira/browse/FLINK-9711 Project: Flink Issue Typ

[jira] [Updated] (FLINK-9711) Flink CLI --running option does not show RUNNING only jobs

2018-07-03 Thread Sayat Satybaldiyev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayat Satybaldiyev updated FLINK-9711: -- Summary: Flink CLI --running option does not show RUNNING only jobs (was: Flink CLI do

[jira] [Created] (FLINK-9705) Failed to close kafka producer - Interrupted while joining ioThread

2018-07-02 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-9705: - Summary: Failed to close kafka producer - Interrupted while joining ioThread Key: FLINK-9705 URL: https://issues.apache.org/jira/browse/FLINK-9705 Project: