[jira] [Updated] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miamiaoxyz updated FLINK-31059: --- Attachment: image-2023-02-21-15-59-44-470.png > Release Testing: Verify FLINK-29717 Supports hive ud

[GitHub] [flink] Samrat002 commented on pull request #21770: [FLINK-30277][python]Allow PYTHONPATH of Python Worker configurable

2023-02-21 Thread via GitHub
Samrat002 commented on PR #21770: URL: https://github.com/apache/flink/pull/21770#issuecomment-1438005348 Test failure associated ticket https://issues.apache.org/jira/browse/FLINK-31120 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Assigned] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31120: -- Assignee: Shuiqiang Chen > ConcurrentModificationException occurred in StringFunction

[jira] [Commented] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691447#comment-17691447 ] Martijn Visser commented on FLINK-31109: [~vsowrirajan] Is there any eta on this

[jira] [Assigned] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31109: -- Assignee: Venkata krishnan Sowrirajan > Fails with proxy user not supported even when

[jira] [Commented] (FLINK-31092) Hive ITCases fail with OutOfMemoryError

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691453#comment-17691453 ] Martijn Visser commented on FLINK-31092: [~luoyuxia] Can you take a look? > Hiv

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
zhipeng93 commented on code in PR #213: URL: https://github.com/apache/flink-ml/pull/213#discussion_r1112704530 ## flink-ml-servable-core/pom.xml: ## @@ -0,0 +1,127 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
zhipeng93 commented on code in PR #213: URL: https://github.com/apache/flink-ml/pull/213#discussion_r1112704530 ## flink-ml-servable-core/pom.xml: ## @@ -0,0 +1,127 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi

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

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31159: -- Assignee: Hong Liang Teoh (was: Jane Chan) > Release Testing: Verify FLINK-30583 Pro

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

2023-02-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-31159. - Resolution: Fixed This issue has been completed! Sorry for the churn [~qingyue] + [~renq

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

2023-02-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-31159. --- > Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask > level >

[jira] [Updated] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miamiaoxyz updated FLINK-31059: --- Attachment: image-2023-02-21-16-28-22-038.png > Release Testing: Verify FLINK-29717 Supports hive ud

[jira] [Updated] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miamiaoxyz updated FLINK-31059: --- Attachment: image-2023-02-21-16-29-42-983.png > Release Testing: Verify FLINK-29717 Supports hive ud

[GitHub] [flink] snuyanzin commented on pull request #21958: [FLINK-31118][table] Add ARRAY_UNION function.

2023-02-21 Thread via GitHub
snuyanzin commented on PR #21958: URL: https://github.com/apache/flink/pull/21958#issuecomment-1438042696 > so i ask you do you have a good implements unfortunately right now i do not have where i can just pick it up. You probably could do some research in this direction -- This is

[jira] [Updated] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miamiaoxyz updated FLINK-31059: --- Attachment: image-2023-02-21-16-31-58-361.png > Release Testing: Verify FLINK-29717 Supports hive ud

[jira] [Closed] (FLINK-31164) Unexpected correlate variable $cor0 in the plan error in where clause

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31164. -- Resolution: Duplicate > Unexpected correlate variable $cor0 in the plan error in where clause

[jira] [Updated] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miamiaoxyz updated FLINK-31059: --- Attachment: image-2023-02-21-16-35-46-294.png > Release Testing: Verify FLINK-29717 Supports hive ud

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31142: Description: Although the behavior has been changed in 1.17.0, I'm not sure whether it is

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31142: Description: Although the behavior has been changed in 1.17.0, I'm not sure whether it is

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31142: Labels: (was: release-testing) > Some queries lead to abrupt sql client close >

[GitHub] [flink] rkhachatryan opened a new pull request, #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
rkhachatryan opened a new pull request, #21981: URL: https://github.com/apache/flink/pull/21981 ## What is the purpose of the change Adjust slot assignment by Adaptive Scheduler to try to re-use previous allocations so that TMs can use Local Recovery. Contributed mostly by

[jira] [Updated] (FLINK-21450) Add local recovery support to adaptive scheduler

2023-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21450: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-avail

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new major release, you need to update Flink version in the fo

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112733682 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apach

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112739085 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apach

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112739085 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apach

[GitHub] [flink] reswqa commented on pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on PR #21977: URL: https://github.com/apache/flink/pull/21977#issuecomment-1438069932 Thanks @luoyuxia and @JunRuiLee for the review, I have updated this pr in two fixup commits, PTAL agian~ -- This is an automated message from the Apache Git Service. To respond to the me

[jira] [Commented] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691462#comment-17691462 ] Matthias Pohl commented on FLINK-31153: --- {quote} BTW, you mentioned in the descrip

[GitHub] [flink] flinkbot commented on pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
flinkbot commented on PR #21981: URL: https://github.com/apache/flink/pull/21981#issuecomment-1438071101 ## CI report: * 90f669d3099333992edcd961682b0cde4fa06dc8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1112741455 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java: ## @@ -121,16 +133,13 @@ public Optional deter

[GitHub] [flink] pnowojski commented on a diff in pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

2023-02-21 Thread via GitHub
pnowojski commented on code in PR #21923: URL: https://github.com/apache/flink/pull/21923#discussion_r1112741636 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -949,7 +952,9 @@ public final void cleanUp(Throwable throwable)

[jira] [Comment Edited] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691462#comment-17691462 ] Matthias Pohl edited comment on FLINK-31153 at 2/21/23 8:48 AM: --

[GitHub] [flink] MartijnVisser merged pull request #21964: [FLINK-30948][Formats/AWS] Remove GlueSchemaRegistry Avro and JSON fo…

2023-02-21 Thread via GitHub
MartijnVisser merged PR #21964: URL: https://github.com/apache/flink/pull/21964 -- 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

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

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30948: --- Fix Version/s: 1.17.0 > Remove flink-avro-glue-schema-registry and flink-json-glue-schema-re

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Commented] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread miamiaoxyz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691464#comment-17691464 ] miamiaoxyz commented on FLINK-31059: I first use sql client to test the feature, but

[GitHub] [flink] FangYongs commented on a diff in pull request #21901: [FLINK-30968][sql-client] Sql client supports dynamic config to open session

2023-02-21 Thread via GitHub
FangYongs commented on code in PR #21901: URL: https://github.com/apache/flink/pull/21901#discussion_r1112748189 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DefaultContextUtils.java: ## @@ -51,12 +52,17 @@ public static DefaultContext bui

[GitHub] [flink] MartijnVisser merged pull request #21969: [FLINK-30948][Formats/AWS] Remove GlueSchemaRegistry Avro and JSON fo…

2023-02-21 Thread via GitHub
MartijnVisser merged PR #21969: URL: https://github.com/apache/flink/pull/21969 -- 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

[jira] [Assigned] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-31150: - Assignee: Qingsheng Ren > Cross team testing > -- > > K

[jira] [Created] (FLINK-31165) Over Agg: The window rank function without order by error in top N query

2023-02-21 Thread P Rohan Kumar (Jira)
P Rohan Kumar created FLINK-31165: - Summary: Over Agg: The window rank function without order by error in top N query Key: FLINK-31165 URL: https://issues.apache.org/jira/browse/FLINK-31165 Project: F

[jira] [Assigned] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-31153: - Assignee: Leonard Xu > Create a release branch > --- > >

[jira] [Commented] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691465#comment-17691465 ] Matthias Pohl commented on FLINK-31150: --- [~renqs] created FLINK-30926 as an umbrel

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

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691466#comment-17691466 ] Martijn Visser commented on FLINK-30948: Fixed in: master: 29f009b7e8c714cd5af0

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

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30948. -- Resolution: Fixed > Remove flink-avro-glue-schema-registry and flink-json-glue-schema-registry

[GitHub] [flink] dmvk commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
dmvk commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1112754334 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java: ## @@ -794,7 +802,23 @@ public void goToWaitingForResources() {

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
Fanoid commented on code in PR #213: URL: https://github.com/apache/flink-ml/pull/213#discussion_r1112756657 ## flink-ml-servable-core/pom.xml: ## @@ -0,0 +1,127 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:sc

[jira] [Assigned] (FLINK-31092) Hive ITCases fail with OutOfMemoryError

2023-02-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-31092: -- Assignee: luoyuxia > Hive ITCases fail with OutOfMemoryError > --

[jira] [Closed] (FLINK-30951) Release Testing: Verify FLINK-29635 Hive sink should support merge files in batch mode

2023-02-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30951. - Resolution: Fixed > Release Testing: Verify FLINK-29635 Hive sink should support merge files in

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
zhipeng93 commented on code in PR #213: URL: https://github.com/apache/flink-ml/pull/213#discussion_r1112772912 ## flink-ml-servable-core/pom.xml: ## @@ -0,0 +1,127 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi

[jira] [Commented] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691472#comment-17691472 ] dalongliu commented on FLINK-31059: --- [~miamiaoxyz] Thanks for your verify, for the pro

[GitHub] [flink-ml] zhipeng93 commented on pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
zhipeng93 commented on PR #213: URL: https://github.com/apache/flink-ml/pull/213#issuecomment-1438119732 Thanks for the PR. 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 comm

[GitHub] [flink-ml] zhipeng93 merged pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
zhipeng93 merged PR #213: URL: https://github.com/apache/flink-ml/pull/213 -- 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

[jira] [Closed] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

2023-02-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-31059. - Resolution: Fixed > Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by > nativ

[GitHub] [flink-ml] lindong28 commented on pull request #213: [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-21 Thread via GitHub
lindong28 commented on PR #213: URL: https://github.com/apache/flink-ml/pull/213#issuecomment-1438122258 Thank you both for the review! -- 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 specifi

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Updated] (FLINK-31147) Create a new version in JIRA

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31147: -- Description: When contributors resolve an issue in JIRA, they are tagging it with a release t

[jira] [Updated] (FLINK-31149) Review and update documentation

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31149: -- Description: There are a few pages in the documentation that need to be reviewed and updated

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112641083 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkITCase.java: ## @@ -42,17 +44,18 @@ import static org.assert

[GitHub] [flink] FangYongs commented on pull request #21956: [FLINK-31113] Support AND filter push down in orc

2023-02-21 Thread via GitHub
FangYongs commented on PR #21956: URL: https://github.com/apache/flink/pull/21956#issuecomment-1438133167 Thanks @libenchao , I have updated -- 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 sp

[GitHub] [flink-ml] lindong28 commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-21 Thread via GitHub
lindong28 commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1438134181 @jiangxin369 Can you help review this PR? -- 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-31152) Setup for the executing release manager

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31152: -- Description: h4. GPG Key You need to have a GPG key to sign the release artifacts. Please be

[jira] [Updated] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-02-21 Thread Julien Tournay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Tournay updated FLINK-31144: --- Attachment: image-2023-02-21-10-29-49-388.png > Slow scheduling on large-scale batch jobs >

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #212: [FLINK-31125] Flink ML benchmark framework should minimize the source operator overhead

2023-02-21 Thread via GitHub
zhipeng93 commented on code in PR #212: URL: https://github.com/apache/flink-ml/pull/212#discussion_r1112795550 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java: ## @@ -42,7 +42,7 @@ protected RowGenerator[] ge

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #212: [FLINK-31125] Flink ML benchmark framework should minimize the source operator overhead

2023-02-21 Thread via GitHub
zhipeng93 commented on code in PR #212: URL: https://github.com/apache/flink-ml/pull/212#discussion_r1112795550 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java: ## @@ -42,7 +42,7 @@ protected RowGenerator[] ge

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-02-21 Thread Julien Tournay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691474#comment-17691474 ] Julien Tournay commented on FLINK-31144: Hi [~huwh], Thank you for the quick r

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[GitHub] [flink-ml] zhipeng93 closed pull request #176: Bump jackson-databind from 2.12.6.1 to 2.12.7.1

2023-02-21 Thread via GitHub
zhipeng93 closed pull request #176: Bump jackson-databind from 2.12.6.1 to 2.12.7.1 URL: https://github.com/apache/flink-ml/pull/176 -- 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 comm

[GitHub] [flink-ml] dependabot[bot] commented on pull request #176: Bump jackson-databind from 2.12.6.1 to 2.12.7.1

2023-02-21 Thread via GitHub
dependabot[bot] commented on PR #176: URL: https://github.com/apache/flink-ml/pull/176#issuecomment-1438157269 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major or minor version, let

[GitHub] [flink] dmvk commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
dmvk commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1112810683 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] dmvk commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-21 Thread via GitHub
dmvk commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1112815613 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java: ## @@ -121,16 +133,13 @@ public Optional determinePara

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31142: Priority: Blocker (was: Major) > Some queries lead to abrupt sql client close > -

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31142: Description: Although the behavior has been changed in 1.17.0, I'm not sure whether it is

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Commented] (FLINK-31153) Create a release branch

2023-02-21 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691491#comment-17691491 ] Jing Ge commented on FLINK-31153: - Make sense. Thanks [~mapohl] for the clarification. L

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Description: If you are doing a new minor release, you need to update Flink version in the fo

[jira] [Closed] (FLINK-31036) StateCheckpointedITCase timed out

2023-02-21 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31036. --- Resolution: Fixed > StateCheckpointedITCase timed out > - > >

[GitHub] [flink] luoyuxia commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
luoyuxia commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112798182 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -18,178 +18,174 @@ package org.apache.f

[GitHub] [flink] luoyuxia commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
luoyuxia commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112838547 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -18,178 +18,174 @@ package org.apache.f

[jira] [Commented] (FLINK-31165) Over Agg: The window rank function without order by error in top N query

2023-02-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691493#comment-17691493 ] Martijn Visser commented on FLINK-31165: [~godfrey] [~lincoln.86xy] Any thoughts

[GitHub] [flink] snuyanzin commented on a diff in pull request #21945: [FLINK-31091][Table SQL/Client] Add Ser/de for Interval types

2023-02-21 Thread via GitHub
snuyanzin commented on code in PR #21945: URL: https://github.com/apache/flink/pull/21945#discussion_r1112846597 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/LogicalTypeJsonSerializer.java: ## @@ -87,6 +89,10 @@ public final class Logi

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112847462 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,191 @@ +/* + * Licensed to the Apach

[GitHub] [flink] MartijnVisser commented on pull request #21965: [FLINK-31121] Support discarding too large records in kafka sink

2023-02-21 Thread via GitHub
MartijnVisser commented on PR #21965: URL: https://github.com/apache/flink/pull/21965#issuecomment-1438209724 Can we hold off merging this PR since we're in the process of externalizing the Kafka connector, which means that this PR should then be moved to the external Kafka connector reposi

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Fix Version/s: 1.17.0 > Create a release branch > --- > >

[jira] [Updated] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31153: -- Affects Version/s: 1.17.0 > Create a release branch > --- > >

[jira] [Resolved] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31153. --- Resolution: Fixed * (/) Release branch has been created and pushed * (/) Changes on the new

[jira] [Comment Edited] (FLINK-31153) Create a release branch

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691495#comment-17691495 ] Matthias Pohl edited comment on FLINK-31153 at 2/21/23 10:14 AM: -

[GitHub] [flink] reswqa commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

2023-02-21 Thread via GitHub
reswqa commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1112847462 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,191 @@ +/* + * Licensed to the Apach

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Commented] (FLINK-30337) Stateful Functions application throws an exception when stopping a job gracefully creating a final savepoint

2023-02-21 Thread Alexey Novakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691499#comment-17691499 ] Alexey Novakov commented on FLINK-30337: I have been able to reproduce this issu

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Comment Edited] (FLINK-30337) Stateful Functions application throws an exception when stopping a job gracefully creating a final savepoint

2023-02-21 Thread Alexey Novakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691499#comment-17691499 ] Alexey Novakov edited comment on FLINK-30337 at 2/21/23 10:16 AM:

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Updated] (FLINK-31150) Cross team testing

2023-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31150: -- Description: For user facing features that go into the release we'd like to ensure they can a

[jira] [Comment Edited] (FLINK-30337) Stateful Functions application throws an exception when stopping a job gracefully creating a final savepoint

2023-02-21 Thread Alexey Novakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691499#comment-17691499 ] Alexey Novakov edited comment on FLINK-30337 at 2/21/23 10:17 AM:

  1   2   3   4   >