> once the feature is merged.
> Best Regards
> Ahmed Hamdy
>
>
> On Mon, 28 Apr 2025 at 17:22, Lorenzo Nicora
> wrote:
>
> > Hello
> > the current version of Kinesis source (5.0.0) lacks support for KLP
> > de-aggregation [1]
> > There is a pend
Hello
the current version of Kinesis source (5.0.0) lacks support for KLP
de-aggregation [1]
There is a pending PR [2] but it breaks the API and will require a new
major version of the connector.
I implemented an alternative solution using a DeserializationSchema wrapper
which adds de-aggregation
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
+1 (non binding)
- verified checksums
- run an e2e application using the 1.0.0-1.20 artifacts, (including Amazon
Managed Prometheus request signer)
Best regards
Lorenzo
On Tue, 5 Nov 2024 at 07:37, Xintong Song wrote:
> +1 (binding)
>
> - verified signatures and checksum
> - built from source
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
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
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
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-36008:
--
Summary: Guidance for connector docs contributions
Key: FLINK-36008
URL: https://issues.apache.org/jira/browse/FLINK-36008
Project: Flink
Issue Type
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-33141:
--
Summary: Promentheus Sink Connector - Amazon Managed Prometheus
Request Signer
Key: FLINK-33141
URL: https://issues.apache.org/jira/browse/FLINK-33141
Project
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
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
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-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-33137:
--
Summary: FLIP-312: Prometheus Sink Connector
Key: FLINK-33137
URL: https://issues.apache.org/jira/browse/FLINK-33137
Project: Flink
Issue Type: New
Hello
The proposal FLIP-312: Prometheus Sink Connector, has been approved with 8
votes (6 binding)
Thanks everybody
Lorenzo
e AWS signer in the AWS
> repo, without taking a dependency on Prometheus. Thus the connectors are
> completely decoupled and the core Prometheus repo does not contain any AWS
> pollution?
>
> Danny
>
> On Mon, 18 Sept 2023, 18:16 Lorenzo Nicora,
> wrote:
>
> > Hi Dann
tor-aws [2]?
>
> Thanks,
> Danny
>
> [1] https://lists.apache.org/thread/fowhltc1n0tn4627ycwhrd5p8ds77lm8
> [2]
>
> https://github.com/apache/flink-connector-aws/blob/main/flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java#L91
&
document/d/1LPhVRSFkGNSuU1fBd81ulhsCPR4hkSZyyBj1SZ8fWOM/edit
Lorenzo
On Sun, 17 Sept 2023 at 09:51, Ahmed Hamdy wrote:
> Thanks Lorenzo,
> Looking forward to the PRs.
> Best Regards
> Ahmed Hamdy
>
>
> On Sat, 16 Sept 2023 at 06:27, Lorenzo Nicora
> wrote:
>
> > Hello
>
/tm4qqfb4fxr7bc6nq5mwty1fqz8sj39x
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-312%3A+Prometheus+Sink+Connector
Regards
Lorenzo Nicora
Hello
(apologies if this is a duplicate reply)
I was working with Karthi on this connector, and I have taken over the
development.
We have a working version we would like to submit to the community.
The renumbered FLIP-312 is also updated with more details [1].
Happy to answer any questions.
Re
Hello
I was working with Karthi and took over development. I have a working
version already.
I also updated the FLIP (now FLIP-312, it was renumbered due to a clash)
Please, let me know how to proceed with this. Happy to answer any questions
about the FLIP
Regards
Lorenzo
[1]
https://cwiki.apach
Hi everybody
I am working with Karthi on this connector. I think I can address some of
the concerns raised by Danny et al. I do not have write access to the FLIP
yet, but I will get it and do some edits. Also regarding the motivation, as
suggested by Martijn.
Q1) The fact we are using the remote
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
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
26 matches
Mail list logo
