[jira] [Comment Edited] (FLINK-9592) Notify on moving file into pending/ final state

2018-10-11 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646230#comment-16646230 ] Rinat Sharipov edited comment on FLINK-9592 at 10/11/18 11:17 AM: -- Hi 

[jira] [Commented] (FLINK-9592) Notify on moving file into pending/ final state

2018-10-11 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646230#comment-16646230 ] Rinat Sharipov commented on FLINK-9592: --- Hi [~kkl0u] , during the process of migration to the

[jira] [Updated] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-10 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-10525: --- Description: Hi mates, in accordance with the contract of 

[jira] [Updated] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-10 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-10525: --- Description: Hi mates, in accordance with the contract of 

[jira] [Updated] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-10 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-10525: --- Description: Hi mates, in accordance with the contract of 

[jira] [Created] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-10 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-10525: -- Summary: Deserialization schema, skip data, that couldn't be properly deserialized Key: FLINK-10525 URL: https://issues.apache.org/jira/browse/FLINK-10525

[jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515084#comment-16515084 ] Rinat Sharipov commented on FLINK-9603: --- I've created a PR, that fixes this problem, please, have a

[jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16515072#comment-16515072 ] Rinat Sharipov commented on FLINK-9603: --- Hi mates, I got the following proposal about fix of this

[jira] [Updated] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-16 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9603: -- Description: Hi mates, since 1.5 release, BucketingSink has ability to configure suffix of

[jira] [Updated] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-16 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9603: -- Description: Hi mates, since 1.5 release, BucketingSink has ability to configure suffix of

[jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-16 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9603: - Summary: Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) Key: FLINK-9603 URL: https://issues.apache.org/jira/browse/FLINK-9603

[jira] [Updated] (FLINK-9596) Ability to configure logging using single log4j file

2018-06-15 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9596: -- Summary: Ability to configure logging using single log4j file (was: Ability to configure

[jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file

2018-06-15 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9596: - Summary: Ability to configure logging using the same log4j file Key: FLINK-9596 URL: https://issues.apache.org/jira/browse/FLINK-9596 Project: Flink Issue

[jira] [Commented] (FLINK-9592) Notify on moving file into pending/ final state

2018-06-15 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513555#comment-16513555 ] Rinat Sharipov commented on FLINK-9592: --- [~kkl0u], I will be glad to help )) Thx > Notify on

[jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state

2018-06-14 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9592: -- Description: Hi mates, I got a proposal about functionality of BucketingSink.   During

[jira] [Created] (FLINK-9592) Notify on moving into pending/ final state

2018-06-14 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9592: - Summary: Notify on moving into pending/ final state Key: FLINK-9592 URL: https://issues.apache.org/jira/browse/FLINK-9592 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state

2018-06-14 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9592: -- Summary: Notify on moving file into pending/ final state (was: Notify on moving into pending/

[jira] [Updated] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9558: -- Description: Hi mates, we have some Flink jobs, that are writing data from kafka into hdfs,

[jira] [Updated] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9558: -- Description: Hi mates, we have some Flink jobs, that are writing data from kafka into hdfs,

[jira] [Updated] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9558: -- Description: Hi mates, we got some Flink jobs, that are writing data from kafka into hdfs,

[jira] [Updated] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-9558: -- Summary: Memory leaks during usage of bucketing-sink with disabled checkpointing (was: Memory

[jira] [Created] (FLINK-9558) Memory leaks during usage with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9558: - Summary: Memory leaks during usage with disabled checkpointing Key: FLINK-9558 URL: https://issues.apache.org/jira/browse/FLINK-9558 Project: Flink Issue

[jira] [Updated] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

2017-11-02 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-7963: -- Description: Hi guys, I've got an idea of a little improvement for testing flink jobs. All my

[jira] [Updated] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

2017-11-02 Thread Rinat Sharipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rinat Sharipov updated FLINK-7963: -- Description: Hi guys, I've got an idea of a little improvement for testing flink jobs. All my

[jira] [Created] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

2017-11-02 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-7963: - Summary: Add ability to call trigger savepoint on flink cluster shutdown Key: FLINK-7963 URL: https://issues.apache.org/jira/browse/FLINK-7963 Project: Flink