[jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side

2023-02-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-31193: -- Description: Sink Flink 1.17, we have implemented the native hive aggregation function, users can

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27115: --- Labels: pull-request-available (was: ) > Error while executing BLOB connection.

[GitHub] [flink] huwh opened a new pull request, #22004: [FLINK-27115][blob] Enrich the error log with remote address for blobServer

2023-02-22 Thread via GitHub
huwh opened a new pull request, #22004: URL: https://github.com/apache/flink/pull/22004 ## What is the purpose of the change The error log of executing BLOB connection failed does not shows client address. If there are some malicious attacks, it's hard to find the sources. We should

[jira] [Updated] (FLINK-31185) Python BroadcastProcessFunction not support side output

2023-02-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31185: --- Labels: pull-request-available (was: ) > Python BroadcastProcessFunction not support side

[GitHub] [flink] Vancior opened a new pull request, #22003: [FLINK-31185][Python] Support side-output in broadcast processing

2023-02-22 Thread via GitHub
Vancior opened a new pull request, #22003: URL: https://github.com/apache/flink/pull/22003 ## What is the purpose of the change This PR supports using side-output functionality in broadcast processing case in pyflink. ## Brief change log - add operator delegation

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

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

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

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

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

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

[jira] [Commented] (FLINK-31089) pin L0 index in memory can lead to slow memory grow finally lead to memory beyond limit

2023-02-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692546#comment-17692546 ] xiaogang zhou commented on FLINK-31089: --- [~yunta] if I turn off the PinTopLevelIndexAndFilter, the

[jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side

2023-02-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-31193: -- Description: Sink Flink 1.17, we have implemented the native hive aggregation function, users can

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692543#comment-17692543 ] xzw0223 commented on FLINK-31192: - [~Weijie Guo] thank you > dataGen takes too long to initialize under

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

2023-02-22 Thread via GitHub
lindong28 commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1441314725 @zhipeng93 Thanks for the review. Can you help take another look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692526#comment-17692526 ] Weijie Guo edited comment on FLINK-31192 at 2/23/23 7:31 AM: - [~xzw0223]

[jira] [Assigned] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31192: -- Assignee: xzw0223 > dataGen takes too long to initialize under sequence >

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-02-22 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692535#comment-17692535 ] Matthias Pohl commented on FLINK-18356: --- release-1.17:

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

2023-02-22 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692534#comment-17692534 ] Matthias Pohl commented on FLINK-31120: --- This build failure didn't contain the aforementioned fix,

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115310961 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/types/MatrixType.java: ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software Foundation

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115309864 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/types/MatrixType.java: ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Updated] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31143: -- Issue Type: New Feature (was: Bug) > Invalid request: offset doesn't match when restarting

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

2023-02-22 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692530#comment-17692530 ] Weihua Hu commented on FLINK-31144: --- [~zhuzh] That sounds good to me. > Slow scheduling on

[jira] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

2023-02-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23810 ] hehuiyuan deleted comment on FLINK-23810: --- was (Author: hehuiyuan): [~jark] ,[~twalthr]  , I can try to do it if necessary. > Print sql when parse failed , which is convenient to find error

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115308290 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/api/DataFrame.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

2023-02-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692531#comment-17692531 ] hehuiyuan commented on FLINK-23810: --- Hi [~jark]  [~twalthr] , whether to add the detail sql? > Print

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115308117 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/api/TransformerServable.java: ## @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that SteamTask skip handle exception during restoring.

2023-02-22 Thread via GitHub
RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115303685 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskITCase.java: ## @@ -110,6 +118,47 @@ public void

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115304116 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/api/DataFrame.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

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

2023-02-22 Thread via GitHub
lindong28 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115303911 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/api/DataFrame.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[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-22 Thread via GitHub
zhipeng93 commented on code in PR #212: URL: https://github.com/apache/flink-ml/pull/212#discussion_r1115302692 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java: ## @@ -42,7 +42,7 @@ protected RowGenerator[]

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

2023-02-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692527#comment-17692527 ] Zhu Zhu commented on FLINK-31144: - I suspect the slowness is caused by the N^2 complexity to compute the

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

2023-02-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692527#comment-17692527 ] Zhu Zhu edited comment on FLINK-31144 at 2/23/23 7:06 AM: -- I suspect the

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692526#comment-17692526 ] Weijie Guo commented on FLINK-31192: [~xzw0223] flink community no longer supports versions lower

[jira] [Updated] (FLINK-31194) Introduces savepoint mechanism of Table Store

2023-02-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31194: --- Summary: Introduces savepoint mechanism of Table Store (was: ntroduces savepoint mechanism

[jira] [Updated] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31192: --- Fix Version/s: (was: 1.11.0) (was: 1.12.0) (was:

[GitHub] [flink-table-store] tsreaper merged pull request #551: [FLINK-31179] Make data structures serializable

2023-02-22 Thread via GitHub
tsreaper merged PR #551: URL: https://github.com/apache/flink-table-store/pull/551 -- 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:

[jira] [Updated] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31192: --- Affects Version/s: 1.15.3 1.17.0 (was: 1.16.0) >

[jira] [Created] (FLINK-31194) ntroduces savepoint mechanism of Table Store

2023-02-22 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-31194: -- Summary: ntroduces savepoint mechanism of Table Store Key: FLINK-31194 URL: https://issues.apache.org/jira/browse/FLINK-31194 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #22002: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.

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

[GitHub] [flink] reswqa opened a new pull request, #22002: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.

2023-02-22 Thread via GitHub
reswqa opened a new pull request, #22002: URL: https://github.com/apache/flink/pull/22002 ## What is the purpose of the change *For some config options like `taskmanager.runtime.sort-spilling-threshold` ,`taskmanager.runtime.max-fan` ... etc. used for sorting and spilling, we get

[jira] [Created] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side

2023-02-22 Thread dalongliu (Jira)
dalongliu created FLINK-31193: - Summary: The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side Key: FLINK-31193 URL:

[GitHub] [flink] Aitozi commented on pull request #20775: [FLINK-29088][table] Extract the common project to enhance source reuse

2023-02-22 Thread via GitHub
Aitozi commented on PR #20775: URL: https://github.com/apache/flink/pull/20775#issuecomment-1441277370 @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.

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

2023-02-22 Thread via GitHub
zhipeng93 commented on code in PR #214: URL: https://github.com/apache/flink-ml/pull/214#discussion_r1115277590 ## flink-ml-servable-core/src/main/java/org/apache/flink/ml/servable/api/DataFrame.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692518#comment-17692518 ] xzw0223 commented on FLINK-31192: - Add one thing : It is added that during snapshot restoration and

[jira] [Assigned] (FLINK-28086) Table Store Catalog supports partition methods

2023-02-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28086: Assignee: (was: Nicholas Jiang) > Table Store Catalog supports partition methods >

[GitHub] [flink] reswqa closed pull request #21797: [FLINK-29845] Using System.nanoTime instead of currentTimeMillis in T…

2023-02-22 Thread via GitHub
reswqa closed pull request #21797: [FLINK-29845] Using System.nanoTime instead of currentTimeMillis in T… URL: https://github.com/apache/flink/pull/21797 -- 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

[GitHub] [flink] reswqa closed pull request #21953: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.

2023-02-22 Thread via GitHub
reswqa closed pull request #21953: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid. URL: https://github.com/apache/flink/pull/21953 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] reswqa closed pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2023-02-22 Thread via GitHub
reswqa closed pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor URL: https://github.com/apache/flink/pull/20229 -- 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

[GitHub] [flink] reswqa closed pull request #20024: [FLINK-28125] Promote leadership changing logs to INFO level

2023-02-22 Thread via GitHub
reswqa closed pull request #20024: [FLINK-28125] Promote leadership changing logs to INFO level URL: https://github.com/apache/flink/pull/20024 -- 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

[GitHub] [flink] JunRuiLee commented on pull request #21943: [FLINK-31077][runtime] Mark pending checkpoint onCompletionPromise complete only after the completed checkpoint is added to the store.

2023-02-22 Thread via GitHub
JunRuiLee commented on PR #21943: URL: https://github.com/apache/flink/pull/21943#issuecomment-1441270605 @gaoyunhaii Thanks for CR and I've addressed comment, PTAL! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xzw0223 updated FLINK-31192: Fix Version/s: 1.15.0 1.14.0 1.13.0 1.12.0

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692514#comment-17692514 ] xzw0223 commented on FLINK-31192: - [~Weijie Guo] All versions, it seems, have been around since birth.

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692515#comment-17692515 ] xzw0223 commented on FLINK-31192: - I'd like to solve this problem. May I have a ticket [~Weijie Guo]  >

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692510#comment-17692510 ] Weijie Guo commented on FLINK-31192: [~xzw0223] Thanks for reporting this, does this problem only

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21943: [FLINK-31077][runtime] Mark pending checkpoint onCompletionPromise complete only after the completed checkpoint is added to the

2023-02-22 Thread via GitHub
gaoyunhaii commented on code in PR #21943: URL: https://github.com/apache/flink/pull/21943#discussion_r1115275981 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java: ## @@ -1314,13 +1314,12 @@ private void

[jira] [Commented] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692508#comment-17692508 ] xzw0223 commented on FLINK-31192: - [~mapohl] I created a new issue to discuss the problem of slow

[jira] [Assigned] (FLINK-31190) Supports Spark call procedure command on Table Store

2023-02-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31190: Assignee: Nicholas Jiang > Supports Spark call procedure command on Table Store >

[jira] [Commented] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692507#comment-17692507 ] Xintong Song commented on FLINK-27115: -- Log the client address only in error cases sounds good to

[jira] [Updated] (FLINK-31191) VectorIndexer should check whether doublesByColumn is null before snapshot

2023-02-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31191: --- Labels: pull-request-available (was: ) > VectorIndexer should check whether

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #217: [FLINK-31191] Fix null pointer exception in VectorIndexer

2023-02-22 Thread via GitHub
zhipeng93 opened a new pull request, #217: URL: https://github.com/apache/flink-ml/pull/217 ## What is the purpose of the change - Fix NPE in VectorIndexer. ## Brief change log - Add check for `doublesByColumn` when doing snapshot. ## Does this pull request

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27115: - Affects Version/s: (was: 1.12.7) > Error while executing BLOB connection.

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27115: - Issue Type: Improvement (was: Bug) > Error while executing BLOB connection.

[jira] [Created] (FLINK-31192) dataGen takes too long to initialize under sequence

2023-02-22 Thread xzw0223 (Jira)
xzw0223 created FLINK-31192: --- Summary: dataGen takes too long to initialize under sequence Key: FLINK-31192 URL: https://issues.apache.org/jira/browse/FLINK-31192 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-31182) CompiledPlan cannot deserialize BridgingSqlFunction with MissingTypeStrategy

2023-02-22 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692450#comment-17692450 ] Jane Chan edited comment on FLINK-31182 at 2/23/23 6:08 AM: [~Sergey

[jira] [Created] (FLINK-31191) VectorIndexer should check whether doublesByColumn is null before snapshot

2023-02-22 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31191: - Summary: VectorIndexer should check whether doublesByColumn is null before snapshot Key: FLINK-31191 URL: https://issues.apache.org/jira/browse/FLINK-31191

[jira] [Closed] (FLINK-31124) Add it case for HiveTableSink speculative execution

2023-02-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-31124. --- Fix Version/s: 1.17.0 Resolution: Done master: db6e01e028ec69d7702d3371d6b3db253aafbbf8

[GitHub] [flink] zhuzhurk closed pull request #21962: [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution

2023-02-22 Thread via GitHub
zhuzhurk closed pull request #21962: [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution URL: https://github.com/apache/flink/pull/21962 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] FangYongs commented on pull request #21979: [FLINK-30810] Rework CliClientITCase extends AbstractStatementTestBase

2023-02-22 Thread via GitHub
FangYongs commented on PR #21979: URL: https://github.com/apache/flink/pull/21979#issuecomment-1441244618 Hi @fsk119 Please help to review this PR when you're free, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that SteamTask skip handle exception during restoring.

2023-02-22 Thread via GitHub
RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115242031 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskITCase.java: ## @@ -110,6 +118,42 @@ public void

[GitHub] [flink-table-store] zhuangchong opened a new pull request, #553: Unify the version of `kafka` in pom.

2023-02-22 Thread via GitHub
zhuangchong opened a new pull request, #553: URL: https://github.com/apache/flink-table-store/pull/553 Unify the version of `kafka` in pom. -- 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

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that SteamTask skip handle exception during restoring.

2023-02-22 Thread via GitHub
RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115242031 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskITCase.java: ## @@ -110,6 +118,42 @@ public void

[jira] [Commented] (FLINK-31190) Supports Spark call procedure command on Table Store

2023-02-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692494#comment-17692494 ] Nicholas Jiang commented on FLINK-31190: [~lzljs3620320], could you assign this ticket to me? I

[jira] [Created] (FLINK-31190) Supports Spark call procedure command on Table Store

2023-02-22 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-31190: -- Summary: Supports Spark call procedure command on Table Store Key: FLINK-31190 URL: https://issues.apache.org/jira/browse/FLINK-31190 Project: Flink

[jira] [Updated] (FLINK-31173) Fix several bugs in flink-ml-iteration module

2023-02-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-31173: -- Description: In flink-ml-iteration, there are several bugs as follows: # TailOperator should

[jira] [Assigned] (FLINK-31173) Fix several bugs in flink-ml-iteration module

2023-02-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-31173: - Assignee: Zhipeng Zhang > Fix several bugs in flink-ml-iteration module >

[jira] [Updated] (FLINK-31173) Fix several bugs in flink-ml-iteration module

2023-02-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-31173: -- Description: In flink-ml-iteration, there are several bugs as follows:   # TailOperator

[jira] [Assigned] (FLINK-31176) correct the description of sql gateway configuration

2023-02-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-31176: - Assignee: wangkang > correct the description of sql gateway configuration >

[jira] [Closed] (FLINK-31176) correct the description of sql gateway configuration

2023-02-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-31176. - Fix Version/s: 1.18.0 Resolution: Fixed Merged into master:

[GitHub] [flink] fsk119 merged pull request #21983: [FLINK-31176][sql-gateway] correct the description of sql gateway configuration

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

[GitHub] [flink] Rruop commented on pull request #21968: [FLINK-31123][connector/files] Add IT cases for FileSink speculative …

2023-02-22 Thread via GitHub
Rruop commented on PR #21968: URL: https://github.com/apache/flink/pull/21968#issuecomment-1441191875 > LGTM. Thanks for addressing the comments! @Rruop Would you squash the commits? Thanks for your patiently reviewing, I will squash all the commits into one. -- This is an

[jira] [Updated] (FLINK-31189) Allow special handle of less frequent values in StringIndexer

2023-02-22 Thread Fan Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fan Hong updated FLINK-31189: - Description: Real-world datasets often contain categorical features with millions of distinct values,

[jira] [Updated] (FLINK-31189) Allow special handle of less frequent values in StringIndexer

2023-02-22 Thread Fan Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fan Hong updated FLINK-31189: - Summary: Allow special handle of less frequent values in StringIndexer (was: Allow ignore less

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

2023-02-22 Thread Fan Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fan Hong updated FLINK-31189: - Description: In real-world datasets, categorical features may have millions of distinct values, while

[GitHub] [flink] Aitozi commented on pull request #20775: [FLINK-29088][table] Extract the common project to enhance source reuse

2023-02-22 Thread via GitHub
Aitozi commented on PR #20775: URL: https://github.com/apache/flink/pull/20775#issuecomment-1441176867 @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-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692473#comment-17692473 ] Weihua Hu commented on FLINK-27115: --- I tried to send a request to the netty server and it will log the

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

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

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-27115: -- Attachment: image-2023-02-23-11-30-39-406.png > Error while executing BLOB connection.

[jira] [Commented] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692471#comment-17692471 ] Weihua Hu commented on FLINK-27115: --- Sorry, the screenshot has been attached. {quote}I cannot see the

[GitHub] [flink] gj199575 commented on pull request #20467: [FLINK-28825][k8s] Add K8S pod scheduler into Kubernetes options

2023-02-22 Thread via GitHub
gj199575 commented on PR #20467: URL: https://github.com/apache/flink/pull/20467#issuecomment-1441172829 I will handle this PR as @bzhaoopenstack successor 。 And there are two PR(https://github.com/apache/flink/pull/20498 https://github.com/apache/flink/pull/20636) is replenish of

[jira] [Closed] (FLINK-31136) SQL Client Gateway mode should not read read execution config

2023-02-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-31136. - Resolution: Fixed > SQL Client Gateway mode should not read read execution config >

[jira] [Comment Edited] (FLINK-31136) SQL Client Gateway mode should not read read execution config

2023-02-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691889#comment-17691889 ] Shengkai Fang edited comment on FLINK-31136 at 2/23/23 3:24 AM: Merged

[GitHub] [flink] fsk119 merged pull request #21987: Cherry pick FLINK-31136 to master

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

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:21 AM: -- Hi [~mapohl]

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:17 AM: -- Hi [~mapohl]

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:17 AM: -- Hi [~mapohl]

[jira] [Updated] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu updated FLINK-27115: -- Attachment: image-2023-02-23-11-14-16-479.png > Error while executing BLOB connection.

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:14 AM: -- Hi [~mapohl]

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:13 AM: -- Hi [~mapohl]

[jira] [Commented] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

2023-02-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692463#comment-17692463 ] Caizhi Weng commented on FLINK-31143: - Hi [~mapohl] [~Weijie Guo]. When implementing {{collect}} I

[jira] [Commented] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2

2023-02-22 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692462#comment-17692462 ] Ran Tao commented on FLINK-31161: - hi, guys. i got same issue. in my company, we have a extended project

[jira] [Comment Edited] (FLINK-31182) CompiledPlan cannot deserialize BridgingSqlFunction with MissingTypeStrategy

2023-02-22 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692450#comment-17692450 ] Jane Chan edited comment on FLINK-31182 at 2/23/23 3:02 AM: [~Sergey

[jira] [Commented] (FLINK-27115) Error while executing BLOB connection. java.io.IOException: Unknown operation 80

2023-02-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692460#comment-17692460 ] Xintong Song commented on FLINK-27115: -- I cannot see the screenshot. Is this exception causing

  1   2   3   4   >