static-max created FLINK-16574:
--
Summary: StreamingFileSink should rename files or fail if
destination file already exists
Key: FLINK-16574
URL: https://issues.apache.org/jira/browse/FLINK-16574
[
https://issues.apache.org/jira/browse/FLINK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027461#comment-17027461
]
static-max commented on FLINK-15832:
Setting {{shadeTestJar}} to {{false}} resolves the problem.
>
static-max created FLINK-15832:
--
Summary: Artifact flink-metrics-core-tests will be uploaded twice
Key: FLINK-15832
URL: https://issues.apache.org/jira/browse/FLINK-15832
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021282#comment-17021282
]
static-max commented on FLINK-13689:
Hi there, I would like to contribute the changes proposed by
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15690734#comment-15690734
]
static-max commented on FLINK-3404:
---
I'm in need of a _stop()_ method too, I will propose an PR for this
[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
static-max reassigned FLINK-5122:
-
Assignee: static-max
> Elasticsearch Sink loses documents when cluster has high load
>
[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686338#comment-15686338
]
static-max commented on FLINK-5122:
---
Your PR does not handle single failed bulk requests, as far as I
static-max created FLINK-5122:
-
Summary: Elasticsearch Sink loses documents when cluster has high
load
Key: FLINK-5122
URL: https://issues.apache.org/jira/browse/FLINK-5122
Project: Flink
Issue
static-max created FLINK-4779:
-
Summary: Restoring from savepoint fails when BucketingSink has not
yet created folder
Key: FLINK-4779
URL: https://issues.apache.org/jira/browse/FLINK-4779
Project: Flink
