[jira] [Closed] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max closed FLINK-18000. --- Resolution: Not A Problem > Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet > 1.18.2 >

[jira] [Commented] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121509#comment-17121509 ] Max commented on FLINK-18000: - Thanks for your quickly response. After read the document that you post. I

[jira] [Updated] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

[ https://issues.apache.org/jira/browse/FLINK-18000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max updated FLINK-18000: Description: Hi all     I try to delpoy the kubernetes-session.sh on my kubernetes 1.18, but it failed. I got a

[jira] [Created] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2

Max created FLINK-18000: --- Summary: Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2 Key: FLINK-18000 URL: https://issues.apache.org/jira/browse/FLINK-18000 Project: Flink

[jira] [Created] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists

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

[jira] [Commented] (FLINK-15832) Artifact flink-metrics-core-tests will be uploaded twice

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

[jira] [Created] (FLINK-15832) Artifact flink-metrics-core-tests will be uploaded twice

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

[jira] [Commented] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

[ 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

[jira] [Updated] (FLINK-10604) Add REMAINDER math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max updated FLINK-10604: Summary: Add REMAINDER math function supported in Table API and SQL (was: Add Remainder math function supported

[jira] [Commented] (FLINK-10604) Add Remainder math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16655234#comment-16655234 ] Max commented on FLINK-10604: - May you assign this ticket to me please? > Add Remainder math function

[jira] [Created] (FLINK-10604) Add Remainder math function supported in Table API and SQL

Max created FLINK-10604: --- Summary: Add Remainder math function supported in Table API and SQL Key: FLINK-10604 URL: https://issues.apache.org/jira/browse/FLINK-10604 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

[ 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

[jira] [Assigned] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

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

[jira] [Commented] (FLINK-5122) 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

[jira] [Created] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

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

[jira] [Created] (FLINK-4779) Restoring from savepoint fails when BucketingSink has not yet created folder

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