[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646230#comment-16646230
]
Rinat Sharipov edited comment on FLINK-9592 at 10/11/18 11:17 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646230#comment-16646230
]
Rinat Sharipov commented on FLINK-9592:
---
Hi [~kkl0u] , during the process of migrat
[
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
*org.apache.flink.api.common.seri
[
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
*org.apache.flink.api.common.seri
[
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
*org.apache.flink.api.common.seri
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
Project
[
https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515084#comment-16515084
]
Rinat Sharipov commented on FLINK-9603:
---
I've created a PR, that fixes this problem
[
https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515072#comment-16515072
]
Rinat Sharipov commented on FLINK-9603:
---
Hi mates, I got the following proposal abo
[
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
the
[
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
the
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
[
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 loggi
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
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513555#comment-16513555
]
Rinat Sharipov commented on FLINK-9592:
---
[~kkl0u], I will be glad to help )) Thx
>
[
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 implem
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 Fe
[
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/
[
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,
us
[
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,
us
[
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,
usi
[
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
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 T
[
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 j
[
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 j
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
25 matches
Mail list logo
