Re: [PR] [FLINK-33914][ci] Adds basic Flink CI workflow [flink]

2024-01-19 Thread via GitHub
XComp commented on PR #23970: URL: https://github.com/apache/flink/pull/23970#issuecomment-1901781107 The [past force push](https://github.com/apache/flink/compare/947e77f8535285ebe45d4300e0a6e088aafeae79..081dcd6fa0aebc00eb9a8cb6277695ef431b2e49) squashes the following changes into the rea

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808872#comment-17808872 ] Matthias Pohl edited comment on FLINK-34007 at 1/20/24 6:11 AM: --

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808872#comment-17808872 ] Matthias Pohl edited comment on FLINK-34007 at 1/20/24 6:12 AM: --

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808872#comment-17808872 ] Matthias Pohl commented on FLINK-34007: --- Increasing the thread size was necessary

Re: [PR] [FLINK-33914][ci] Adds basic Flink CI workflow [flink]

2024-01-19 Thread via GitHub
XComp commented on PR #23970: URL: https://github.com/apache/flink/pull/23970#issuecomment-1901775011 The force push above is a plain rebase to most recent master to include FLINK-33907 and FLINK-34510 -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-33132] Flink Connector Redshift TableSink Implementation [flink-connector-aws]

2024-01-19 Thread via GitHub
melin commented on PR #114: URL: https://github.com/apache/flink-connector-aws/pull/114#issuecomment-1901773568 1、The tuncate table paramter is supported in the batch import scenario. If data exists in a table, duplicate data will be generated and the table must be cleared first 2、Can u

[jira] [Updated] (FLINK-34171) Cannot restore from savepoint when increasing parallelism of operator using reinterpretAsKeyedStream and RichAsyncFunction

2024-01-19 Thread Ken Burford (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Burford updated FLINK-34171: Description: We recently upgraded from Flink 1.14.2 to 1.17.0. Our job has not materially changed

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-01-19 Thread via GitHub
flinkbot commented on PR #24156: URL: https://github.com/apache/flink/pull/24156#issuecomment-1901290843 ## CI report: * e7e7684af95b8571b6db9fda9a396d92b4256bc2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
jnh5y commented on PR #24155: URL: https://github.com/apache/flink/pull/24155#issuecomment-1901289792 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-01-19 Thread via GitHub
jeyhunkarimov opened a new pull request, #24156: URL: https://github.com/apache/flink/pull/24156 ## What is the purpose of the change This pull request adds JSON_QUOTE and JSON_UNQUOTE functions ## Brief change log - Add the necessary documentation and functions to

Re: [PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
jnh5y commented on PR #24155: URL: https://github.com/apache/flink/pull/24155#issuecomment-1901281000 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
jnh5y commented on PR #24155: URL: https://github.com/apache/flink/pull/24155#issuecomment-1901153363 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
flinkbot commented on PR #24155: URL: https://github.com/apache/flink/pull/24155#issuecomment-1901077942 ## CI report: * 8efb7ec8160d787817c1f1ef268d8489e10d0a67 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
jnh5y commented on PR #24155: URL: https://github.com/apache/flink/pull/24155#issuecomment-1901075344 This implements the first part of FLINK-33494 / FLIP-376. Notably, the things left to do are: FLINK-34172 (ALTER TABLE support) FLINK-34173 (Adding a CatalogTable.Builder). --

[jira] [Updated] (FLINK-33495) Add catalog and connector ability API and validation

2024-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33495: --- Labels: pull-request-available (was: ) > Add catalog and connector ability API and validati

[PR] [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause [flink]

2024-01-19 Thread via GitHub
jnh5y opened a new pull request, #24155: URL: https://github.com/apache/flink/pull/24155 * Adds DISTRIBUTED BY clause to CREATE TABLE * Adds Distribution support to CatalogTable * Add classes - TableDistribution - SupportsBucketing Adds distribution to TableDescriptor.

[jira] [Created] (FLINK-34173) Implement CatalogTable.Builder

2024-01-19 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-34173: -- Summary: Implement CatalogTable.Builder Key: FLINK-34173 URL: https://issues.apache.org/jira/browse/FLINK-34173 Project: Flink Issue Type: Sub-task R

[jira] [Assigned] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

2024-01-19 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-34172: -- Assignee: Jim Hughes > Add support for altering a distribution via ALTER TABLE > ---

[jira] [Created] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

2024-01-19 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-34172: -- Summary: Add support for altering a distribution via ALTER TABLE Key: FLINK-34172 URL: https://issues.apache.org/jira/browse/FLINK-34172 Project: Flink Issue Ty

[jira] [Updated] (FLINK-34171) Cannot restore from savepoint when increasing parallelism of operator using reinterpretAsKeyedStream and RichAsyncFunction

2024-01-19 Thread Ken Burford (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Burford updated FLINK-34171: Description: We recently upgraded from Flink 1.14.2 to 1.17.0. Our job has not materially changed

[jira] [Updated] (FLINK-34171) Cannot restore from savepoint when increasing parallelism of operator using reinterpretAsKeyedStream and RichAsyncFunction

2024-01-19 Thread Ken Burford (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Burford updated FLINK-34171: Description: We recently upgraded from Flink 1.14.2 to 1.17.0. Our job has not materially changed

[jira] [Created] (FLINK-34171) Cannot restore from savepoint when increasing parallelism of operator using reinterpretAsKeyedStream and RichAsyncFunction

2024-01-19 Thread Ken Burford (Jira)
Ken Burford created FLINK-34171: --- Summary: Cannot restore from savepoint when increasing parallelism of operator using reinterpretAsKeyedStream and RichAsyncFunction Key: FLINK-34171 URL: https://issues.apache.org/j

[jira] [Updated] (FLINK-33846) Remove outdated versions (need PMC role)

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33846: Description: h4. dist.apache.org For a new bugfix version remove all release files for previous bugfix re

Re: [PR] [FLINK-34000] Implement restore tests for IncrementalGroupAgg node [flink]

2024-01-19 Thread via GitHub
flinkbot commented on PR #24154: URL: https://github.com/apache/flink/pull/24154#issuecomment-1900799197 ## CI report: * 8c65d2c4b13b3ab943fa600efb4b544ba0882d30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2024-01-19 Thread via GitHub
davidradl commented on code in PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1459375955 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java: ## @@ -70,6 +98,51 @@ public void testFilterPushdown() {

[jira] [Created] (FLINK-34170) Include the look up join conditions in the optimised plan.

2024-01-19 Thread david radley (Jira)
david radley created FLINK-34170: Summary: Include the look up join conditions in the optimised plan. Key: FLINK-34170 URL: https://issues.apache.org/jira/browse/FLINK-34170 Project: Flink Is

Re: [PR] [FLINK-34000] Implement restore tests for IncrementalGroupAgg node [flink]

2024-01-19 Thread via GitHub
bvarghese1 commented on code in PR #24154: URL: https://github.com/apache/flink/pull/24154#discussion_r1459374849 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/IncrementalGroupAggregateTestPrograms.java: ## @@ -0,0 +1,130

[PR] [FLINK-34000] Implement restore tests for IncrementalGroupAgg node [flink]

2024-01-19 Thread via GitHub
bvarghese1 opened a new pull request, #24154: URL: https://github.com/apache/flink/pull/24154 ## What is the purpose of the change *Add restore tests for IncrementalGroupAggregate node* ## Verifying this change This change added tests and can be verified as follows:

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2024-01-19 Thread via GitHub
davidradl commented on code in PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1459366515 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java: ## @@ -116,6 +124,15 @@ public void open(Functio

Re: [PR] [FLINK-33850][doc] Update minor version for 1.18.1 release [flink]

2024-01-19 Thread via GitHub
JingGe merged PR #24107: URL: https://github.com/apache/flink/pull/24107 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Resolved] (FLINK-33850) Updates the docs stable version

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33850. - Resolution: Fixed > Updates the docs stable version > --- > >

[jira] [Resolved] (FLINK-33848) Other announcements

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33848. - Resolution: Fixed > Other announcements > --- > > Key: FLINK-33848 >

Re: [PR] [FLINK-33975] Tests for the new Sink V2 transformations [flink]

2024-01-19 Thread via GitHub
flinkbot commented on PR #24153: URL: https://github.com/apache/flink/pull/24153#issuecomment-1900747679 ## CI report: * 1b1ef8fd0ce5a223f5863ae8d0c746513373bd7a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33975) Tests for the new Sink V2 transformations

2024-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33975: --- Labels: pull-request-available (was: ) > Tests for the new Sink V2 transformations > --

[PR] [FLINK-33975] Tests for the new Sink V2 transformations [flink]

2024-01-19 Thread via GitHub
pvary opened a new pull request, #24153: URL: https://github.com/apache/flink/pull/24153 ## What is the purpose of the change Moving Sink tests to using the new Sink API, and creating new deprecated ones to keep testing the old Sink API. Also adding a few specific tests. ##

[jira] [Resolved] (FLINK-33844) Update japicmp configuration

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33844. - Resolution: Fixed > Update japicmp configuration > > > Key:

Re: [PR] [FLINK-33844][doc] Update japicmp configuration for 1.18.1 [flink]

2024-01-19 Thread via GitHub
JingGe merged PR #24123: URL: https://github.com/apache/flink/pull/24123 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-33844][doc] Update japicmp configuration for 1.18.1 [flink]

2024-01-19 Thread via GitHub
JingGe commented on PR #24123: URL: https://github.com/apache/flink/pull/24123#issuecomment-1900730652 Thanks @XComp ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To un

[jira] [Resolved] (FLINK-33847) Apache mailing lists announcements

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33847. - Resolution: Fixed > Apache mailing lists announcements > -- > >

[jira] [Commented] (FLINK-33847) Apache mailing lists announcements

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808730#comment-17808730 ] Jing Ge commented on FLINK-33847: - https://lists.apache.org/thread/p5f4j11nylvhw15knvlbz

[jira] [Resolved] (FLINK-33845) Merge website pull request

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33845. - Resolution: Fixed > Merge website pull request > -- > > Key: FLI

[jira] [Resolved] (FLINK-33885) Build Release Candidate: 1.18.1-rc2

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33885. - Resolution: Fixed > Build Release Candidate: 1.18.1-rc2 > --- > >

[jira] [Resolved] (FLINK-33888) Propose a pull request for website updates

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33888. - Resolution: Fixed > Propose a pull request for website updates > ---

Re: [PR] [hotfix] fix typo in the 1.18.1 release announcement [flink-web]

2024-01-19 Thread via GitHub
JingGe merged PR #716: URL: https://github.com/apache/flink-web/pull/716 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty [flink]

2024-01-19 Thread via GitHub
flinkbot commented on PR #24152: URL: https://github.com/apache/flink/pull/24152#issuecomment-1900715765 ## CI report: * 0ac79867089732ecba26b32b985519be084e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34166) KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty

2024-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34166: --- Labels: pull-request-available (was: ) > KeyedLookupJoinWrapper incorrectly process delete

[PR] [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty [flink]

2024-01-19 Thread via GitHub
lincoln-lil opened a new pull request, #24152: URL: https://github.com/apache/flink/pull/24152 ## What is the purpose of the change KeyedLookupJoinWrapper(when 'table.optimizer.non-deterministic-update.strategy ' is set to 'TRY_RESOLVE' and the lookup join exists NDU problemns) incorr

[PR] [hotfix] fix typo in the 1.18.1 release announcement [flink-web]

2024-01-19 Thread via GitHub
JingGe opened a new pull request, #716: URL: https://github.com/apache/flink-web/pull/716 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mai

[jira] [Updated] (FLINK-33846) Remove outdated versions (need PMC role)

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33846: Description: h4. dist.apache.org For a new bugfix version remove all release files for previous bugfix re

Re: [PR] [FLINK-33845] Rebuild Website [flink-web]

2024-01-19 Thread via GitHub
JingGe commented on PR #714: URL: https://github.com/apache/flink-web/pull/714#issuecomment-1900652497 Thanks! @XComp -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To un

Re: [PR] [FLINK-33845] Rebuild Website [flink-web]

2024-01-19 Thread via GitHub
JingGe merged PR #714: URL: https://github.com/apache/flink-web/pull/714 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Comment Edited] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808603#comment-17808603 ] David Morávek edited comment on FLINK-34063 at 1/19/24 2:29 PM: --

[jira] [Resolved] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-34063. --- Resolution: Fixed > When snapshot compression is enabled, rescaling of a source operator lea

Re: [PR] [BP-1.18][FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot. [flink]

2024-01-19 Thread via GitHub
dmvk merged PR #24083: URL: https://github.com/apache/flink/pull/24083 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.o

Re: [PR] [hotfix] Update version to 18.0 [flink-shaded]

2024-01-19 Thread via GitHub
XComp commented on code in PR #133: URL: https://github.com/apache/flink-shaded/pull/133#discussion_r1459013385 ## flink-shaded-asm-9/pom.xml: ## @@ -25,11 +25,11 @@ under the License. org.apache.flink flink-shaded -17.0 +18.0 Review Comm

[jira] [Closed] (FLINK-33974) Implement the Sink transformation depending on the new SinkV2 interfaces

2024-01-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33974. -- Fix Version/s: 1.19.0 Resolution: Fixed merged to master fd673a2f46206ff65978f05fcb96b525696aea

Re: [PR] [FLINK-33974] Implement the Sink transformation depending on the new SinkV2 interfaces [flink]

2024-01-19 Thread via GitHub
gyfora merged PR #24103: URL: https://github.com/apache/flink/pull/24103 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-01-19 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808635#comment-17808635 ] Jiabao Sun commented on FLINK-34156: Thanks [~Sergey Nuyanzin]. If there is a need f

Re: [PR] [FLINK-33888] Add a note for a blocker issue [flink-web]

2024-01-19 Thread via GitHub
JingGe merged PR #715: URL: https://github.com/apache/flink-web/pull/715 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-33888] Add a note for a blocker issue [flink-web]

2024-01-19 Thread via GitHub
JingGe commented on PR #715: URL: https://github.com/apache/flink-web/pull/715#issuecomment-1900344185 Thanks @MartijnVisser! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34104][autoscaler] Improve the ScalingReport format of autoscaling [flink-kubernetes-operator]

2024-01-19 Thread via GitHub
mxm commented on code in PR #757: URL: https://github.com/apache/flink-kubernetes-operator/pull/757#discussion_r1458941912 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoscalerEventUtils.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-33450][autoscaler] Support the JDBCAutoScalerStateStore [flink-kubernetes-operator]

2024-01-19 Thread via GitHub
mxm commented on PR #741: URL: https://github.com/apache/flink-kubernetes-operator/pull/741#issuecomment-1900339753 LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Commented] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-19 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808630#comment-17808630 ] Martijn Visser commented on FLINK-34148: Let's mark it as a blocker; worst case

[jira] [Updated] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-19 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34148: --- Priority: Blocker (was: Critical) > Potential regression (Jan. 13): stringWrite with Java8

[jira] [Commented] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

2024-01-19 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808629#comment-17808629 ] Martijn Visser commented on FLINK-34149: Thank you [~lindong] and [~yunfengzhou]

[PR] [FLINK-33888] Add a note for a blocker issue [flink-web]

2024-01-19 Thread via GitHub
JingGe opened a new pull request, #715: URL: https://github.com/apache/flink-web/pull/715 Add a note for a blocker issue FLINK-34063 which will be fixed in 1.18.2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [Flink 32701] [cep] Fix CEP Operator Memory Leak Issue [flink]

2024-01-19 Thread via GitHub
MartijnVisser commented on PR #24084: URL: https://github.com/apache/flink/pull/24084#issuecomment-1900334701 @pdream17 You'll need to rebase, and not use merge-commits since PRs that contain merge commits can't be merged -- This is an automated message from the Apache Git Service. To res

Re: [PR] [FLINK-34117][bugfix][table] Fix CompactCoordinator data loss upon termination [flink]

2024-01-19 Thread via GitHub
afedulov commented on PR #24120: URL: https://github.com/apache/flink/pull/24120#issuecomment-1900329185 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Commented] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-19 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808625#comment-17808625 ] Sergey Nuyanzin commented on FLINK-34148: - interesting, my first guess is jackso

Re: [PR] [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging [flink]

2024-01-19 Thread via GitHub
XComp commented on code in PR #24003: URL: https://github.com/apache/flink/pull/24003#discussion_r1458870055 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandlerTest.java: ## @@ -183,6 +194,59 @@ void testNonRecoverableFailureHa

Re: [PR] [Flink 32701] [cep] Fix CEP Operator Memory Leak Issue [flink]

2024-01-19 Thread via GitHub
pdream17 commented on PR #24084: URL: https://github.com/apache/flink/pull/24084#issuecomment-1900312312 Thanks @MartijnVisser . Have corrected it and CI phase is success. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Closed] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

2024-01-19 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-34149. Resolution: Fixed > Flink Kafka connector can't compile against 1.19-SNAPSHOT > --

[jira] [Assigned] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

2024-01-19 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-34149: Assignee: Yunfeng Zhou > Flink Kafka connector can't compile against 1.19-SNAPSHOT >

[jira] [Commented] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

2024-01-19 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808624#comment-17808624 ] Dong Lin commented on FLINK-34149: -- Merged to master branch b309ceb8de005fd65d979ffce92

Re: [PR] [FLINK-34149][Runtime/Checkpointing] Fix SplitEnumeratorContext compatibility issue [flink]

2024-01-19 Thread via GitHub
lindong28 merged PR #24146: URL: https://github.com/apache/flink/pull/24146 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apa

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808623#comment-17808623 ] Jing Ge commented on FLINK-34135: - gotcha, thanks! Let's keep this ticket open for a few

[jira] [Commented] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808622#comment-17808622 ] Zakelly Lan commented on FLINK-34148: - Also ping release managers of 1.19 [~lincoln.

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

2024-01-19 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808620#comment-17808620 ] Sergey Nuyanzin commented on FLINK-34135: - The point is that there are several s

Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka]

2024-01-19 Thread via GitHub
MartijnVisser commented on PR #76: URL: https://github.com/apache/flink-connector-kafka/pull/76#issuecomment-1900300761 @ruanhang1993 If you want to add support for this feature, I think you need to propose to drop support for Flink 1.18 in this version -- This is an automated message fr

[jira] [Commented] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808618#comment-17808618 ] Zakelly Lan commented on FLINK-34148: - After some investigation, I found it is this

Re: [PR] [hotfix] Update version to 18.0 [flink-shaded]

2024-01-19 Thread via GitHub
MartijnVisser commented on code in PR #133: URL: https://github.com/apache/flink-shaded/pull/133#discussion_r1458877150 ## flink-shaded-asm-9/pom.xml: ## @@ -25,11 +25,11 @@ under the License. org.apache.flink flink-shaded -17.0 +18.0 Rev

[jira] [Updated] (FLINK-33845) Merge website pull request

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33845: Description: Merge the website pull request to [list the release|http://flink.apache.org/downloads.html].

Re: [PR] [FLINK-33845] Rebuild Website [flink-web]

2024-01-19 Thread via GitHub
JingGe commented on PR #714: URL: https://github.com/apache/flink-web/pull/714#issuecomment-1900265572 The PR does not include some new js files under content that have been generated with new ids, e.g. en.search.min.ac811b400a41013e3d589c56141ea9c5be0e8b97ed1a1a26d091fbe44844ea5c

[jira] [Updated] (FLINK-33845) Merge website pull request

2024-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33845: --- Labels: pull-request-available (was: ) > Merge website pull request > -

[PR] [FLINK-33845] Rebuild Website [flink-web]

2024-01-19 Thread via GitHub
JingGe opened a new pull request, #714: URL: https://github.com/apache/flink-web/pull/714 Rebuild Website -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-

Re: [PR] [FLINK-34104][autoscaler] Improve the ScalingReport format of autoscaling [flink-kubernetes-operator]

2024-01-19 Thread via GitHub
1996fanrui commented on code in PR #757: URL: https://github.com/apache/flink-kubernetes-operator/pull/757#discussion_r1458859337 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoscalerEventUtils.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

2024-01-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808606#comment-17808606 ] Jing Ge commented on FLINK-34135: - [~Sergey Nuyanzin] thanks for letting us know. After

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Release Note: Fixes a regression introduced in 1.18.0, where operator state couldn't be prope

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Release Note: Fixes a regression introduced in 1.18.0, where operator state couldn't be proper

[jira] [Commented] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808603#comment-17808603 ] David Morávek commented on FLINK-34063: --- master: 161378ad3a234f4ff17b6fd4e6f950e2

Re: [PR] [hotfix] Add test dependency to fix tests in flink-table-planner module [flink]

2024-01-19 Thread via GitHub
dawidwys closed pull request #24138: [hotfix] Add test dependency to fix tests in flink-table-planner module URL: https://github.com/apache/flink/pull/24138 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] [hotfix] Add test dependency to fix tests in flink-table-planner module [flink]

2024-01-19 Thread via GitHub
dawidwys commented on PR #24138: URL: https://github.com/apache/flink/pull/24138#issuecomment-1900236891 Closing in favor of 8dd28a2e8bf10ec278ff90c99563468e294a135a -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException [flink]

2024-01-19 Thread via GitHub
dawidwys merged PR #24147: URL: https://github.com/apache/flink/pull/24147 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

Re: [PR] [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot. [flink]

2024-01-19 Thread via GitHub
dmvk merged PR #24079: URL: https://github.com/apache/flink/pull/24079 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.o

Re: [PR] [FLINK-33450][autoscaler] Support the JDBCAutoScalerStateStore [flink-kubernetes-operator]

2024-01-19 Thread via GitHub
1996fanrui commented on PR #741: URL: https://github.com/apache/flink-kubernetes-operator/pull/741#issuecomment-1900226029 Hi @gyfora @mxm , do you have any other comments? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [hotfix] Update version to 18.0 [flink-shaded]

2024-01-19 Thread via GitHub
snuyanzin commented on PR #133: URL: https://github.com/apache/flink-shaded/pull/133#issuecomment-1900220507 Actually this is a good point, thanks for raising it I didn't find this at [1] , so agree we need to update it I believe @MartijnVisser has more info about that, could you pleas

[jira] [Resolved] (FLINK-34150) file sink e2e tests with local setup are not executed if s3 credentials are not provided

2024-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34150. --- Fix Version/s: 1.19.0 1.17.3 1.18.2 Resolution:

Re: [PR] [FLINK-34150][ci] Enables local file sink e2e tests in general CI setups [flink]

2024-01-19 Thread via GitHub
XComp merged PR #24131: URL: https://github.com/apache/flink/pull/24131 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.

[jira] [Assigned] (FLINK-34150) file sink e2e tests with local setup are not executed if s3 credentials are not provided

2024-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34150: - Assignee: Matthias Pohl > file sink e2e tests with local setup are not executed if s3 c

Re: [PR] [BP-1.17][FLINK-34150][ci] Enables local file sink e2e tests in general CI setups [flink]

2024-01-19 Thread via GitHub
XComp commented on PR #24137: URL: https://github.com/apache/flink/pull/24137#issuecomment-1900216120 :heavy_check_mark: Parent PR got approved. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

  1   2   >