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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807809#comment-17807809 ] Sergey Nuyanzin edited comment on FLINK-34135 at 1/17/24 4:52 PM: -- most

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

2024-01-17 Thread via GitHub
davidradl commented on PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1896205523 Hi @libenchao @snuyanzin , I have got the POC mostly working. I added fixups and some junits to

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807809#comment-17807809 ] Sergey Nuyanzin edited comment on FLINK-34135 at 1/17/24 4:49 PM: -- most

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807809#comment-17807809 ] Sergey Nuyanzin edited comment on FLINK-34135 at 1/17/24 4:47 PM: -- most

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807809#comment-17807809 ] Sergey Nuyanzin edited comment on FLINK-34135 at 1/17/24 4:47 PM: -- most

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807809#comment-17807809 ] Sergey Nuyanzin commented on FLINK-34135: - most of the yes there is at least one reproduction

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

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807805#comment-17807805 ] Matthias Pohl commented on FLINK-34135: --- Yes, actually all the builds [~snuyanzin] shared were

[jira] [Comment Edited] (FLINK-33776) Allow to specify optional profile for connectors

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807803#comment-17807803 ] Etienne Chauchot edited comment on FLINK-33776 at 1/17/24 4:39 PM: ---

[jira] [Commented] (FLINK-33776) Allow to specify optional profile for connectors

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807803#comment-17807803 ] Etienne Chauchot commented on FLINK-33776: -- [~Sergey Nuyanzin] I'm releasing

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

2024-01-17 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807802#comment-17807802 ] Jing Ge commented on FLINK-34135: - [~Sergey Nuyanzin] it looks like most failed builds were running on

Re: [PR] Pushdown predicates to lookup function [flink-connector-jdbc]

2024-01-17 Thread via GitHub
davidradl closed pull request #92: Pushdown predicates to lookup function URL: https://github.com/apache/flink-connector-jdbc/pull/92 -- 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

Re: [PR] [FLINK-27992] Set ALWAYS chaining strategy for CepOperator in ExecMatch [flink]

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

Re: [PR] [FLINK-34137] Update CI to test archunit configuration [flink-connector-shared-utils]

2024-01-17 Thread via GitHub
echauchot commented on PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#issuecomment-1896158738 Jira ticket moved to a subtask FLINK-34137: branch squashed and rebased and PR renamed. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-34137) Update CI to test archunit configuration

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34137: --- Labels: pull-request-available (was: ) > Update CI to test archunit configuration >

[jira] [Updated] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27992: --- Labels: pull-request-available (was: ) > cep StreamExecMatch need check the parallelism

[PR] [FLINK-27992] Set ALWAYS chaining strategy for CepOperator in ExecMatch [flink]

2024-01-17 Thread via GitHub
dawidwys opened a new pull request, #24122: URL: https://github.com/apache/flink/pull/24122 ## What is the purpose of the change Set the chaining strategy of CepOperator to ALWAYS so that it can be chained with StreamRecordInserter. This is important to keep those two operators as

Re: [PR] [FLINK-34049][table]Refactor classes related to window TVF aggregation to prepare for non-aligned windows [flink]

2024-01-17 Thread via GitHub
fsk119 commented on code in PR #24068: URL: https://github.com/apache/flink/pull/24068#discussion_r1455848131 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/logical/WindowSpec.java: ## @@ -31,4 +32,15 @@ public interface WindowSpec {

[jira] [Updated] (FLINK-34136) Execute archunit tests only with Flink version that connectors were built against

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-34136: - Component/s: Connectors / Parent > Execute archunit tests only with Flink version that

[jira] [Updated] (FLINK-34137) Update CI to test archunit configuration

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-34137: - Component/s: Connectors / Parent > Update CI to test archunit configuration >

[jira] [Updated] (FLINK-34137) Update CI to test archunit configuration

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-34137: - Component/s: Build System / CI > Update CI to test archunit configuration >

[jira] [Resolved] (FLINK-32563) Add additionalExcludes property to add exclusions to surefire tests

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot resolved FLINK-32563. -- Fix Version/s: connector-parent-1.1.0 Resolution: Fixed > Add

[jira] [Created] (FLINK-34137) Update CI to test archunit configuration

2024-01-17 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34137: Summary: Update CI to test archunit configuration Key: FLINK-34137 URL: https://issues.apache.org/jira/browse/FLINK-34137 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32563) Add additionalExcludes property to add exclusions to surefire tests

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-32563: - Description: Add an optional property to add exclusions to surefire tests (among other

[jira] [Updated] (FLINK-32563) Add additionalExcludes property to add exclusions to surefire tests

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-32563: - Component/s: Connectors / Parent (was: Build System / CI) > Add

[jira] [Updated] (FLINK-32563) Add additionalExcludes property to add exclusions to surefire tests

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-32563: - Summary: Add additionalExcludes property to add exclusions to surefire tests (was:

[jira] [Updated] (FLINK-32563) execute archunit tests only with Flink version that connectors were built against

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-32563: - Parent: FLINK-34136 Issue Type: Sub-task (was: Technical Debt) > execute

[jira] [Created] (FLINK-34136) Execute archunit tests only with Flink version that connectors were built against

2024-01-17 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34136: Summary: Execute archunit tests only with Flink version that connectors were built against Key: FLINK-34136 URL: https://issues.apache.org/jira/browse/FLINK-34136

Re: [PR] [FLINK-34126][configuration] Correct the description of jobmanager.scheduler [flink]

2024-01-17 Thread via GitHub
JunRuiLee commented on PR #24112: URL: https://github.com/apache/flink/pull/24112#issuecomment-1896070815 @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

Re: [PR] [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize [flink]

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

Re: [PR] [FLINK-33819] support set CompressionType for RocksDBStateBackend [flink]

2024-01-17 Thread via GitHub
mayuehappy commented on code in PR #24072: URL: https://github.com/apache/flink/pull/24072#discussion_r1455847890 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java: ## @@ -149,24 +144,42 @@

[jira] [Updated] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33182: --- Labels: pull-request-available (was: ) > Allow metadata columns in NduAnalyzer with

[PR] [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize [flink]

2024-01-17 Thread via GitHub
lincoln-lil opened a new pull request, #24121: URL: https://github.com/apache/flink/pull/24121 ## What is the purpose of the change As discussed in the jira of FLINK-33182, metadata columns will not affect determinism when ChangelogNormalize is enabled, this pr aims to relax ndu-anlayze

Re: [PR] [FLINK-33819] support set CompressionType for RocksDBStateBackend [flink]

2024-01-17 Thread via GitHub
mayuehappy commented on code in PR #24072: URL: https://github.com/apache/flink/pull/24072#discussion_r1455817124 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java: ## @@ -149,24 +144,42 @@

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1896013475 @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

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

2024-01-17 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807760#comment-17807760 ] Jing Ge commented on FLINK-34135: - [~Sergey Nuyanzin] [~mapohl] FYI: [~jeyhunkarimov] is working on it.

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

2024-01-17 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-34135: --- Assignee: Jeyhun Karimov > A number of ci failures with Access to the path >

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

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

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

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807758#comment-17807758 ] Matthias Pohl commented on FLINK-34135: --- Just as a fyi for the other release managers: [~lincoln] 

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1895992057 @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

[jira] [Updated] (FLINK-34117) CompactCoordinator for table file sink loses data upon job termination

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34117: --- Labels: pull-request-available (was: ) > CompactCoordinator for table file sink loses data

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

2024-01-17 Thread via GitHub
afedulov commented on PR #24120: URL: https://github.com/apache/flink/pull/24120#issuecomment-1895986994 Haha, indeed. Thanks, fixed. -- 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

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

2024-01-17 Thread via GitHub
MartijnVisser commented on PR #24120: URL: https://github.com/apache/flink/pull/24120#issuecomment-1895983785 @afedulov You already got me excited that you implemented https://issues.apache.org/jira/browse/FLINK-34111 but I think you've linked the wrong Jira ;) -- This is an automated

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

2024-01-17 Thread via GitHub
afedulov commented on PR #24120: URL: https://github.com/apache/flink/pull/24120#issuecomment-1895982433 @JingsongLi could you please take a look? -- 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

[jira] [Updated] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34111: --- Labels: pull-request-available (was: ) > Add JSON_QUOTE and JSON_UNQUOTE function >

[PR] [FLINK-34111][bugfix][table] Fix CompactCoordinator data loss upon termination [flink]

2024-01-17 Thread via GitHub
afedulov opened a new pull request, #24120: URL: https://github.com/apache/flink/pull/24120 CompactCoordinator accumulates data in currentInputFiles and only rolls them into inputFiles in snapshotState(). At the same time it relies on separately receiving checkpoint indications from the

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807752#comment-17807752 ] Sergey Nuyanzin commented on FLINK-34135: -

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

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807751#comment-17807751 ] Matthias Pohl commented on FLINK-34135: --- Could this be related to FLINK-34098 [~jeyhunkarimov] ?

Re: [PR] [FLINK-28915] Support fetching artifacts in native K8s and standalone application mode [flink]

2024-01-17 Thread via GitHub
ferenc-csaky commented on code in PR #24065: URL: https://github.com/apache/flink/pull/24065#discussion_r1455758733 ## flink-clients/src/main/java/org/apache/flink/client/program/artifact/ArtifactFetchManager.java: ## @@ -0,0 +1,185 @@ +/* + * Licensed to the Apache Software

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-34135: Description: There is a number of builds failing with something like {noformat}

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-34135: Description: There is a number of builds failing with something like {noformat}

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807747#comment-17807747 ] Sergey Nuyanzin commented on FLINK-34135: - [~jingge]  since it seems to be related to Alibaba

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

2024-01-17 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34135: --- Summary: A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied. Key: FLINK-34135 URL:

[jira] [Updated] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

2024-01-17 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27992: --- Priority: Blocker (was: Major) > cep StreamExecMatch need check the parallelism and

[jira] [Commented] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

2024-01-17 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807743#comment-17807743 ] Martijn Visser commented on FLINK-27992: [~dwysakowicz] I've upgraded this ticket to a Blocker

Re: [PR] [FLINK-28915] Support fetching artifacts in native K8s and standalone application mode [flink]

2024-01-17 Thread via GitHub
ferenc-csaky commented on code in PR #24065: URL: https://github.com/apache/flink/pull/24065#discussion_r1455716382 ## flink-clients/src/main/java/org/apache/flink/client/program/artifact/ArtifactFetchManager.java: ## @@ -0,0 +1,185 @@ +/* + * Licensed to the Apache Software

[jira] [Comment Edited] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807736#comment-17807736 ] Matthias Pohl edited comment on FLINK-33923 at 1/17/24 2:28 PM: We run

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

2024-01-17 Thread via GitHub
MartijnVisser commented on PR #24084: URL: https://github.com/apache/flink/pull/24084#issuecomment-1895922772 @pdream17 Thanks for the PR, but you'll need to apply spotless since currently it already fails on the compilation step of the CI -- This is an automated message from the Apache

[jira] [Commented] (FLINK-34128) oracle jdbc connector bug. When the oracle table field is of type float, the type obtained by jdbc is bigdecimal. error is 'java.lang.ClassCastException: java.math.Bi

2024-01-17 Thread blackpighe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807739#comment-17807739 ] blackpighe commented on FLINK-34128: !image-2024-01-17-22-18-27-781.png! update this commit,will

[jira] [Updated] (FLINK-34128) oracle jdbc connector bug. When the oracle table field is of type float, the type obtained by jdbc is bigdecimal. error is 'java.lang.ClassCastException: java.math.BigD

2024-01-17 Thread blackpighe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blackpighe updated FLINK-34128: --- Attachment: image-2024-01-17-22-18-27-781.png > oracle jdbc connector bug. When the oracle table

[jira] [Commented] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807736#comment-17807736 ] Matthias Pohl commented on FLINK-33923: --- We run into transient issues with the uploads recently

[jira] [Updated] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33923: -- Description: {{upload-artifacts}} and {{download-artifacts}} can be upgraded to v4. This

Re: [PR] [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API [flink]

2024-01-17 Thread via GitHub
yuchen-ecnu commented on PR #24041: URL: https://github.com/apache/flink/pull/24041#issuecomment-1895891972 Hi @Myasuka , I have added two more tests for `TaskManagerProfilingHandler` and `TaskManagerProfilingListHandler`. -- This is an automated message from the Apache Git Service. To

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

2024-01-17 Thread via GitHub
XComp commented on code in PR #24003: URL: https://github.com/apache/flink/pull/24003#discussion_r1455652997 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/FixedDelayRestartBackoffTimeStrategy.java: ## @@ -61,8 +61,9 @@ public long

Re: [PR] [FLINK-34134] Add tracing for restored state size and locations [flink]

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

[jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34134: --- Labels: pull-request-available (was: ) > Add tracing for restored state size and locations

[PR] [FLINK-34134] Add tracing for restored state size and locations [flink]

2024-01-17 Thread via GitHub
StefanRRichter opened a new pull request, #24119: URL: https://github.com/apache/flink/pull/24119 ## What is the purpose of the change Introduces tracing for state sizes and locations in task recovery. This is particularly interesting for a mixed recovery with some local and some

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-17 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-1895850048 @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

[jira] [Created] (FLINK-34134) Add tracing for restored state size and locations

2024-01-17 Thread Stefan Richter (Jira)
Stefan Richter created FLINK-34134: -- Summary: Add tracing for restored state size and locations Key: FLINK-34134 URL: https://issues.apache.org/jira/browse/FLINK-34134 Project: Flink Issue

[jira] [Comment Edited] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2024-01-17 Thread Yang LI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807401#comment-17807401 ] Yang LI edited comment on FLINK-33545 at 1/17/24 1:34 PM: -- Hello [~aeolus811tw]

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1895814613 @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

[jira] [Assigned] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

2024-01-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-33123: - Assignee: David Morávek > Wrong dynamic replacement of partitioner from FORWARD to

[jira] [Comment Edited] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2024-01-17 Thread Yang LI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807401#comment-17807401 ] Yang LI edited comment on FLINK-33545 at 1/17/24 1:12 PM: -- Hello [~aeolus811tw]

[jira] [Resolved] (FLINK-34070) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails for the AdaptiveScheduler

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

Re: [PR] [FLINK-34070][test] Adds dedicated tests in MiniClusterITCase for scenarios where there are not enough slots available. [flink]

2024-01-17 Thread via GitHub
XComp merged PR #24082: URL: https://github.com/apache/flink/pull/24082 -- 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:

Re: [PR] [FLINK-33971]Specifies whether to use HBase table that supports dynamic columns. [flink-connector-hbase]

2024-01-17 Thread via GitHub
ferenc-csaky commented on PR #36: URL: https://github.com/apache/flink-connector-hbase/pull/36#issuecomment-1895780629 > So I think is better to have a discussion on this topic in the dev mailing list. Agreed! -- This is an automated message from the Apache Git Service. To

Re: [PR] [FLINK-34070][test] Adds dedicated tests in MiniClusterITCase for scenarios where there are not enough slots available. [flink]

2024-01-17 Thread via GitHub
XComp commented on PR #24082: URL: https://github.com/apache/flink/pull/24082#issuecomment-1895778902 Thanks for the review @jiangxin369 and for the approval @snuyanzin . I'm gonna merge this one. The failure is caused by FLINK-34077 and, therefore, unrelated. I verified that the one test

Re: [PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

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

[jira] [Assigned] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

2024-01-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-27992: Assignee: Dawid Wysakowicz > cep StreamExecMatch need check the parallelism and

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1895763918 @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

[jira] [Updated] (FLINK-34077) Python Sphinx version error

2024-01-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34077: -- Fix Version/s: 1.19.0 > Python Sphinx version error > --- > >

Re: [PR] [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits [flink]

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

[jira] [Updated] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34132: --- Labels: pull-request-available (was: ) > Batch WordCount job fails when run with

Re: [PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-17 Thread via GitHub
JunRuiLee commented on PR #24118: URL: https://github.com/apache/flink/pull/24118#issuecomment-1895750981 @wanglijie95 Could you help to review this change when you're free? Thanks a lot! -- This is an automated message from the Apache Git Service. To respond to the message,

[PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-17 Thread via GitHub
JunRuiLee opened a new pull request, #24118: URL: https://github.com/apache/flink/pull/24118 ## What is the purpose of the change Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. ##

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

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

[PR] [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits [flink]

2024-01-17 Thread via GitHub
zhoulii opened a new pull request, #24117: URL: https://github.com/apache/flink/pull/24117 ## What is the purpose of the change fix incorrect inference of minibatch interval traits, related issue [FLINK-34133](https://issues.apache.org/jira/browse/FLINK-34133). ## Brief

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

2024-01-17 Thread zhouli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Attachment: image-2024-01-17-20-34-30-039.png > Merge MiniBatchInterval when propagate traits to child

[jira] [Updated] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

2024-01-17 Thread zhouli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli updated FLINK-34133: --- Description:   we should merge MiniBatchInterval when propagate traits to child block, otherwise we may

[jira] [Created] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

2024-01-17 Thread zhouli (Jira)
zhouli created FLINK-34133: -- Summary: Merge MiniBatchInterval when propagate traits to child block Key: FLINK-34133 URL: https://issues.apache.org/jira/browse/FLINK-34133 Project: Flink Issue

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807709#comment-17807709 ] Junrui Li commented on FLINK-34132: --- After discuss with [~wanglijie] offline, I will prepare a fix to

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1895668532 @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

[jira] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132 ] Junrui Li deleted comment on FLINK-34132: --- was (Author: JIRAUSER293716): Since DataSet is deprecated, I'm unsure if it's still meaningful to make such updates. > Batch WordCount job fails

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

2024-01-17 Thread via GitHub
1996fanrui commented on code in PR #24003: URL: https://github.com/apache/flink/pull/24003#discussion_r145529 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/ExecutionFailureHandlerTest.java: ## @@ -183,6 +194,55 @@ void

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807703#comment-17807703 ] Junrui Li commented on FLINK-34132: --- Since DataSet is deprecated, I'm unsure if it's still meaningful

[jira] [Comment Edited] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807701#comment-17807701 ] Junrui Li edited comment on FLINK-34132 at 1/17/24 11:41 AM: -

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807701#comment-17807701 ] Junrui Li commented on FLINK-34132: --- [~prabhujoseph] The

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

2024-01-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807700#comment-17807700 ] Yang Wang commented on FLINK-34007: --- I agree with you that we could enable {{{}isReleaseOnCancel{}}},

[jira] [Updated] (FLINK-32894) flink-connector-parent should use maven-shade-plugin 3.3.0+ for Java 17

2024-01-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-32894: - Issue Type: Technical Debt (was: Bug) > flink-connector-parent should use

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807697#comment-17807697 ] Lijie Wang commented on FLINK-34132: [~prabhujoseph] AFAIK, adaptive batch scheduler does not

Re: [PR] [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names [flink]

2024-01-17 Thread via GitHub
swuferhong commented on PR #24096: URL: https://github.com/apache/flink/pull/24096#issuecomment-1895601194 @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

<    1   2   3   >