[jira] [Commented] (FLINK-33142) Prometheus Sink Connector - Update Documentation

2024-06-19 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856331#comment-17856331 ] Lorenzo Nicora commented on FLINK-33142: [~Hong Teoh] can you please assign this

[jira] [Commented] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API

2023-12-29 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801142#comment-17801142 ] Lorenzo Nicora commented on FLINK-24379: I picked up the work and submitted a PR

[jira] [Created] (FLINK-36008) Guidance for connector docs contributions

2024-08-08 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36008: -- Summary: Guidance for connector docs contributions Key: FLINK-36008 URL: https://issues.apache.org/jira/browse/FLINK-36008 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions

2024-08-08 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36008: --- Summary: Guidance for previewing connector docs contributions (was: Guidance for connector

[jira] [Commented] (FLINK-36008) Guidance for previewing connector docs contributions

2024-08-08 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871994#comment-17871994 ] Lorenzo Nicora commented on FLINK-36008: I created a PR with the small change re

[jira] [Created] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-23 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33137: -- Summary: FLIP-312: Prometheus Sink Connector Key: FLINK-33137 URL: https://issues.apache.org/jira/browse/FLINK-33137 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-09-23 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33138: -- Summary: Prometheus Connector Sink - DataStream API implementation Key: FLINK-33138 URL: https://issues.apache.org/jira/browse/FLINK-33138 Project: Flink

[jira] [Created] (FLINK-33139) Prometheus Sink Connector - Table API support

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33139: -- Summary: Prometheus Sink Connector - Table API support Key: FLINK-33139 URL: https://issues.apache.org/jira/browse/FLINK-33139 Project: Flink Issue Type:

[jira] [Created] (FLINK-33140) Prometheus Sink Connector - E2E test

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33140: -- Summary: Prometheus Sink Connector - E2E test Key: FLINK-33140 URL: https://issues.apache.org/jira/browse/FLINK-33140 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33142) Prometheus Sink Connector - Update Documentation

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33142: -- Summary: Prometheus Sink Connector - Update Documentation Key: FLINK-33142 URL: https://issues.apache.org/jira/browse/FLINK-33142 Project: Flink Issue Ty

[jira] [Created] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33141: -- Summary: Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Key: FLINK-33141 URL: https://issues.apache.org/jira/browse/FLINK-33141 Project: Fl

[jira] [Updated] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-24 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33137: --- Labels: Connector (was: ) > FLIP-312: Prometheus Sink Connector > -

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Description: End-to-end example application, to be deployed on Amazon Managed Service for Ap

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Summary: Prometheus Sink Connector - E2E example (was: Prometheus Sink Connector - E2E test

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example on AWS

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Description: End-to-end example application, deployable on Amazon Managed Service for Apache

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example on AWS

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Summary: Prometheus Sink Connector - E2E example on AWS (was: Prometheus Sink Connector - E

[jira] [Created] (FLINK-33152) Prometheus Sink Connector - Integration tests

2023-09-25 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33152: -- Summary: Prometheus Sink Connector - Integration tests Key: FLINK-33152 URL: https://issues.apache.org/jira/browse/FLINK-33152 Project: Flink Issue Type:

[jira] [Created] (FLINK-18223) AvroSerializer does not correctly instantiate GenericRecord

2020-06-09 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-18223: -- Summary: AvroSerializer does not correctly instantiate GenericRecord Key: FLINK-18223 URL: https://issues.apache.org/jira/browse/FLINK-18223 Project: Flink

[jira] [Commented] (FLINK-18223) AvroSerializer does not correctly instantiate GenericRecord

2020-06-10 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130570#comment-17130570 ] Lorenzo Nicora commented on FLINK-18223: This is what I'm trying to do, [~aljosc

[jira] [Commented] (FLINK-18223) AvroSerializer does not correctly instantiate GenericRecord

2020-06-10 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130894#comment-17130894 ] Lorenzo Nicora commented on FLINK-18223: I submitted a PR but the bot complains

[jira] [Created] (FLINK-17486) ClassCastException when copying AVRO SpecificRecord containing a decimal field

2020-04-30 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-17486: -- Summary: ClassCastException when copying AVRO SpecificRecord containing a decimal field Key: FLINK-17486 URL: https://issues.apache.org/jira/browse/FLINK-17486 Pr

[jira] [Updated] (FLINK-17486) ClassCastException when copying AVRO SpecificRecord containing a decimal field

2020-04-30 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-17486: --- Description: When consuming from a Kafka source AVRO SpecificRecord containing a {{decimal}}

[jira] [Updated] (FLINK-17486) ClassCastException when copying AVRO SpecificRecord containing a decimal field

2020-04-30 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-17486: --- Description: When consuming from a Kafka source AVRO SpecificRecord containing a {{decimal}}

[jira] [Updated] (FLINK-17486) ClassCastException when copying AVRO SpecificRecord containing a decimal field

2020-05-01 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-17486: --- Labels: AVRO confluent-kafka kafka (was: ) > ClassCastException when copying AVRO SpecificR

[jira] [Updated] (FLINK-17486) ClassCastException when checkpointing AVRO SpecificRecord with decimal fields

2020-05-04 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-17486: --- Summary: ClassCastException when checkpointing AVRO SpecificRecord with decimal fields (was

[jira] [Closed] (FLINK-36400) 403 and 404 responses should be fatal

2024-10-28 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora closed FLINK-36400. -- Release Note: Fixed as part of changing error handling behavior Resolution: Fixed > 403

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36603: --- Summary: Inconsistent spelling of "behavior" and "retryable" across the API (was: Inconsist

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36603: --- Description: The spelling of the word "behavior" is inconsistent across the API e.g. {{.set

[jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API

2024-10-25 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36603: -- Summary: Inconsistent spelling of "behavior" across the API Key: FLINK-36603 URL: https://issues.apache.org/jira/browse/FLINK-36603 Project: Flink Issue

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897894#comment-17897894 ] Lorenzo Nicora commented on FLINK-36595: The remaining connectors have no releas

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897891#comment-17897891 ] Lorenzo Nicora commented on FLINK-36595: flink-connector-mongodb Fixed missing

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897892#comment-17897892 ] Lorenzo Nicora commented on FLINK-36595: flink-connector-elasticsearch  Fixed m

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897890#comment-17897890 ] Lorenzo Nicora commented on FLINK-36595: flink-connector-cassandra docs data fi

[jira] [Comment Edited] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897891#comment-17897891 ] Lorenzo Nicora edited comment on FLINK-36595 at 11/13/24 11:19 AM: ---

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-13 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897893#comment-17897893 ] Lorenzo Nicora commented on FLINK-36595: flink-connector-rabbitmq Fixed missing

[jira] [Created] (FLINK-36400) 403 and 404 responses should be fatal

2024-09-28 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36400: -- Summary: 403 and 404 responses should be fatal Key: FLINK-36400 URL: https://issues.apache.org/jira/browse/FLINK-36400 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-36400) 403 and 404 responses should be fatal

2024-09-28 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36400: --- Description: h3. The issue If the endpoint requires authentication and the connector is not

[jira] [Created] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

2024-09-29 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36404: -- Summary: PrometheusSinkWriteException thrown by the response callback may not cause job to fail Key: FLINK-36404 URL: https://issues.apache.org/jira/browse/FLINK-36404

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

2024-09-29 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36404: --- Description: *Issue* {{PrometheusSinkWriteException}} thrown by {{HttpResponseCallback}} do

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

2024-09-29 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36404: --- Description: *Issue* {{PrometheusSinkWriteException}} thrown by {{HttpResponseCallback}} do

[jira] [Commented] (FLINK-36400) 403 and 404 responses should be fatal

2024-09-29 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885695#comment-17885695 ] Lorenzo Nicora commented on FLINK-36400: This issue is coupled with FLINK-36404.

[jira] [Updated] (FLINK-36319) FAIL behavior on non-retriable write errors causes an infinite loop when restarting from checkpoint

2024-09-18 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36319: --- Description: The {{FAIL}} (default) error handling behavior when a write request is rejected

[jira] [Created] (FLINK-36319) FAIL behavior on non-retriable write errors causes an infinite loop when restarting from checkpoint

2024-09-18 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36319: -- Summary: FAIL behavior on non-retriable write errors causes an infinite loop when restarting from checkpoint Key: FLINK-36319 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-36667) Remove `proto` schema definitions from source

2024-11-06 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-36667: -- Summary: Remove `proto` schema definitions from source Key: FLINK-36667 URL: https://issues.apache.org/jira/browse/FLINK-36667 Project: Flink Issue Type:

[jira] [Commented] (FLINK-36828) Implement example for customers to perform KPL Deaggregation

2025-04-28 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947873#comment-17947873 ] Lorenzo Nicora commented on FLINK-36828: I have a working [example] ([https://g