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

2024-06-26 Thread Hong
+1 (binding) Hong > On 26 Jun 2024, at 12:27, Keith Lee wrote: > > +1 (non binding) > > Best regards > Keith Lee > > >> On Wed, Jun 26, 2024 at 9:48 AM Zakelly Lan wrote: >> +1 (binding) >> Best, >> Zakelly >>> On Wed, Jun 26

Re: [ANNOUNCE] Apache Flink 1.19.1 released

2024-06-19 Thread Hong Liang
] https://hub.docker.com/r/apache/flink/tags?page=1=1.19.1 On Wed, Jun 19, 2024 at 2:52 AM Rui Fan <1996fan...@gmail.com> wrote: > Thanks Hong for driving this release! > > I clicked the library/flink docker images link[1] from > 1.19.1-release-announcement[2]. > And I c

[ANNOUNCE] Apache Flink 1.19.1 released

2024-06-18 Thread Hong Liang
on the release process. Our goal is to constantly improve the release process. Feedback on what could be improved or things that didn't go so well are appreciated. Regards, Hong

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

2024-06-12 Thread Hong Liang
Thanks all for the testing and votes. The RC is approved and this thread is now closed. See results in [1]. [1] https://lists.apache.org/thread/yqr3jv4wr85brnz2ylzqo9pqn453jqvq Regards, Hong On Tue, Jun 11, 2024 at 9:39 AM Hang Ruan wrote: > +1(non-binding) > > - Verified s

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

2024-06-12 Thread Hong Liang
(binding) * Sergey Nuyanzin (non-binding) * Leonard Xu (binding) * Zhongqiang Gong (non-binding) * Hang Ruan (non-binding) There are no disapproving votes. Thanks everyone! [1] https://lists.apache.org/thread/hrptj22y6rjt61flzdzngxdsw134osk4 Regards, Hong

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

2024-06-10 Thread Hong Liang
ore binding vote! Regards, Hong On Sat, Jun 8, 2024 at 11:33 PM Ahmed Hamdy wrote: > Hi Hong, > Thanks for driving > > +1 (non-binding) > > - Verified signatures and hashes > - Checked github release tag > - Verified licenses > - Checked that the source code does not

[VOTE] Release 1.19.1, release candidate #1

2024-06-06 Thread Hong Liang
bsite pull request listing the new release and adding announcement blog post [6]. The vote will be open for at least 72 hours. It is adopted by majority approval, with at least 3 PMC affirmative votes. Thanks, Hong [1] https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12354399

[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
this new patch release, I'm happy to volunteer as the release manager, if another PMC (Danny?) is happy to assist with the PMC-related release steps! Best regards, Hong [1] https://issues.apache.org/jira/projects/FLINK/versions/12354399 [2] https://issues.apache.org/jira/issues/?jql=project%20%3D

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

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 initiall

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
as a feature flag to determine if we should be using this new native file copy support. 2/ Configure the location of the s5cmd binary (version control etc.), as you have mentioned in the FLIP. Regards, Hong On Thu, May 2, 2024 at 9:40 AM Muhammet Orazov wrote: > Hey Piotr, > &g

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

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) > > Be

Security fixes for Flink 1.18 (flink-shaded)

2024-02-01 Thread Hong Liang
is on flink-shaded, which is relocated to keep the usage of libraries contained within the flink runtime itself, I am inclined to go with Option 1, even though the change is slightly larger than just the security fixes. Do people have any objections? Regards, Hong [1] https://nvd.nist.gov/vuln/detail

[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, De

[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

Re: [VOTE] FLIP-312: Prometheus Sink Connector

2023-09-20 Thread Hong
+1 (binding) Thanks Lorenzo. Hong > On 20 Sep 2023, at 17:49, Danny Cranmer wrote: > > +1 binding. > > Thanks for picking this up Lorenzo! > > Danny > > >> On Wed, 20 Sept 2023, 16:33 Jing Ge, wrote: >> >> +1(binding) Thanks! >> &

[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

[jira] [Created] (FLINK-32889) BinaryClassificationEvaluator gives wrong weighted AUC value

2023-08-17 Thread Fan Hong (Jira)
Fan Hong created FLINK-32889: Summary: BinaryClassificationEvaluator gives wrong weighted AUC value Key: FLINK-32889 URL: https://issues.apache.org/jira/browse/FLINK-32889 Project: Flink Issue

[jira] [Created] (FLINK-32810) Improve managed memory usage in ListStateWithCache

2023-08-08 Thread Fan Hong (Jira)
Fan Hong created FLINK-32810: Summary: Improve managed memory usage in ListStateWithCache Key: FLINK-32810 URL: https://issues.apache.org/jira/browse/FLINK-32810 Project: Flink Issue Type

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: > > >

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,

Re: [DISCUSS] Upgrade vendored guava dependency

2023-07-31 Thread Hong Teoh
Sorry - meant to send this to a different mailing list -.- > On 31 Jul 2023, at 15:58, Hong Teoh wrote: > > Hi all, > > The current version of guava that is vendored in Beam is > com.google.guava:guava:26.0-jre. > > This version is really old, and has active vuln

[DISCUSS] Upgrade vendored guava dependency

2023-07-31 Thread Hong Teoh
/1ztEoyGkqq9ie5riQxRtMuBu3vb6BUO91mSMn1PU0pDA/edit#heading=h.vhcuqlttpnog Side question: Does anyone know why we have libraries that use the non-vendored guava version? [6] [6] https://github.com/search?q=repo%3Aapache%2Fbeam%20library.java.guava=code Regards, Hong

[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

Re: [DISCUSS][2.0] FLIP-337: Remove JarRequestBody#programArgs

2023-07-18 Thread Hong Teoh
+1 to this. Nice to simplify the REST API! Regards, Hong > On 18 Jul 2023, at 10:00, Chesnay Schepler wrote: > > Something to note is that the UI is using this parameter, and would have to > be changed to the new one. > > Since we want to avoid having to split arguments o

[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

Re: Working improving the REST API

2023-07-03 Thread Teoh, Hong
Just adding the updates from the Slack thread - @SamratDeb and @JulietLee have expressed interest, and there is a PR ready for review! https://github.com/apache/flink/pull/22901 Regards, Hong On 3 Jul 2023, at 16:56, Teoh, Hong wrote: CAUTION: This email originated from outside

Working improving the REST API

2023-07-03 Thread Teoh, Hong
/C03GV7L3G2C/p1688051972688149 [2] https://lists.apache.org/thread/7o330hfyoqqkkrfhtvz3kp448jcspjrm Regards, Hong

[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

Re: [DISCUSS] Release 2.0 Work Items

2023-06-29 Thread Teoh, Hong
Thanks Xintong for driving the effort. I’d add a +1 to reworking configs, as suggested by @Jark and @Chesnay, especially the types. We have various configs that encode Time / MemorySize that are Long instead! Regards, Hong > On 29 Jun 2023, at 16:19, Yuan Mei wrote: > >

[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

Re: Async I/O: preserve stream order for requests on key level

2023-06-27 Thread Teoh, Hong
/apache/flink-connector-aws/blob/main/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java#L169-L171 Regards, Hong > On 26 Jun 2023, at 03:52, Jark Wu wrote: > > CAUTION: This email originated from outside of the organization. Do

Re: [DISCUSS] Flink REST API improvements

2023-06-26 Thread Hong Teoh
ld get quite complicated. I like that it uses the industry standards, but I agree, we need to think carefully about the multiple layers of cache we have included in the Flink JM. Will take a look at this. Let me know your thoughts! Regards, Hong > On 26 Jun 2023, at 13:26, David Morávek

[DISCUSS] Flink REST API improvements

2023-06-23 Thread Teoh, Hong
to hearing people’s thoughts. Regards, Hong

Re: AsyncFunction vs Async Sink

2023-06-15 Thread Teoh, Hong
lar. However, I think the end use-case is different. For example, AsyncSink might want to implement support for some form of 2phase-commit on Sink (at least once guarantee). This is slightly more complicated on AsyncFunction. Regards, Hong On 15 Jun 2023, at 00:26, Lu Niu wrote: CAUT

Re: AsyncFunction vs Async Sink

2023-06-14 Thread Teoh, Hong
d happens before the record is written to the Kinesis Sink. Hope the above clarifies your question! Regards, Hong On 14 Jun 2023, at 19:27, Lu Niu wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender

[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

Re: [DISCUSSION] Improved USER/SYSTEM exception wrapping in Flink code base

2023-06-10 Thread Teoh, Hong
. We could address this by wrapping the existing exception rather than replacing. @Panagiotis I agree with all your points. This proposal is in synergy with Pluggable Failure Enrichers. Regards, Hong > On 6 Jun 2023, at 06:50, Panagiotis Garefalakis wrote: > > CAUTION: This email o

[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

Re: Questions on checkpointing mechanism for FLIP-27 Source API

2023-05-29 Thread Teoh, Hong
That would be true for events sent from Coordinator -> Subtask, but not from Subtask -> Coordinator. I will work with those active on [1] to resolve this situation! Any feedback is welcome! Regards, Hong [1] https://issues.apache.org/jira/browse/FLINK-26029 [2] https://github.com/apache/f

Re: Questions on checkpointing mechanism for FLIP-27 Source API

2023-05-29 Thread Teoh, Hong
That would be true for events sent from Coordinator -> Subtask, but not from Subtask -> Coordinator. I will work with those active on [1] to resolve this situation! Any feedback is welcome! Regards, Hong [1] https://issues.apache.org/jira/browse/FLINK-26029 [2] https://github.com/apache/f

Re: Questions on checkpointing mechanism for FLIP-27 Source API

2023-05-29 Thread Teoh, Hong
That would be true for events sent from Coordinator -> Subtask, but not from Subtask -> Coordinator. I will work with those active on [1] to resolve this situation! Any feedback is welcome! Regards, Hong [1] https://issues.apache.org/jira/browse/FLINK-26029 [2] https://github.com/apache/f

[DISCUSSION] Improved USER/SYSTEM exception wrapping in Flink code base

2023-05-25 Thread Teoh, Hong
by serialisers to be a Flink-specific serialisation exception instead of IllegalStateException [2] Any thoughts on the above? Regards, Hong [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-304%3A+Pluggable+Failure+Enrichers [2] https://lists.apache.org/thread

Questions on checkpointing mechanism for FLIP-27 Source API

2023-05-17 Thread Teoh, Hong
, does the SplitEnumerator re-take the snapshot of state for a checkpoint if an OperatorEvent is sent before the checkpoint is complete? Regards, Hong

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

2023-05-17 Thread Teoh, Hong
of metrics! I think you might be referring to the metrics of the Flink job itself (e.g. CPU / memory metrics). For this use case, I would agree that we should not use this sink but instead use our metric reporters. Regards, Hong > On 16 May 2023, at 03:37, Lijie Wang wrote: > >

[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-32051) Fix broken documenation links in Flink blogs

2023-05-11 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-32051: Summary: Fix broken documenation links in Flink blogs Key: FLINK-32051 URL: https://issues.apache.org/jira/browse/FLINK-32051 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-31945) Table of contents in the blogs of the project website is missing some titles

2023-04-26 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-31945: Summary: Table of contents in the blogs of the project website is missing some titles Key: FLINK-31945 URL: https://issues.apache.org/jira/browse/FLINK-31945 Project

[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

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

2023-04-20 Thread Hong Teoh
+1 (non-binding) Thank you for driving this effort, Panagiotis. Regards, Hong > On 20 Apr 2023, at 12:16, David Morávek wrote: > > Thanks for the update! > > +1 (binding) > > Best, > D. > > On Thu, Apr 20, 2023 at 9:50 AM Piotr Nowojski wrote: > >

[jira] [Created] (FLINK-31846) Support cancel final checkpoint when all tasks are finished

2023-04-18 Thread Fan Hong (Jira)
Fan Hong created FLINK-31846: Summary: Support cancel final checkpoint when all tasks are finished Key: FLINK-31846 URL: https://issues.apache.org/jira/browse/FLINK-31846 Project: Flink Issue

[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-31809) Improve efficiency of ListStateWithCache#snapshotState

2023-04-14 Thread Fan Hong (Jira)
Fan Hong created FLINK-31809: Summary: Improve efficiency of ListStateWithCache#snapshotState Key: FLINK-31809 URL: https://issues.apache.org/jira/browse/FLINK-31809 Project: Flink Issue Type

Re: [VOTE] Release flink-connector-jdbc v3.1.0, release candidate #1

2023-04-14 Thread Teoh, Hong
Thanks Danny +1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 14 Apr 2023, at 05:21, Elphas Toringepi wr

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

2023-04-14 Thread Teoh, Hong
Thanks Danny +1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 14 Apr 2023, at 06:36, Elphas Toringepi wr

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

2023-04-11 Thread Teoh, Hong
for 1 timeout for all failure handlers. 2. +1 to Zhu’s comment on adding a comma separated list of FailureHandlers instead of boolean toggle! Other than the above, the FLIP looks great! Thank you for your efforts. Regards, Hong > On 11 Apr 2023, at 08:01, Zhu Zhu wrote: > >

Re: [DISCUSS] Releasing Flink ML 2.2.0

2023-03-31 Thread Fan Hong
Hi Dong and Zhipeng, Thanks for starting the discussion. Glad to see a new release of Flink ML. Cheers! On Fri, Mar 31, 2023 at 2:34 PM Zhipeng Zhang wrote: > Hi Dong, > > Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. >

[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

Re: [VOTE] Release flink-connector-mongodb, release candidate #1

2023-03-28 Thread Teoh, Hong
+1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 28 Mar 2023, at 12:56, Samrat Deb wrote: > >

Re: [VOTE] Release flink-connector-aws 4.1.0, release candidate #1

2023-03-28 Thread Teoh, Hong
+1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven Cheers, Hong > On 22 Mar 2023, at 07:21, Robert Metzger wrote: > >

[jira] [Created] (FLINK-31625) Possbile OOM in KBinsDiscretizer

2023-03-27 Thread Fan Hong (Jira)
Fan Hong created FLINK-31625: Summary: Possbile OOM in KBinsDiscretizer Key: FLINK-31625 URL: https://issues.apache.org/jira/browse/FLINK-31625 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31623) Improvements on DataStreamUtils#sample

2023-03-27 Thread Fan Hong (Jira)
Fan Hong created FLINK-31623: Summary: Improvements on DataStreamUtils#sample Key: FLINK-31623 URL: https://issues.apache.org/jira/browse/FLINK-31623 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

2023-03-22 Thread Hong Teoh
tly? - independent vs ordered execution: Should we consider making the order of execution deterministic (use a List instead of Set)? Once again, thank you for working on this. Regards, Hong > On 21 Mar 2023, at 21:07, Jing Ge wrote: > > Hi, > > Thanks Panagiotis for this FLIP

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

2023-02-28 Thread Teoh, Hong
Thanks Danny for driving this +1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Source archive builds using maven * Started packaged example WordCountSQLExample job * Web PR looks good. Cheers, Hong > On 24 Feb 2023, at 05:36, Weihua Hu wr

[jira] [Created] (FLINK-31189) Allow ignore less frequent values in StringIndexer

2023-02-22 Thread Fan Hong (Jira)
Fan Hong created FLINK-31189: Summary: Allow ignore less frequent values in StringIndexer Key: FLINK-31189 URL: https://issues.apache.org/jira/browse/FLINK-31189 Project: Flink Issue Type

[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-31030) Support more binary classification evaluation metrics.

2023-02-12 Thread Fan Hong (Jira)
Fan Hong created FLINK-31030: Summary: Support more binary classification evaluation metrics. Key: FLINK-31030 URL: https://issues.apache.org/jira/browse/FLINK-31030 Project: Flink Issue Type

[jira] [Created] (FLINK-31029) KBinsDiscretizer gives wrong bin edges when input data contains only 2 distinct values

2023-02-12 Thread Fan Hong (Jira)
Fan Hong created FLINK-31029: Summary: KBinsDiscretizer gives wrong bin edges when input data contains only 2 distinct values Key: FLINK-31029 URL: https://issues.apache.org/jira/browse/FLINK-31029

[jira] [Created] (FLINK-31026) KBinsDiscretizer should gives binEdges wrong bin edges when all values are same.

2023-02-12 Thread Fan Hong (Jira)
Fan Hong created FLINK-31026: Summary: KBinsDiscretizer should gives binEdges wrong bin edges when all values are same. Key: FLINK-31026 URL: https://issues.apache.org/jira/browse/FLINK-31026 Project

[jira] [Created] (FLINK-31010) Add Transformer and Estimator for GBTClassifier and GBTRegressor

2023-02-10 Thread Fan Hong (Jira)
Fan Hong created FLINK-31010: Summary: Add Transformer and Estimator for GBTClassifier and GBTRegressor Key: FLINK-31010 URL: https://issues.apache.org/jira/browse/FLINK-31010 Project: Flink

[jira] [Created] (FLINK-30982) Support checkpoint mechanism in GBT

2023-02-08 Thread Fan Hong (Jira)
Fan Hong created FLINK-30982: Summary: Support checkpoint mechanism in GBT Key: FLINK-30982 URL: https://issues.apache.org/jira/browse/FLINK-30982 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30957) Support other missing features

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30957: Summary: Support other missing features Key: FLINK-30957 URL: https://issues.apache.org/jira/browse/FLINK-30957 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30956) Add Python implementation of GBTClassifer and GBTRegressor.

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30956: Summary: Add Python implementation of GBTClassifer and GBTRegressor. Key: FLINK-30956 URL: https://issues.apache.org/jira/browse/FLINK-30956 Project: Flink Issue

[jira] [Created] (FLINK-30955) Support early stopping with validation set.

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30955: Summary: Support early stopping with validation set. Key: FLINK-30955 URL: https://issues.apache.org/jira/browse/FLINK-30955 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30954) Add estimator and transformer for GBTRegressor.

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30954: Summary: Add estimator and transformer for GBTRegressor. Key: FLINK-30954 URL: https://issues.apache.org/jira/browse/FLINK-30954 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30953) Support intermediate state management and model save/load.

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30953: Summary: Support intermediate state management and model save/load. Key: FLINK-30953 URL: https://issues.apache.org/jira/browse/FLINK-30953 Project: Flink Issue

[jira] [Created] (FLINK-30952) Add main training and transforming part.

2023-02-07 Thread Fan Hong (Jira)
Fan Hong created FLINK-30952: Summary: Add main training and transforming part. Key: FLINK-30952 URL: https://issues.apache.org/jira/browse/FLINK-30952 Project: Flink Issue Type: Sub-task

[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

  1   2   3   >