Hi everyone,
Please review and vote on the release candidate #1 for the flink v1.19.1,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
Hong Liang Teoh created FLINK-35532:
---
Summary: Prevent Cross-Site Authentication (XSA) attacks on Flink
dashboard
Key: FLINK-35532
URL: https://issues.apache.org/jira/browse/FLINK-35532
Project
Hong Liang Teoh created FLINK-35512:
---
Summary: ArtifactFetchManagerTest unit tests fail
Key: FLINK-35512
URL: https://issues.apache.org/jira/browse/FLINK-35512
Project: Flink
Issue Type
Hi all,
I would like to discuss creating a new 1.19 patch release (1.19.1). The
last 1.19 release is two months old, and since then, 35 tickets have been
closed [1], of which 7 are blocker/critical [2].
There are 5 items open at the moment; 2 of which are not blocking because
they affect
+1 (binding)
Thanks Ahmed
On Tue, May 14, 2024 at 11:51 AM David Radley
wrote:
> Thanks for the clarification Ahmed
>
> +1 (non-binding)
>
> From: Ahmed Hamdy
> Date: Monday, 13 May 2024 at 19:58
> To: dev@flink.apache.org
> Subject: [EXTERNAL] Re: [VOTE] FLIP-451: Introduce timeout
Hi Ahmed,
Thanks for putting this together! Should we still be marking
getFatalExceptionCons() as @Deprecated in this FLIP, if we are not
providing a replacement?
Regards,
Hong
On Mon, May 13, 2024 at 7:58 PM Ahmed Hamdy wrote:
> Hi David,
> yes there error classification was initially left to
Hi Priya,
Great to see the FLIP has passed the vote.
It would be good to report the final result of the vote at the end of the
thread, listing the binding / non-binding votes in an email. See example
here [1] [2]
Regards,
Hong
[1] https://lists.apache.org/thread/3sj88kk0104vzj4hklfgbn3rpdnjxj8v
Hong Liang Teoh created FLINK-35299:
---
Summary: FlinkKinesisConsumer does not respect
StreamInitialPosition for new Kinesis Stream when restoring from snapshot
Key: FLINK-35299
URL: https://issues.apache.org
Hi Piotr,
Thanks for the FLIP! Nice to see work to improve the filesystem
performance. +1 to future work to improve the upload speed as well. This
would be useful for jobs with large state and high Async checkpointing
times.
Some thoughts on the configuration, it might be good for us to
+1 (binding)
Thanks Priya for driving this! This has been a requested feature for a
while now, and will benefit the community :)
Hong
On Tue, Apr 16, 2024 at 3:23 AM Muhammet Orazov
wrote:
> +1 (non-binding)
>
> Thanks Priya for the FLIP and driving it!
>
> Best,
> Muhammet
>
> On 2024-04-12
+1 (binding)
Thank you for driving this Emre! This is a good step towards better user
experience when diagnosing performance issues with Flink jobs.
Best,
Hong
On Wed, Jan 31, 2024 at 3:00 AM Aleksandr Pilipenko
wrote:
> Thanks for the FLIP!
>
> +1 (non-binding)
>
> Best,
> Aleksandr
>
> On
Hi all,
Recently, we detected some active CVEs on the flink-shaded-guava and
flink-shaded-zookeeper package used in Flink 1.18. Since Flink 1.18 is
still in support for security fixes, we should consider fixing this.
However, since the vulnerable package is coming from flink-shaded, I wanted
to
Hong Liang Teoh created FLINK-33872:
---
Summary: Checkpoint history does not display for completed jobs
Key: FLINK-33872
URL: https://issues.apache.org/jira/browse/FLINK-33872
Project: Flink
+1. Thanks Jing for driving this.
Hong
On Mon, Dec 11, 2023 at 2:27 AM Yun Tang wrote:
> Thanks Jing for driving 1.18.1 release, +1 for this.
>
>
> Best
> Yun Tang
>
> From: Rui Fan <1996fan...@gmail.com>
> Sent: Saturday, December 9, 2023 21:46
> To:
Hong Liang Teoh created FLINK-33259:
---
Summary: flink-connector-aws should use/extend the common
connector workflow
Key: FLINK-33259
URL: https://issues.apache.org/jira/browse/FLINK-33259
Project
Hong Liang Teoh created FLINK-33167:
---
Summary: Run IT tests against Kinesalite if AWS credentials are
not present
Key: FLINK-33167
URL: https://issues.apache.org/jira/browse/FLINK-33167
Project
Hong Liang Teoh created FLINK-33073:
---
Summary: Implement end-to-end tests for the Kinesis Streams Sink
Key: FLINK-33073
URL: https://issues.apache.org/jira/browse/FLINK-33073
Project: Flink
Hong Liang Teoh created FLINK-33072:
---
Summary: Implement end-to-end tests for AWS Kinesis Connectors
Key: FLINK-33072
URL: https://issues.apache.org/jira/browse/FLINK-33072
Project: Flink
Congratulations Matthias!
Very well deserved!
Regards,
Hong
On Fri, Aug 4, 2023 at 10:38 AM Markos Sfikas
wrote:
> Congrats Matthias!
> Best
> Markos
>
> On Fri, Aug 4, 2023 at 11:25 AM Alexander Fedulov <
> alexander.fedu...@gmail.com> wrote:
>
> > Congrats!
> >
> > Best,
> > Alex
> >
> > On
+1 (binding)
Thanks Deepthi!
On Thu, Aug 3, 2023 at 7:44 PM Danny Cranmer
wrote:
> +1 (binding)
>
> Thanks Deepthi
>
>
> On Thu, 3 Aug 2023, 12:03 Rui Fan, <1996fan...@gmail.com> wrote:
>
> > +1(binding), thanks for driving this proposal, it's cool !
> >
> > Best,
> > Rui Fan
> >
> > On Thu,
Hong Liang Teoh created FLINK-32703:
---
Summary: [hotfix] flink-python POM has a typo for protobuf-java in
shading config
Key: FLINK-32703
URL: https://issues.apache.org/jira/browse/FLINK-32703
Hong Liang Teoh created FLINK-32619:
---
Summary: ConfigOptions to support fallback configuration
Key: FLINK-32619
URL: https://issues.apache.org/jira/browse/FLINK-32619
Project: Flink
Issue
Hong Liang Teoh created FLINK-32537:
---
Summary: Add compatibility annotation for REST API classes
Key: FLINK-32537
URL: https://issues.apache.org/jira/browse/FLINK-32537
Project: Flink
Hong Liang Teoh created FLINK-32535:
---
Summary: CheckpointingStatisticsHandler periodically returns
NullArgumentException after job restarts
Key: FLINK-32535
URL: https://issues.apache.org/jira/browse/FLINK
Hong Liang Teoh created FLINK-32499:
---
Summary: Removing dependency of flink-connector-aws on a specific
flink-shaded version
Key: FLINK-32499
URL: https://issues.apache.org/jira/browse/FLINK-32499
Hong Liang Teoh created FLINK-32488:
---
Summary: Introduce configuration to control ExecutionGraph cache
in REST API
Key: FLINK-32488
URL: https://issues.apache.org/jira/browse/FLINK-32488
Project
Hong Liang Teoh created FLINK-32469:
---
Summary: Simplify the implementation of the checkpoint handlers
Key: FLINK-32469
URL: https://issues.apache.org/jira/browse/FLINK-32469
Project: Flink
Hong Liang Teoh created FLINK-32324:
---
Summary: Implement watermark alignment on KDS source
Key: FLINK-32324
URL: https://issues.apache.org/jira/browse/FLINK-32324
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-32229:
---
Summary: Implement metrics and logging for Initial implementation
Key: FLINK-32229
URL: https://issues.apache.org/jira/browse/FLINK-32229
Project: Flink
Hong Liang Teoh created FLINK-32218:
---
Summary: Implement support for parent/child shard ordering
Key: FLINK-32218
URL: https://issues.apache.org/jira/browse/FLINK-32218
Project: Flink
Hong Liang Teoh created FLINK-32116:
---
Summary: FlinkKinesisConsumer cannot stop-with-savepoint when
configured with watermark assigner and watermark tracker
Key: FLINK-32116
URL: https://issues.apache.org/jira
Hong Liang Teoh created FLINK-32097:
---
Summary: Implement support for Kinesis aggregation
Key: FLINK-32097
URL: https://issues.apache.org/jira/browse/FLINK-32097
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-31990:
---
Summary: Use Flink Configuration to specify KDS Source
configuration object
Key: FLINK-31990
URL: https://issues.apache.org/jira/browse/FLINK-31990
Project
Hong Liang Teoh created FLINK-31989:
---
Summary: Update documentation
Key: FLINK-31989
URL: https://issues.apache.org/jira/browse/FLINK-31989
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-31988:
---
Summary: Implement Python wrapper for new KDS source
Key: FLINK-31988
URL: https://issues.apache.org/jira/browse/FLINK-31988
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-31987:
---
Summary: Implement Table API support
Key: FLINK-31987
URL: https://issues.apache.org/jira/browse/FLINK-31987
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-31986:
---
Summary: Implement Integration test for FLIP-27 DataStreams API
Key: FLINK-31986
URL: https://issues.apache.org/jira/browse/FLINK-31986
Project: Flink
Hong Liang Teoh created FLINK-31980:
---
Summary: Implement support for EFO in new Source
Key: FLINK-31980
URL: https://issues.apache.org/jira/browse/FLINK-31980
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-31942:
---
Summary: Support Conditional Writes in DynamoDB connector
Key: FLINK-31942
URL: https://issues.apache.org/jira/browse/FLINK-31942
Project: Flink
Issue
Hong Liang Teoh created FLINK-31922:
---
Summary: Port over Kinesis Client configurations for retry and
backoff
Key: FLINK-31922
URL: https://issues.apache.org/jira/browse/FLINK-31922
Project: Flink
Hong Liang Teoh created FLINK-31813:
---
Summary: Initial implementation of Kinesis Source using FLIP-27
Key: FLINK-31813
URL: https://issues.apache.org/jira/browse/FLINK-31813
Project: Flink
Hong Liang Teoh created FLINK-31662:
---
Summary: Migrate flink-connectors-aws to new structure
Key: FLINK-31662
URL: https://issues.apache.org/jira/browse/FLINK-31662
Project: Flink
Issue
Hong Liang Teoh created FLINK-31159:
---
Summary: Release Testing: Verify FLINK-30583 Provide the flame
graph to the subtask level
Key: FLINK-31159
URL: https://issues.apache.org/jira/browse/FLINK-31159
Hong Liang Teoh created FLINK-31108:
---
Summary: Use StreamARN for API calls in Kinesis Connector
Key: FLINK-31108
URL: https://issues.apache.org/jira/browse/FLINK-31108
Project: Flink
Issue
Hong Liang Teoh created FLINK-30950:
---
Summary: Remove flink-connector-aws-base from Flink main repo
Key: FLINK-30950
URL: https://issues.apache.org/jira/browse/FLINK-30950
Project: Flink
Hong Liang Teoh created FLINK-30949:
---
Summary: Sync flink-connector-aws-base from Flink main to
flink-connector-aws
Key: FLINK-30949
URL: https://issues.apache.org/jira/browse/FLINK-30949
Project
Hong Liang Teoh created FLINK-30948:
---
Summary: Remove flink-avro-glue-schema-registry and
flink-json-glue-schema-registry from Flink main repo
Key: FLINK-30948
URL: https://issues.apache.org/jira/browse/FLINK
Hong Liang Teoh created FLINK-30947:
---
Summary: Sync flink-avro-glue-schema-registry and
flink-json-glue-schema-registry to flink-connector-aws
Key: FLINK-30947
URL: https://issues.apache.org/jira/browse/FLINK
Hong Liang Teoh created FLINK-30946:
---
Summary: Sync master Avro GlueSchemaRegistry formats
flink-connector-aws
Key: FLINK-30946
URL: https://issues.apache.org/jira/browse/FLINK-30946
Project: Flink
Hong Liang Teoh created FLINK-30853:
---
Summary: Make clear the public API for flink-avro
Key: FLINK-30853
URL: https://issues.apache.org/jira/browse/FLINK-30853
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-30837:
---
Summary: Remove dependency of MutableByteArrayInputStream from
flink-avro-glue-schema-registry
Key: FLINK-30837
URL: https://issues.apache.org/jira/browse/FLINK-30837
Hong Liang Teoh created FLINK-30783:
---
Summary: Add pull request template for AWS Connectors repo
Key: FLINK-30783
URL: https://issues.apache.org/jira/browse/FLINK-30783
Project: Flink
Hong Liang Teoh created FLINK-30156:
---
Summary: [FLIP-242] Blogpost about the customisable
RateLimitingStrategy in the AsyncSinkBase
Key: FLINK-30156
URL: https://issues.apache.org/jira/browse/FLINK-30156
Hong Liang Teoh created FLINK-30098:
---
Summary: Update DynamoDb Sink unit tests to JUnit 5
Key: FLINK-30098
URL: https://issues.apache.org/jira/browse/FLINK-30098
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-30096:
---
Summary: Rename DynamoDB config destinationTableName to tableName
Key: FLINK-30096
URL: https://issues.apache.org/jira/browse/FLINK-30096
Project: Flink
Hong Liang Teoh created FLINK-30092:
---
Summary: Improve Table API experience for Flink DOUBLE type
Key: FLINK-30092
URL: https://issues.apache.org/jira/browse/FLINK-30092
Project: Flink
Hong Liang Teoh created FLINK-29909:
---
Summary: Standardise connector package names
Key: FLINK-29909
URL: https://issues.apache.org/jira/browse/FLINK-29909
Project: Flink
Issue Type: Sub
Hong Liang Teoh created FLINK-29900:
---
Summary: Implement Table API for DynamoDB Sink
Key: FLINK-29900
URL: https://issues.apache.org/jira/browse/FLINK-29900
Project: Flink
Issue Type
Hong Liang Teoh created FLINK-29683:
---
Summary: Introduce config parser for AWS BackoffStrategy
Key: FLINK-29683
URL: https://issues.apache.org/jira/browse/FLINK-29683
Project: Flink
Issue
Hong Liang Teoh created FLINK-29574:
---
Summary: Upgrade software.amazon.glue:schema-registry-common and
software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14
Key: FLINK-29574
URL: https
Hong Liang Teoh created FLINK-29395:
---
Summary: [Kinesis][EFO] Issue using EFO consumer at timestamp with
empty shard
Key: FLINK-29395
URL: https://issues.apache.org/jira/browse/FLINK-29395
Project
Hong Liang Teoh created FLINK-28978:
---
Summary: [aws][connectors] Kinesis connector doesn't work for new
AWS regions
Key: FLINK-28978
URL: https://issues.apache.org/jira/browse/FLINK-28978
Project
Hong Liang Teoh created FLINK-28487:
---
Summary: Introduce configurable RateLimitingStrategy for Async Sink
Key: FLINK-28487
URL: https://issues.apache.org/jira/browse/FLINK-28487
Project: Flink
Hong Liang Teoh created FLINK-19226:
---
Summary: [Kinesis] [EFO] Connector reaches default max attempts
for describeStream and describeStreamConsumer when parallelism is high
Key: FLINK-19226
URL: https
64 matches
Mail list logo
