[
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
[
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
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
[
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
[
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
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
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
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:
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
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
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
[
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
> -
[
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
[
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
[
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
[
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
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:
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
[
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
[
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
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
[
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}}
[
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}}
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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:
---
[
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
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
[
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
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
[
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
[
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
[
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.
[
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
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-
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:
[
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
45 matches
Mail list logo