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

2024-01-30 Thread gongzhongqiang
+1(non-binding) - Signatures and Checksums are good - No binaries in the source archive - Tag is present - Build successful with jdk8 on ubuntu 22.04 Leonard Xu 于2024年1月30日周二 18:23写道: > Hey all, > > Please help review and vote on the release candidate #2 for the version > v1.1.0 of the >

[jira] [Created] (FLINK-34316) Reduce instantiation of ScanRuntimeProvider for in streaming mode

2024-01-30 Thread Timo Walther (Jira)
Timo Walther created FLINK-34316: Summary: Reduce instantiation of ScanRuntimeProvider for in streaming mode Key: FLINK-34316 URL: https://issues.apache.org/jira/browse/FLINK-34316 Project: Flink

[jira] [Created] (FLINK-34315) Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf

2024-01-30 Thread xuyang (Jira)
xuyang created FLINK-34315: -- Summary: Forcibly disable window join, window rank and window deduplicate optimization when using session window tvf Key: FLINK-34315 URL: https://issues.apache.org/jira/browse/FLINK-34315

[jira] [Created] (FLINK-34314) Update CI Node Actions from NodeJS 16 to NodeJS 20

2024-01-30 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34314: -- Summary: Update CI Node Actions from NodeJS 16 to NodeJS 20 Key: FLINK-34314 URL: https://issues.apache.org/jira/browse/FLINK-34314 Project: Flink Issue

[jira] [Created] (FLINK-34313) Update doc about session window tvf

2024-01-30 Thread xuyang (Jira)
xuyang created FLINK-34313: -- Summary: Update doc about session window tvf Key: FLINK-34313 URL: https://issues.apache.org/jira/browse/FLINK-34313 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-01-30 Thread weijie guo
Hi Xintong, Thanks for the quick reply. > Why introduce a new `MetricManager` rather than just return `MetricGroup` from `RuntimeContext`? This is to facilitate possible future extensions. But I thought it through, MetricGroup itself also plays the role of a manager. So I think you are right, I

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-01-30 Thread Xintong Song
> > > How can users define custom metrics within the `ProcessFunction`? > Will there be a method like `getMetricGroup` available in the > `RuntimeContext`? > > I think this is a reasonable request. For extensibility, I have added the > getMetricManager instead of getMetricGroup to RuntimeContext,

Re: [VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-01-30 Thread weijie guo
+1(binding) Best regards, Weijie Rui Fan <1996fan...@gmail.com> 于2024年1月31日周三 12:51写道: > +1(binding) > > Best, > Rui > > On Wed, Jan 31, 2024 at 12:46 PM Xintong Song > wrote: > > > +1 > > > > Best, > > > > Xintong > > > > > > > > On Wed, Jan 31, 2024 at 11:41 AM Xuannan Su > wrote: > > >

Re: [VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-01-30 Thread Rui Fan
+1(binding) Best, Rui On Wed, Jan 31, 2024 at 12:46 PM Xintong Song wrote: > +1 > > Best, > > Xintong > > > > On Wed, Jan 31, 2024 at 11:41 AM Xuannan Su wrote: > > > Hi everyone, > > > > Thanks for all the feedback about the FLIP-331: Support > > EndOfStreamTrigger and

Re: [VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-01-30 Thread Xintong Song
+1 Best, Xintong On Wed, Jan 31, 2024 at 11:41 AM Xuannan Su wrote: > Hi everyone, > > Thanks for all the feedback about the FLIP-331: Support > EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute > to optimize task deployment [1] [2]. > > I'd like to start a vote for it.

[VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-01-30 Thread Xuannan Su
Hi everyone, Thanks for all the feedback about the FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment [1] [2]. I'd like to start a vote for it. The vote will be open for at least 72 hours(excluding weekends,until Feb 5, 12:00AM

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

2024-01-30 Thread Hang Ruan
+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR - Check that the jar is built by jdk8 - Review the release note Best, Hang Jiabao Sun 于2024年1月30日周二 21:44写道: >

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

2024-01-30 Thread Aleksandr Pilipenko
Thanks for the FLIP! +1 (non-binding) Best, Aleksandr On Mon, 29 Jan 2024 at 10:11, Kartoglu, Emre wrote: > Hello, > > I'd like to call votes on FLIP-418: Show data skew score on Flink > Dashboard. > > FLIP: >

[jira] [Created] (FLINK-34312) Improve the handling of default node types when using named parameters.

2024-01-30 Thread Feng Jin (Jira)
Feng Jin created FLINK-34312: Summary: Improve the handling of default node types when using named parameters. Key: FLINK-34312 URL: https://issues.apache.org/jira/browse/FLINK-34312 Project: Flink

Re: [ANNOUNCE] Flink 1.19 feature freeze & sync summary on 01/30/2024

2024-01-30 Thread Matthias Pohl
Thanks for the update, Lincoln. fyi: I merged FLINK-32684 (deprecating AkkaOptions) [1] since we agreed in today's meeting that this change is still ok to go in. The beta version of the GitHub Actions workflows (FLIP-396 [2]) are also finalized (see related PRs for basic CI [3], nightly master

Re: [DISCUSS] Drop support for HBase v1

2024-01-30 Thread Ferenc Csaky
Hi Martijn, thanks for starting the discussion. Let me link the older discussion regarding the same topic [1]. My opinion did not change, so +1. BR, Ferenc [1] https://lists.apache.org/thread/x7l2gj8g93r4v6x6953cyt6jrs8c4r1b On Monday, January 29th, 2024 at 09:37, Martijn Visser wrote:

[jira] [Created] (FLINK-34311) Do not change min resource requirements when rescaling for adaptive scheduler

2024-01-30 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-34311: -- Summary: Do not change min resource requirements when rescaling for adaptive scheduler Key: FLINK-34311 URL: https://issues.apache.org/jira/browse/FLINK-34311 Project:

[jira] [Created] (FLINK-34309) Release Testing Instructions: Verify FLINK-33315 Optimize memory usage of large StreamOperato

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34309: --- Summary: Release Testing Instructions: Verify FLINK-33315 Optimize memory usage of large StreamOperato Key: FLINK-34309 URL: https://issues.apache.org/jira/browse/FLINK-34309

[jira] [Created] (FLINK-34310) Release Testing Instructions: Verify FLINK-33325 Built-in cross-platform powerful java profiler

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34310: --- Summary: Release Testing Instructions: Verify FLINK-33325 Built-in cross-platform powerful java profiler Key: FLINK-34310 URL: https://issues.apache.org/jira/browse/FLINK-34310

[jira] [Created] (FLINK-34308) Release Testing Instructions: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34308: --- Summary: Release Testing Instructions: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded Key: FLINK-34308 URL:

[jira] [Created] (FLINK-34307) Release Testing Instructions: Verify FLINK-33972 Enhance and synchronize Sink API to match the Source API

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34307: --- Summary: Release Testing Instructions: Verify FLINK-33972 Enhance and synchronize Sink API to match the Source API Key: FLINK-34307 URL:

RE: [VOTE] Release flink-connector-mongodb v1.1.0, release candidate #2

2024-01-30 Thread Jiabao Sun
Thanks Leonard for driving this. +1(non-binding) - Release notes look good - Tag is present in Github - Validated checksum hash - Verified signature - Build the source with Maven by jdk8,11,17,21 - Checked the dist jar was built by jdk8 - Reviewed web PR - Run a filter push down test by

[jira] [Created] (FLINK-34306) Release Testing Instructions: Verify FLINK-25857 Add committer metrics to track the status of committables

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34306: --- Summary: Release Testing Instructions: Verify FLINK-25857 Add committer metrics to track the status of committables Key: FLINK-34306 URL:

[jira] [Created] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34305: --- Summary: Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources Key: FLINK-34305 URL: https://issues.apache.org/jira/browse/FLINK-34305

[jira] [Created] (FLINK-34304) Release Testing Instructions: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34304: --- Summary: Release Testing Instructions: Verify FLINK-34219 Introduce a new join operator to support minibatch Key: FLINK-34304 URL: https://issues.apache.org/jira/browse/FLINK-34304

[jira] [Created] (FLINK-34303) Release Testing Instructions: Verify FLINK-34054 Support named parameters for functions and procedures

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34303: --- Summary: Release Testing Instructions: Verify FLINK-34054 Support named parameters for functions and procedures Key: FLINK-34303 URL:

[jira] [Created] (FLINK-34302) Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34302: --- Summary: Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializable Key: FLINK-34302 URL: https://issues.apache.org/jira/browse/FLINK-34302 Project:

[jira] [Created] (FLINK-34301) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34301: --- Summary: Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input Key: FLINK-34301 URL: https://issues.apache.org/jira/browse/FLINK-34301

[jira] [Created] (FLINK-34300) Release Testing: Verify FLINK-24024 Support session Window TVF

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34300: --- Summary: Release Testing: Verify FLINK-24024 Support session Window TVF Key: FLINK-34300 URL: https://issues.apache.org/jira/browse/FLINK-34300 Project: Flink

[jira] [Created] (FLINK-34299) Release Testing: Verify FLINK-33203 Adding a separate configuration for specifying Java Options of the SQL Gateway

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34299: --- Summary: Release Testing: Verify FLINK-33203 Adding a separate configuration for specifying Java Options of the SQL Gateway Key: FLINK-34299 URL:

[jira] [Created] (FLINK-34298) Release Testing: Verify FLINK-33397 Support Configuring Different State TTLs using SQL Hint

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34298: --- Summary: Release Testing: Verify FLINK-33397 Support Configuring Different State TTLs using SQL Hint Key: FLINK-34298 URL: https://issues.apache.org/jira/browse/FLINK-34298

[jira] [Created] (FLINK-34297) Release Testing: Verify FLINK-34079 Migrate string configuration key to ConfigOption

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34297: --- Summary: Release Testing: Verify FLINK-34079 Migrate string configuration key to ConfigOption Key: FLINK-34297 URL: https://issues.apache.org/jira/browse/FLINK-34297

[jira] [Created] (FLINK-34296) Release Testing: Verify FLINK-33581 Deprecate configuration getters/setters that return/set complex Java objects

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34296: --- Summary: Release Testing: Verify FLINK-33581 Deprecate configuration getters/setters that return/set complex Java objects Key: FLINK-34296 URL:

[jira] [Created] (FLINK-34295) Release Testing: Verify FLINK-33712 Deprecate RuntimeContext#getExecutionConfig

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34295: --- Summary: Release Testing: Verify FLINK-33712 Deprecate RuntimeContext#getExecutionConfig Key: FLINK-34295 URL: https://issues.apache.org/jira/browse/FLINK-34295

[jira] [Created] (FLINK-34294) Release Testing: Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34294: --- Summary: Release Testing: Verify FLINK-33297 Support standard YAML for FLINK configuration Key: FLINK-34294 URL: https://issues.apache.org/jira/browse/FLINK-34294

[jira] [Created] (FLINK-34293) Release Testing: Verify FLINK-34190 Deprecate RestoreMode#LEGACY

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34293: --- Summary: Release Testing: Verify FLINK-34190 Deprecate RestoreMode#LEGACY Key: FLINK-34293 URL: https://issues.apache.org/jira/browse/FLINK-34293 Project: Flink

[jira] [Created] (FLINK-34292) Release Testing: Verify FLINK-30613 Improve resolving schema compatibility

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34292: --- Summary: Release Testing: Verify FLINK-30613 Improve resolving schema compatibility Key: FLINK-34292 URL: https://issues.apache.org/jira/browse/FLINK-34292 Project:

[jira] [Created] (FLINK-34291) Release Testing: Verify FLINK-33697 Support adding custom metrics in Recovery Spans

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34291: --- Summary: Release Testing: Verify FLINK-33697 Support adding custom metrics in Recovery Spans Key: FLINK-34291 URL: https://issues.apache.org/jira/browse/FLINK-34291

[jira] [Created] (FLINK-34290) Release Testing: Verify FLINK-33696 Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34290: --- Summary: Release Testing: Verify FLINK-33696 Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter Key: FLINK-34290 URL: https://issues.apache.org/jira/browse/FLINK-34290

[jira] [Created] (FLINK-34289) Release Testing: Verify FLINK-33695 Introduce TraceReporter and use it to create checkpointing and recovery traces

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34289: --- Summary: Release Testing: Verify FLINK-33695 Introduce TraceReporter and use it to create checkpointing and recovery traces Key: FLINK-34289 URL:

[jira] [Created] (FLINK-34288) Release Testing: Verify FLINK-33735 Improve the exponential-delay restart-strategy

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34288: --- Summary: Release Testing: Verify FLINK-33735 Improve the exponential-delay restart-strategy Key: FLINK-34288 URL: https://issues.apache.org/jira/browse/FLINK-34288

[jira] [Created] (FLINK-34287) Release Testing: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34287: --- Summary: Release Testing: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs Key: FLINK-34287 URL: https://issues.apache.org/jira/browse/FLINK-34287

[ANNOUNCE] Flink 1.19 feature freeze & sync summary on 01/30/2024

2024-01-30 Thread Lincoln Lee
Hi everyone, (Since feature freeze and release sync are on the same day, we merged the announcement and sync summary together) *- Feature freeze* The feature freeze of 1.19 has started now. That means that no new features or improvements should now be merged into the master branch unless you

Re: [DISCUSS] FLIP-419: Optimize multi-sink query plan generation

2024-01-30 Thread Jeyhun Karimov
Hi devs, I just wanted to give an update on this FLIP. I updated the doc based on the comments from Jim. Also, I developed a prototype and did some testing. I in my small prototype I ran the following tests: -

[jira] [Created] (FLINK-34286) Attach cluster config map labels at creation time

2024-01-30 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34286: Summary: Attach cluster config map labels at creation time Key: FLINK-34286 URL: https://issues.apache.org/jira/browse/FLINK-34286 Project: Flink

[jira] [Created] (FLINK-34285) [Umbrella] Test Flink Release 1.19

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34285: --- Summary: [Umbrella] Test Flink Release 1.19 Key: FLINK-34285 URL: https://issues.apache.org/jira/browse/FLINK-34285 Project: Flink Issue Type: Improvement

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

2024-01-30 Thread Leonard Xu
Sorry for late verification, +1(binding) - built from source code succeeded - verified signatures - verified hashsums - checked the contents contains jar and pom files in apache repo - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2024年1月13日

[VOTE] Release flink-connector-mongodb v1.1.0, release candidate #2

2024-01-30 Thread Leonard Xu
Hey all, Please help review and vote on the release candidate #2 for the version v1.1.0 of the Apache Flink MongoDB Connector 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,

[jira] [Created] (FLINK-34284) Submit Software License Grant to ASF

2024-01-30 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-34284: -- Summary: Submit Software License Grant to ASF Key: FLINK-34284 URL: https://issues.apache.org/jira/browse/FLINK-34284 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34283) CLONE - Verify that no exclusions were erroneously added to the japicmp plugin

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34283: --- Summary: CLONE - Verify that no exclusions were erroneously added to the japicmp plugin Key: FLINK-34283 URL: https://issues.apache.org/jira/browse/FLINK-34283

[jira] [Created] (FLINK-34279) CLONE - Cross team testing

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34279: --- Summary: CLONE - Cross team testing Key: FLINK-34279 URL: https://issues.apache.org/jira/browse/FLINK-34279 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34282) CLONE - Create a release branch

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34282: --- Summary: CLONE - Create a release branch Key: FLINK-34282 URL: https://issues.apache.org/jira/browse/FLINK-34282 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34277) CLONE - Triage release-blocking issues in JIRA

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34277: --- Summary: CLONE - Triage release-blocking issues in JIRA Key: FLINK-34277 URL: https://issues.apache.org/jira/browse/FLINK-34277 Project: Flink Issue Type:

[jira] [Created] (FLINK-34276) CLONE - Create a new version in JIRA

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34276: --- Summary: CLONE - Create a new version in JIRA Key: FLINK-34276 URL: https://issues.apache.org/jira/browse/FLINK-34276 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34281) CLONE - Select executing Release Manager

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34281: --- Summary: CLONE - Select executing Release Manager Key: FLINK-34281 URL: https://issues.apache.org/jira/browse/FLINK-34281 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34275) Prepare Flink 1.19 Release

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34275: --- Summary: Prepare Flink 1.19 Release Key: FLINK-34275 URL: https://issues.apache.org/jira/browse/FLINK-34275 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-34280) CLONE - Review Release Notes in JIRA

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34280: --- Summary: CLONE - Review Release Notes in JIRA Key: FLINK-34280 URL: https://issues.apache.org/jira/browse/FLINK-34280 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34278) CLONE - Review and update documentation

2024-01-30 Thread lincoln lee (Jira)
lincoln lee created FLINK-34278: --- Summary: CLONE - Review and update documentation Key: FLINK-34278 URL: https://issues.apache.org/jira/browse/FLINK-34278 Project: Flink Issue Type: Sub-task

Confluence access request

2024-01-30 Thread tanjialiang
Hi, devs! I want to prepare a FLIP and start a discussion on the dev mailing list, but I find I don't have the access, can someone give me access to confluence? My Confluence username: tanjialiang Best regards, tanjialiang

[jira] [Created] (FLINK-34273) git fetch fails

2024-01-30 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34273: - Summary: git fetch fails Key: FLINK-34273 URL: https://issues.apache.org/jira/browse/FLINK-34273 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-34274) AdaptiveSchedulerTest.testRequirementLowerBoundDecreaseAfterResourceScarcityBelowAvailableSlots times out

2024-01-30 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34274: - Summary: AdaptiveSchedulerTest.testRequirementLowerBoundDecreaseAfterResourceScarcityBelowAvailableSlots times out Key: FLINK-34274 URL: