Re: [VOTE] FLIP-524: CloudWatch Metric Sink Connector

2025-05-04 Thread Hong Liang
+1 (binding) Thanks, Hong On Sun, May 4, 2025 at 4:02 PM Danny Cranmer wrote: > +1 (binding) > > Thanks, > Danny > > On Sat, 3 May 2025, 15:55 Daren Wong, wrote: > > > Hi devs, > > > > A friendly ping if you could vote for this please? This is a new > connector > > in addition to our existing

[VOTE] FLIP-518: Introduce a community review process

2025-05-02 Thread Hong Liang
+1 (binding) Thanks for driving this! It is a great way to engage the community. Hong Note: My Gmail still shows the votes going to the [DISCUSS] thread. I’ve tried to remedy this by renaming the Subject to [VOTE]. On Thursday, May 1, 2025, Ferenc Csaky wrote: > +1 (binding) > > Thanks for dr

Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector

2025-04-08 Thread Hong Liang
Hi Daren, Thanks for the contribution — exciting to see support for new sinks! I’ve added a few comments and suggestions below: 1. Clarify Cloudwatch API limitations and handling in the sink. [1] Great to see we're being explicit with the Java API model! Let's be explicit about the PutMetricsData

Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

2025-04-07 Thread Hong Liang
Congratulations Sergey! Well deserved. Hong On Mon, Apr 7, 2025 at 8:03 AM David Radley wrote: > Congratuations - well deserved Sergey, I really appreciate your deep > knowledge, prolific contributions, support and community minded attitude, > > Kind regards David. > > From: Arvid Heise > Dat

[jira] [Created] (FLINK-37565) Connector python CI failing for JDK 8

2025-03-26 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-37565: --- Summary: Connector python CI failing for JDK 8 Key: FLINK-37565 URL: https://issues.apache.org/jira/browse/FLINK-37565 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37514) Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab

2025-03-19 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-37514: --- Summary: Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab Key: FLINK-37514 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink

2025-03-19 Thread Hong Liang
Thanks for driving this! +1 (binding) Hong On Fri, Mar 14, 2025 at 6:01 PM Danny Cranmer wrote: > Thanks for driving this Poorvank. > > +1 (binding) > > Thanks, > Danny > > > On Wed, 12 Mar 2025, 11:48 Ahmed Hamdy, wrote: > > > Thanks for addressing the feedback Poorvank, > > > > +1 (non-bind

[jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery

2025-03-04 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-37417: --- Summary: Implement better exception message to explain why KinesisSource doesn't support partial recovery Key: FLINK-37417 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-37004) Implement Multithreaded SourceReader

2025-01-03 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-37004: --- Summary: Implement Multithreaded SourceReader Key: FLINK-37004 URL: https://issues.apache.org/jira/browse/FLINK-37004 Project: Flink Issue Type

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

2024-12-02 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36828: --- Summary: Implement example for customers to perform KPL Deaggregation Key: FLINK-36828 URL: https://issues.apache.org/jira/browse/FLINK-36828 Project: Flink

[jira] [Created] (FLINK-36820) SourceCoordinator#addSplitsBack() should not be called on full failover

2024-11-29 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36820: --- Summary: SourceCoordinator#addSplitsBack() should not be called on full failover Key: FLINK-36820 URL: https://issues.apache.org/jira/browse/FLINK-36820

[ANNOUNCE] Apache flink-connector-aws 5.0.0 released

2024-11-11 Thread Hong Liang
The Apache Flink community is very happy to announce the release of Apache flink-connector-aws 5.0.0. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for download at:

[ANNOUNCE] Apache flink-connector-prometheus 1.0.0 released

2024-11-11 Thread Hong Liang
The Apache Flink community is very happy to announce the release of Apache flink-connector-prometheus 1.0.0. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for downl

[RESULT][VOTE] flink-connector-aws v5.0.0, release candidate #3

2024-11-11 Thread Hong Liang
I'm happy to announce that we have unanimously approved this release. There are 4 approving votes, 3 of which are binding: * Danny Cranmer (binding) * Weijie Guo (binding) * Xintong Song (binding) * Ahmed Hamdy (non-binding) There are no disapproving votes. Thanks everyone!

Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #3

2024-11-11 Thread Hong Liang
> > > > > * Release notes look good > > > > * Source archive signatures and checksums match > > > > * There are no binaries in the source > > > > * Build source using Maven > > > > * Verified Apache headers exist and are correct in the

[RESULT][VOTE] flink-connector-prometheus v1.0.0, release candidate #1

2024-11-08 Thread Hong Liang
I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * Weijie Guo (binding) * Xintong Song (binding) * Yanquan Lv (non-binding) * Lorenzo Nicora (non-binding) * Danny Cranmer (binding) There are no disapproving votes. Thanks e

Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1

2024-11-08 Thread Hong Liang
Thank you everyone for voting. I'm closing the vote in another thread. Thanks, Hong On Wed, Nov 6, 2024 at 5:03 PM Hong Liang wrote: > Thanks for the thorough verification Danny! > > > - I note that the AWS SDK version differs between flink-connector- > prometheus [1] and

[jira] [Created] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN

2024-11-07 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36672: --- Summary: Kinesis Table API for new KDS source should infer region from streamARN Key: FLINK-36672 URL: https://issues.apache.org/jira/browse/FLINK-36672

[jira] [Created] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata.

2024-11-07 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36671: --- Summary: Kinesis Table API for new KDS source does not support metadata. Key: FLINK-36671 URL: https://issues.apache.org/jira/browse/FLINK-36671 Project: Flink

Re: Flink technical debt.

2024-11-07 Thread Hong Liang
Hi David, Thanks for this proposal. I agree that this is something we can strive to do better in the Flink community, and I would be keen to help out here. +1 to the suggestion for a recurring working group meeting to triage and assign PRs. I think the suggestions we have on the thread are great

[jira] [Created] (FLINK-36668) Release flink-connector-aws v5.0.0

2024-11-06 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36668: --- Summary: Release flink-connector-aws v5.0.0 Key: FLINK-36668 URL: https://issues.apache.org/jira/browse/FLINK-36668 Project: Flink Issue Type

Re: [VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1

2024-11-06 Thread Hong Liang
t; > > > > > Xintong > > > > > > > > > > > > On Tue, Nov 5, 2024 at 2:04 PM weijie guo > > > wrote: > > > > > > > +1 (binding) > > > > > > > > - verified signatures > > > > - verified hash

[VOTE] Release flink-connector-aws v5.0.0, release candidate #3

2024-11-06 Thread Hong Liang
Hi everyone, Please review and vote on release candidate #3 for flink-connector-aws v5.0.0, 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

Re: [ANNOUNCE] New Apache Flink Committer - Junrui Li

2024-11-06 Thread Hong Liang
Congratulations Junrui! Hong On Wed, Nov 6, 2024 at 12:36 PM Yanquan Lv wrote: > Congratulations, Junrui! > > Best, > Yanquan > > > 2024年11月5日 19:59,Zhu Zhu 写道: > > > > Hi everyone, > > > > On behalf of the PMC, I'm happy to announce that Junrui Li has become a > > new Flink Committer! > > > >

Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2

2024-11-06 Thread Hong Liang
6.19 > < software.amazon.awssdk:identity-spi:2.26.19 > < software.amazon.awssdk:retries-spi:2.26.19 > < software.amazon.awssdk:retries:2.26.19 > > We will need to check other NOTICE files, update them and create RC3. > > Thanks, > Danny > > > > > > On Tue, Nov 5, 2

[jira] [Created] (FLINK-36666) CI/CD should check NOTICE files for discrepancies.

2024-11-06 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-3: --- Summary: CI/CD should check NOTICE files for discrepancies. Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink

Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2

2024-11-05 Thread Hong Liang
anquan Lv, wrote: > > > +1 (non-binding) > > > > Thanks for Hong’s explanation. > > I'm just making sure we haven't missed any previous discussions. > > > > > > > 2024年11月5日 15:51,Hong Liang 写道: > > > > > > Hi Yanquan, > &

Re: [VOTE] Release flink-connector-aws v5.0.0, release candidate #2

2024-11-04 Thread Hong Liang
ssing something? > > > > 2024年11月5日 07:00,Hong Liang 写道: > > > > Hi everyone, > > Please review and vote on release candidate #2 for flink-connector-aws > > v5.0.0, as follows: > > [ ] +1, Approve the release > > [ ] -1, Do not approve the rel

[VOTE] Release flink-connector-prometheus v1.0.0, release candidate #1

2024-11-04 Thread Hong Liang
Hi everyone, Please review and vote on release candidate #1 for flink-connector-prometheus v1.0.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This version supports Flink 1.19 and 1.20. The complete staging area is available for yo

[VOTE] Release flink-connector-aws v5.0.0, release candidate #2

2024-11-04 Thread Hong Liang
Hi everyone, Please review and vote on release candidate #2 for flink-connector-aws v5.0.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This version supports Flink 1.19 and 1.20. The complete staging area is available for your revi

[jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok

2024-10-28 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36612: --- Summary: Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok Key: FLINK-36612 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-36571) Flink dashboard does not show Busy / Backpressure

2024-10-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36571: --- Summary: Flink dashboard does not show Busy / Backpressure Key: FLINK-36571 URL: https://issues.apache.org/jira/browse/FLINK-36571 Project: Flink

[jira] [Created] (FLINK-36359) IT case for DDB Streams connector

2024-09-24 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36359: --- Summary: IT case for DDB Streams connector Key: FLINK-36359 URL: https://issues.apache.org/jira/browse/FLINK-36359 Project: Flink Issue Type

[jira] [Created] (FLINK-36357) SDK retry for KDS connector

2024-09-24 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36357: --- Summary: SDK retry for KDS connector Key: FLINK-36357 URL: https://issues.apache.org/jira/browse/FLINK-36357 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36289) Create Prometheus Flink connector release

2024-09-16 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36289: --- Summary: Create Prometheus Flink connector release Key: FLINK-36289 URL: https://issues.apache.org/jira/browse/FLINK-36289 Project: Flink Issue Type

[jira] [Created] (FLINK-36288) Set up architectural test

2024-09-16 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36288: --- Summary: Set up architectural test Key: FLINK-36288 URL: https://issues.apache.org/jira/browse/FLINK-36288 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36286) Set up pull request template

2024-09-16 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36286: --- Summary: Set up pull request template Key: FLINK-36286 URL: https://issues.apache.org/jira/browse/FLINK-36286 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name

2024-09-03 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36205: --- Summary: DDB Streams connector should be able to resolve the stream ARN from given Table name Key: FLINK-36205 URL: https://issues.apache.org/jira/browse/FLINK-36205

[jira] [Created] (FLINK-36187) Reimplement UniformShardAssigner using Kinesis shard hashes

2024-08-30 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-36187: --- Summary: Reimplement UniformShardAssigner using Kinesis shard hashes Key: FLINK-36187 URL: https://issues.apache.org/jira/browse/FLINK-36187 Project: Flink

[jira] [Created] (FLINK-35989) Document and log error on partially failed requests for AWS sinks

2024-08-06 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-35989: --- Summary: Document and log error on partially failed requests for AWS sinks Key: FLINK-35989 URL: https://issues.apache.org/jira/browse/FLINK-35989 Project

Re: [ANNOUNCE] Apache Flink 1.19.1 released

2024-06-19 Thread Hong Liang
t; > Best, > Rui > > On Wed, Jun 19, 2024 at 9:49 AM Leonard Xu wrote: > > > Congratulations! Thanks Hong for the release work and all involved! > > > > Best, > > Leonard > > > > > 2024年6月19日 上午4:20,Hong Liang 写道: > > > > > > The A

[ANNOUNCE] Apache Flink 1.19.1 released

2024-06-18 Thread Hong Liang
The Apache Flink community is very happy to announce the release of Apache Flink 1.19.1, which is the first bugfix release for the Apache Flink 1.19 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming a

Re: [VOTE] Release 1.19.1, release candidate #1

2024-06-12 Thread Hong Liang
; > - Verified signatures and sha512 > > - Checked Github release tag exsit > > - Source archives with no binary files > > - Build the source with jdk8 on ubuntu 22.04 succeed > > - Reviewed the flink-web PR > > > > Best, > > Zhongqiang Gong > &

[RESULT] [VOTE] Release 1.19.1, release candidate #1

2024-06-12 Thread Hong Liang
Hi all, I'm happy to announce that we have unanimously approved this release. [1] There are 11 approving votes, 5 of which are binding: * Rui Fan (binding) * Xiqian Yu (non-binding) * Weijie Guo (binding) * Jeyhun (non-binding) * Ahmed Hamdy (non-binding) * Xintong Song (binding) * Matthias Pohl

Re: [VOTE] Release 1.19.1, release candidate #1

2024-06-10 Thread Hong Liang
ndredi, 7 juin 2024 à 17:14 > > > > À : dev@flink.apache.org > > > > Objet : Re: [VOTE] Release 1.19.1, release candidate #1 > > > > +1(binding) > > > > > > > > - Reviewed the flink-web PR (Left some comments) > > > > - Ch

[VOTE] Release 1.19.1, release candidate #1

2024-06-06 Thread Hong Liang
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], *

[jira] [Created] (FLINK-35532) Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard

2024-06-05 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-35512) ArtifactFetchManagerTest unit tests fail

2024-06-03 Thread Hong Liang Teoh (Jira)
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

[DISCUSS] Flink 1.19.1 release

2024-05-24 Thread Hong Liang
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 previous

Re: [VOTE] FLIP-451: Introduce timeout configuration to AsyncSink

2024-05-21 Thread Hong Liang
+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 configura

Re: [DISCUSS] FLIP-451: Refactor Async sink API

2024-05-20 Thread Hong Liang
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

Re: [Vote] FLIP-438: Amazon SQS Sink Connector

2024-05-07 Thread Hong Liang
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

[jira] [Created] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot

2024-05-06 Thread Hong Liang Teoh (Jira)
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

Re: [DISCUSS] FLIP-444: Native file copy support

2024-05-02 Thread Hong Liang
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 introduce

Re: [Vote] FLIP-438: Amazon SQS Sink Connector

2024-04-16 Thread Hong Liang
+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 2

Re: [VOTE] FLIP-418: Show data skew score on Flink Dashboard

2024-02-12 Thread Hong Liang
+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 Mo

Security fixes for Flink 1.18 (flink-shaded)

2024-02-01 Thread Hong Liang
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 ch

[jira] [Created] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
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

Re: [DISCUSS] Release Flink 1.18.1

2023-12-11 Thread Hong Liang
+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: dev@flink.

[jira] [Created] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow

2023-10-12 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present

2023-09-28 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
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

Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl

2023-08-04 Thread Hong Liang
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

Re: [VOTE] FLIP-333: Redesign Apache Flink website

2023-08-03 Thread Hong Liang
+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,

[jira] [Created] (FLINK-32703) [hotfix] flink-python POM has a typo for protobuf-java in shading config

2023-07-27 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32619) ConfigOptions to support fallback configuration

2023-07-18 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32537) Add compatibility annotation for REST API classes

2023-07-04 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

2023-07-04 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32499) Removing dependency of flink-connector-aws on a specific flink-shaded version

2023-06-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-06-29 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32469) Simplify the implementation of the checkpoint handlers

2023-06-28 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32324) Implement watermark alignment on KDS source

2023-06-13 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32229) Implement metrics and logging for Initial implementation

2023-05-31 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32218) Implement support for parent/child shard ordering

2023-05-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker

2023-05-17 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32097) Implement support for Kinesis aggregation

2023-05-15 Thread Hong Liang Teoh (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

[jira] [Created] (FLINK-31990) Use Flink Configuration to specify KDS Source configuration object

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31989) Update documentation

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31988) Implement Python wrapper for new KDS source

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31987) Implement Table API support

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31980) Implement support for EFO in new Source

2023-05-02 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31942) Support Conditional Writes in DynamoDB connector

2023-04-25 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-04-24 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27

2023-04-14 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31662) Migrate flink-connectors-aws to new structure

2023-03-29 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector

2023-02-16 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30950) Remove flink-connector-aws-base from Flink main repo

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30949) Sync flink-connector-aws-base from Flink main to flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30948) Remove flink-avro-glue-schema-registry and flink-json-glue-schema-registry from Flink main repo

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30947) Sync flink-avro-glue-schema-registry and flink-json-glue-schema-registry to flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30946) Sync master Avro GlueSchemaRegistry formats flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30853) Make clear the public API for flink-avro

2023-01-31 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30837) Remove dependency of MutableByteArrayInputStream from flink-avro-glue-schema-registry

2023-01-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30783) Add pull request template for AWS Connectors repo

2023-01-25 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase

2022-11-22 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30098) Update DynamoDb Sink unit tests to JUnit 5

2022-11-19 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30096) Rename DynamoDB config destinationTableName to tableName

2022-11-19 Thread Hong Liang Teoh (Jira)
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

  1   2   >