[jira] [Commented] (FLINK-37421) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment

[ https://issues.apache.org/jira/browse/FLINK-37421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932440#comment-17932440 ] Yaroslav Tkachenko commented on FLINK-37421: [~jklaw90] you can add labels a

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896846#comment-17896846 ] Yaroslav Tkachenko commented on FLINK-36673: Using 1.19.1. Yeah, it could be

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896829#comment-17896829 ] Yaroslav Tkachenko commented on FLINK-36673: Fair enough, the issue is proba

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896744#comment-17896744 ] Yaroslav Tkachenko commented on FLINK-36673: {quote}The problem seems to be

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896741#comment-17896741 ] Yaroslav Tkachenko commented on FLINK-36673: {quote}The PR you linked doesn'

[jira] [Created] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

Yaroslav Tkachenko created FLINK-36673: -- Summary: Operator is not properly handling failed deployments without savepoints Key: FLINK-36673 URL: https://issues.apache.org/jira/browse/FLINK-36673 P

[jira] [Commented] (FLINK-33622) table.optimizer.reuse-sub-plan-enabled doesn't work when a Table is converted to a DataStream

[ https://issues.apache.org/jira/browse/FLINK-33622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794832#comment-17794832 ] Yaroslav Tkachenko commented on FLINK-33622: > why don't you apply the filte

[jira] [Created] (FLINK-33622) table.optimizer.reuse-sub-plan-enabled doesn't work when a Table is converted to a DataStream

Yaroslav Tkachenko created FLINK-33622: -- Summary: table.optimizer.reuse-sub-plan-enabled doesn't work when a Table is converted to a DataStream Key: FLINK-33622 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Commented] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785575#comment-17785575 ] Yaroslav Tkachenko commented on FLINK-29288: Standalone mode. I think it may

[jira] [Commented] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783816#comment-17783816 ] Yaroslav Tkachenko commented on FLINK-29288: Yep, it should work out of the

[jira] [Commented] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783773#comment-17783773 ] Yaroslav Tkachenko commented on FLINK-29288: > what is the correct procedure

[jira] [Closed] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaroslav Tkachenko closed FLINK-32814. -- Resolution: Won't Fix > Support disabling failed JM shutdown in the operator > ---

[jira] [Commented] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752493#comment-17752493 ] Yaroslav Tkachenko commented on FLINK-32814: It's your call :) It is a nich

[jira] [Commented] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752170#comment-17752170 ] Yaroslav Tkachenko commented on FLINK-32814: [~gyfora] true! I had to set it

[jira] [Created] (FLINK-32814) Support disabling failed JM shutdown in the operator

Yaroslav Tkachenko created FLINK-32814: -- Summary: Support disabling failed JM shutdown in the operator Key: FLINK-32814 URL: https://issues.apache.org/jira/browse/FLINK-32814 Project: Flink

[jira] [Updated] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaroslav Tkachenko updated FLINK-32814: --- Description: Currently, it's not possible to disable the shutdown of the jobmanager

[jira] [Commented] (FLINK-32242) Datadog HTTP Reporter produces a huge outgoing traffic and CPU overhead

[ https://issues.apache.org/jira/browse/FLINK-32242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728421#comment-17728421 ] Yaroslav Tkachenko commented on FLINK-32242: This is not surprising. I've al

[jira] [Commented] (FLINK-28842) Add client.id.prefix for the KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722601#comment-17722601 ] Yaroslav Tkachenko commented on FLINK-28842: Hi Valentina, unfortunately I d

[jira] [Commented] (FLINK-31285) FileSource should support reading files in order

[ https://issues.apache.org/jira/browse/FLINK-31285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695425#comment-17695425 ] Yaroslav Tkachenko commented on FLINK-31285: I think FileSplitAssigner is th

[jira] [Created] (FLINK-31285) FileSource should support reading files in order

Yaroslav Tkachenko created FLINK-31285: -- Summary: FileSource should support reading files in order Key: FLINK-31285 URL: https://issues.apache.org/jira/browse/FLINK-31285 Project: Flink

[jira] [Commented] (FLINK-31095) FileSink doesn't work with s3a on EKS

[ https://issues.apache.org/jira/browse/FLINK-31095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689491#comment-17689491 ] Yaroslav Tkachenko commented on FLINK-31095: It works for me (specifically o

[jira] [Commented] (FLINK-31049) Add support for Kafka record headers to KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688622#comment-17688622 ] Yaroslav Tkachenko commented on FLINK-31049: Thanks for the update! It makes

[jira] [Commented] (FLINK-31049) Add support for Kafka record headers to KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688153#comment-17688153 ] Yaroslav Tkachenko commented on FLINK-31049: Hi Alex, Would you mind correc

[jira] [Commented] (FLINK-30873) FileSystem Table API connector doesn't discover new files when partitions are specified

[ https://issues.apache.org/jira/browse/FLINK-30873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683493#comment-17683493 ] Yaroslav Tkachenko commented on FLINK-30873: [~mateczagany] feel free to pic

[jira] [Created] (FLINK-30873) FileSystem Table API connector doesn't discover new files when partitions are specified

Yaroslav Tkachenko created FLINK-30873: -- Summary: FileSystem Table API connector doesn't discover new files when partitions are specified Key: FLINK-30873 URL: https://issues.apache.org/jira/browse/FLINK-3087

[jira] [Created] (FLINK-29633) Operator doesn't pass initialSavepointPath as fromSavepoint argument

Yaroslav Tkachenko created FLINK-29633: -- Summary: Operator doesn't pass initialSavepointPath as fromSavepoint argument Key: FLINK-29633 URL: https://issues.apache.org/jira/browse/FLINK-29633 Proj

[jira] [Comment Edited] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603817#comment-17603817 ] Yaroslav Tkachenko edited comment on FLINK-29288 at 9/14/22 4:13 PM: -

[jira] [Commented] (FLINK-29288) Can't start a job with a jar in the system classpath

[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603817#comment-17603817 ] Yaroslav Tkachenko commented on FLINK-29288: Apparently removing *pipeline.j

[jira] [Created] (FLINK-29288) Can't start a job with a jar in the system classpath

Yaroslav Tkachenko created FLINK-29288: -- Summary: Can't start a job with a jar in the system classpath Key: FLINK-29288 URL: https://issues.apache.org/jira/browse/FLINK-29288 Project: Flink

[jira] [Commented] (FLINK-28842) Add client.id.prefix for the KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576047#comment-17576047 ] Yaroslav Tkachenko commented on FLINK-28842: I believe this will also fix ht

[jira] [Created] (FLINK-28842) Add client.id.prefix for the KafkaSink

Yaroslav Tkachenko created FLINK-28842: -- Summary: Add client.id.prefix for the KafkaSink Key: FLINK-28842 URL: https://issues.apache.org/jira/browse/FLINK-28842 Project: Flink Issue Type

[jira] [Commented] (FLINK-27873) Primary key is lost after calling addColumns

[ https://issues.apache.org/jira/browse/FLINK-27873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551181#comment-17551181 ] Yaroslav Tkachenko commented on FLINK-27873: Re: 1.15, I haven't actually tr

[jira] [Created] (FLINK-27873) Primary key is lost after calling addColumns

Yaroslav Tkachenko created FLINK-27873: -- Summary: Primary key is lost after calling addColumns Key: FLINK-27873 URL: https://issues.apache.org/jira/browse/FLINK-27873 Project: Flink Issu

[jira] [Commented] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541275#comment-17541275 ] Yaroslav Tkachenko commented on FLINK-18640: I'd love to address this issue,

[jira] [Commented] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531875#comment-17531875 ] Yaroslav Tkachenko commented on FLINK-25205: Hey everyone, I was going to op

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaroslav Tkachenko updated FLINK-25205: --- Attachment: flamegraph-final.html > Optimize SinkUpsertMaterializer > --

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaroslav Tkachenko updated FLINK-25205: --- Attachment: without-SinkUpsertMaterializer.png with-SinkUpsertMateria

[jira] [Commented] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454364#comment-17454364 ] Yaroslav Tkachenko commented on FLINK-25164: Another thought, would you reco

[jira] [Commented] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454362#comment-17454362 ] Yaroslav Tkachenko commented on FLINK-25164: [~chesnay] just to confirm, are

[jira] [Comment Edited] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453447#comment-17453447 ] Yaroslav Tkachenko edited comment on FLINK-25164 at 12/4/21, 4:36 PM:

[jira] [Commented] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453447#comment-17453447 ] Yaroslav Tkachenko commented on FLINK-25164: [~chesnay] yes! That, [https:/

[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453293#comment-17453293 ] Yaroslav Tkachenko commented on FLINK-7009: --- Created another issue https://issu

[jira] [Created] (FLINK-25164) DogStatsD Metrics Reporter

Yaroslav Tkachenko created FLINK-25164: -- Summary: DogStatsD Metrics Reporter Key: FLINK-25164 URL: https://issues.apache.org/jira/browse/FLINK-25164 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426853#comment-17426853 ] Yaroslav Tkachenko commented on FLINK-21986: We had a very similar problem i

[jira] [Created] (FLINK-23127) Can't use plugins for GCS filesystem

Yaroslav Tkachenko created FLINK-23127: -- Summary: Can't use plugins for GCS filesystem Key: FLINK-23127 URL: https://issues.apache.org/jira/browse/FLINK-23127 Project: Flink Issue Type: