[GitHub] [flink] dannycranmer commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
dannycranmer commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1195076222 @DavidLiu001 I can see the [CI build has already failed](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=38732&view=results). Before pushing your branch

[GitHub] [flink] dannycranmer commented on pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
dannycranmer commented on PR #20338: URL: https://github.com/apache/flink/pull/20338#issuecomment-1195074655 @DavidLiu001 in future instead of opening a new PR, you can simply push a new commit to you branch and the PR will automatically update? You can even squash and force push to rewrite

[jira] [Closed] (FLINK-28610) Enable speculative execution of sources

2022-07-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28610. --- Resolution: Done Done via 9192446847b6fb29beb8d36d49d6900de1e61685 > Enable speculative execution of source

[GitHub] [flink] zhuzhurk closed pull request #20345: [FLINK-28610][runtime] Enable speculative execution for sources

2022-07-25 Thread GitBox
zhuzhurk closed pull request #20345: [FLINK-28610][runtime] Enable speculative execution for sources URL: https://github.com/apache/flink/pull/20345 -- 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 t

[GitHub] [flink] zoltar9264 commented on pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

2022-07-25 Thread GitBox
zoltar9264 commented on PR #20103: URL: https://github.com/apache/flink/pull/20103#issuecomment-1195070679 Sorry @rkhachatryan , you are right. I test it on yarn cluster before and it works. I test it locally just now, it really does't work. I will check it. -- This is an automated messag

[GitHub] [flink] wangyang0918 commented on pull request #19772: [FLINK-27579][client] The param client.timeout can not be set by dyna…

2022-07-25 Thread GitBox
wangyang0918 commented on PR #19772: URL: https://github.com/apache/flink/pull/19772#issuecomment-1195070066 @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 sp

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #138: [FLINK-28684] Fix OneHotEncoder NPE during checkpoint

2022-07-25 Thread GitBox
yunfengzhou-hub opened a new pull request, #138: URL: https://github.com/apache/flink-ml/pull/138 This PR fixes the NullPointerException that might be generated during OneHotEncoder's checkpoint process. -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-28684: -- Issue Type: Bug (was: New Feature) > NullPointerException at OneHotEncoder.GenerateModelDataO

[jira] [Commented] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

2022-07-25 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571225#comment-17571225 ] Qingsheng Ren commented on FLINK-27691: --- An instance on my own Azure pipeline: htt

[jira] [Commented] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571223#comment-17571223 ] Yunfeng Zhou commented on FLINK-28684: -- It is not found that this problem exists in

[jira] [Updated] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28684: --- Labels: pull-request-available (was: ) > NullPointerException at OneHotEncoder.GenerateMode

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #137: [FLINK-28684] Fix OneHotEncoder NPE during checkpoint

2022-07-25 Thread GitBox
yunfengzhou-hub opened a new pull request, #137: URL: https://github.com/apache/flink-ml/pull/137 This PR fixes the NullPointerException that might be generated during OneHotEncoder's checkpoint process. -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Commented] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571221#comment-17571221 ] Yunfeng Zhou commented on FLINK-28684: -- This problem occurs when a checkpoint barri

[GitHub] [flink] fsk119 commented on a diff in pull request #20298: [FLINK-28152][sql-gateway][hive] Allow executing statement for the HiveServer2Endpoint

2022-07-25 Thread GitBox
fsk119 commented on code in PR #20298: URL: https://github.com/apache/flink/pull/20298#discussion_r929567090 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/util/ThriftObjectConversions.java: ## @@ -51,25 +261,250 @@ public static TSta

[jira] [Updated] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28685: - Priority: Minor (was: Major) > Optimize CatalogManager getTable implementation > --

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #237: [FLINK-28677] Primary key should not be null when creating Spark table

2022-07-25 Thread GitBox
JingsongLi commented on code in PR #237: URL: https://github.com/apache/flink-table-store/pull/237#discussion_r929555403 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/UpdateSchema.java: ## @@ -80,6 +83,33 @@ public String comment() { r

[GitHub] [flink] zhuzhurk commented on pull request #20345: [FLINK-28610][runtime] Enable speculative execution for sources

2022-07-25 Thread GitBox
zhuzhurk commented on PR #20345: URL: https://github.com/apache/flink/pull/20345#issuecomment-1195038830 @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] zhuzhurk commented on pull request #20345: [FLINK-28610][runtime] Enable speculative execution for sources

2022-07-25 Thread GitBox
zhuzhurk commented on PR #20345: URL: https://github.com/apache/flink/pull/20345#issuecomment-1195034267 @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] [Closed] (FLINK-28660) Simplify logs of blocklist

2022-07-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28660. --- Resolution: Fixed Fixed via 64ad6709f412e80c5e48d24127e7a558bed99e8a > Simplify logs of blocklist > ---

[GitHub] [flink] zhuzhurk closed pull request #20349: [FLINK-28660][runtime] Simplify logs of blocklist

2022-07-25 Thread GitBox
zhuzhurk closed pull request #20349: [FLINK-28660][runtime] Simplify logs of blocklist URL: https://github.com/apache/flink/pull/20349 -- 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 co

[jira] [Commented] (FLINK-23020) NullPointerException when running collect twice from Python API

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571200#comment-17571200 ] Zhipeng Zhang commented on FLINK-23020: --- Another similar one: https://github.com/

[GitHub] [flink] pltbkd commented on a diff in pull request #20296: [FLINK-28588] Enhance REST API for Speculative Execution

2022-07-25 Thread GitBox
pltbkd commented on code in PR #20296: URL: https://github.com/apache/flink/pull/20296#discussion_r929534318 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java: ## @@ -113,7 +123,8 @@ public TaskManagerInfo( @JsonP

[jira] [Comment Edited] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-07-25 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571196#comment-17571196 ] DavidLiu edited comment on FLINK-27536 at 7/26/22 5:13 AM: --- [~

[jira] [Comment Edited] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-07-25 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571196#comment-17571196 ] DavidLiu edited comment on FLINK-27536 at 7/26/22 5:13 AM: --- [~

[GitHub] [flink] flinkbot commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
flinkbot commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1195012201 ## CI report: * 9bcd71acf5c72dc681a8d707f50632f6628a6a0f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-07-25 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571196#comment-17571196 ] DavidLiu edited comment on FLINK-27536 at 7/26/22 5:10 AM: --- [~

[jira] [Commented] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-07-25 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571196#comment-17571196 ] DavidLiu commented on FLINK-27536: -- [~dannycranmer] I will open a new Pull Request > R

[jira] [Comment Edited] (FLINK-27536) Rename method parameter in AsyncSinkWriter

2022-07-25 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569805#comment-17569805 ] DavidLiu edited comment on FLINK-27536 at 7/26/22 5:09 AM: --- Th

[GitHub] [flink] DavidLiu001 opened a new pull request, #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
DavidLiu001 opened a new pull request, #20360: URL: https://github.com/apache/flink/pull/20360 …nkWriter ## What is the purpose of the change Change the abstract method's parameter naming in AsyncSinkWriter and AsyncSinkWriterTest From Consumer requestResult to Co

[GitHub] [flink] DavidLiu001 commented on pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
DavidLiu001 commented on PR #20338: URL: https://github.com/apache/flink/pull/20338#issuecomment-1195003585 Close this pull request and I Will open a new Pull Request -- 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] DavidLiu001 closed pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

2022-07-25 Thread GitBox
DavidLiu001 closed pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi… URL: https://github.com/apache/flink/pull/20338 -- 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

[GitHub] [flink] PatrickRen commented on pull request #20177: [FLINK-28416][table] Add (Async)LookupFunction and providers in replace of (Async)TableFunction as the API for lookup table

2022-07-25 Thread GitBox
PatrickRen commented on PR #20177: URL: https://github.com/apache/flink/pull/20177#issuecomment-1194989800 @lincoln-lil Thanks for the review! I've addressed your comments in the latest commit. Please take a look when you are available. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571188#comment-17571188 ] Paul Lin commented on FLINK-28685: -- Please assign this issue to me. I have fixed it in

[jira] [Updated] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28685: - Description: Currently, Catalog#getTable(ObjectPath) might be abused in CatalogManager. CatalogManager

[jira] [Created] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
Paul Lin created FLINK-28685: Summary: Optimize CatalogManager getTable implementation Key: FLINK-28685 URL: https://issues.apache.org/jira/browse/FLINK-28685 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-28677) Primary key should not be null when creating Spark table

2022-07-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28677: - Priority: Blocker (was: Minor) > Primary key should not be null when creating Spark table > ---

[jira] [Assigned] (FLINK-28677) Primary key should not be null when creating Spark table

2022-07-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28677: Assignee: Jane Chan > Primary key should not be null when creating Spark table >

[jira] [Updated] (FLINK-28683) Modify changelog-file to changelog-producer

2022-07-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28683: - Priority: Blocker (was: Major) > Modify changelog-file to changelog-producer >

[jira] [Created] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28684: - Summary: NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot Key: FLINK-28684 URL: https://issues.apache.org/jira/browse/FLINK-28684 Project: F

[jira] [Updated] (FLINK-28683) Modify changelog-file to changelog-producer

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28683: --- Labels: pull-request-available (was: ) > Modify changelog-file to changelog-producer >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #238: [FLINK-28683] Modify changelog-file to changelog-producer

2022-07-25 Thread GitBox
JingsongLi opened a new pull request, #238: URL: https://github.com/apache/flink-table-store/pull/238 The changelog-file is limited, not just from input, we can have more changelog producer types. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Created] (FLINK-28683) Modify changelog-file to changelog-producer

2022-07-25 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28683: Summary: Modify changelog-file to changelog-producer Key: FLINK-28683 URL: https://issues.apache.org/jira/browse/FLINK-28683 Project: Flink Issue Type: Impro

[GitHub] [flink] xintongsong commented on a diff in pull request #20236: [FLINK-27769][sql-gateway]Introduce the REST endpoint framework

2022-07-25 Thread GitBox
xintongsong commented on code in PR #20236: URL: https://github.com/apache/flink/pull/20236#discussion_r929490014 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestAPIVersion.java: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Ap

[GitHub] [flink] flinkbot commented on pull request #20359: [FLINK-28682][table-planner] support join hint in batch rules

2022-07-25 Thread GitBox
flinkbot commented on PR #20359: URL: https://github.com/apache/flink/pull/20359#issuecomment-1194974784 ## CI report: * 6d854244340b64ad1243aabb8d0bea54e596af8e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28682) support join hint in flink batch

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28682: --- Labels: pull-request-available (was: ) > support join hint in flink batch > ---

[GitHub] [flink] xuyangzhong opened a new pull request, #20359: [FLINK-28682][table-planner] support join hint in batch rules

2022-07-25 Thread GitBox
xuyangzhong opened a new pull request, #20359: URL: https://github.com/apache/flink/pull/20359 ## What is the purpose of the change Introduce join hint in Flink batch. ## Brief change log - [FLINK-28678][table-planner] Support SQL hint for Filter, SetOp, Sort, Wind

[jira] [Created] (FLINK-28682) support join hint in flink batch

2022-07-25 Thread xuyang (Jira)
xuyang created FLINK-28682: -- Summary: support join hint in flink batch Key: FLINK-28682 URL: https://issues.apache.org/jira/browse/FLINK-28682 Project: Flink Issue Type: Sub-task Component

[jira] [Updated] (FLINK-28678) Support SQL hint for Filter, SetOp, Sort, Window, Values

2022-07-25 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-28678: --- Parent: FLINK-27853 Issue Type: Sub-task (was: New Feature) > Support SQL hint for Filter, SetOp, S

[jira] [Assigned] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

2022-07-25 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-25545: - Assignee: RocMarshal > [JUnit5 Migration] Module: flink-clients > -

[jira] [Created] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular

2022-07-25 Thread nyingping (Jira)
nyingping created FLINK-28681: - Summary: The number of windows allocated by sliding windows is inaccurate, when the window length is irregular Key: FLINK-28681 URL: https://issues.apache.org/jira/browse/FLINK-28681

[GitHub] [flink] flinkbot commented on pull request #20358: [FLINK-28679][hive] Use fixed version for hive-service-rpc

2022-07-25 Thread GitBox
flinkbot commented on PR #20358: URL: https://github.com/apache/flink/pull/20358#issuecomment-1194947295 ## CI report: * b9aa1d05ad91f397d02c5952a159d5d967111c66 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28679) HiveServer2Endpoint compile failed

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28679: --- Labels: pull-request-available (was: ) > HiveServer2Endpoint compile failed > -

[GitHub] [flink] fsk119 opened a new pull request, #20358: [FLINK-28679][hive] Use fixed version for hive-service-rpc

2022-07-25 Thread GitBox
fsk119 opened a new pull request, #20358: URL: https://github.com/apache/flink/pull/20358 ## What is the purpose of the change *Use fixed hive server2 version. Because the different version of hiveserver2 has different interfaces. Currently, the hive connector uses reflection

[GitHub] [flink-ml] zhipeng93 commented on pull request #135: Support ElementwiseProduct in FlinkML

2022-07-25 Thread GitBox
zhipeng93 commented on PR #135: URL: https://github.com/apache/flink-ml/pull/135#issuecomment-1194937026 Thanks for the PR. Could you please add a JIRA ticket for this? Also for the title of the PR, could you follow the existing convention, i.e., [FLINK-XXX] Add Transformer for ... -- T

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #133: [FLINK-28601] Support FeatureHasher in FlinkML

2022-07-25 Thread GitBox
yunfengzhou-hub commented on code in PR #133: URL: https://github.com/apache/flink-ml/pull/133#discussion_r929474516 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/featurehasher/FeatureHasher.java: ## @@ -0,0 +1,186 @@ +/* + * Licensed to the Apache Software Foundatio

[jira] [Closed] (FLINK-28549) Support DataStream PythonProcessOperator in Thread Mode

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-28549. Resolution: Done Merged into master via 7ea31cfcf360bc40b2445c72aae14746577aff9d > Support DataSt

[GitHub] [flink] HuangXingBo closed pull request #20276: [FLINK-28549][python] Support DataStream PythonProcessOperator in Thread Mode

2022-07-25 Thread GitBox
HuangXingBo closed pull request #20276: [FLINK-28549][python] Support DataStream PythonProcessOperator in Thread Mode URL: https://github.com/apache/flink/pull/20276 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-28677) Primary key should not be null when creating Spark table

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28677: --- Labels: pull-request-available (was: ) > Primary key should not be null when creating Spark

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #237: [FLINK-28677] Primary key should not be null when creating Spark table

2022-07-25 Thread GitBox
JingsongLi commented on code in PR #237: URL: https://github.com/apache/flink-table-store/pull/237#discussion_r929472578 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkCatalog.java: ## @@ -291,8 +291,19 @@ private UpdateSchema toUpdateSchema(

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #236: [FLINK-28668] Fail to create Spark table without primary key

2022-07-25 Thread GitBox
JingsongLi commented on code in PR #236: URL: https://github.com/apache/flink-table-store/pull/236#discussion_r929470611 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkCatalog.java: ## @@ -284,14 +284,19 @@ private UpdateSchema toUpdateSchema(

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571174#comment-17571174 ] Huang Xingbo commented on FLINK-28680: -- KinesisStreamsTableApiIT: https://dev.azur

[GitHub] [flink] zhuzhurk commented on pull request #20345: [FLINK-28610][runtime] Enable speculative execution for sources

2022-07-25 Thread GitBox
zhuzhurk commented on PR #20345: URL: https://github.com/apache/flink/pull/20345#issuecomment-1194922018 @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-table-store] JingsongLi commented on a diff in pull request #236: [FLINK-28668] Fail to create Spark table without primary key

2022-07-25 Thread GitBox
JingsongLi commented on code in PR #236: URL: https://github.com/apache/flink-table-store/pull/236#discussion_r929470611 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkCatalog.java: ## @@ -284,14 +284,19 @@ private UpdateSchema toUpdateSchema(

[jira] [Updated] (FLINK-28673) Migrate Flink ML to Flink 1.15.1

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-28673: -- Fix Version/s: ml-2.2.0 > Migrate Flink ML to Flink 1.15.1 >

[jira] [Resolved] (FLINK-28673) Migrate Flink ML to Flink 1.15.1

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-28673. --- Resolution: Fixed fixed via d9bac9a44812d6eca145112f4901ceaf484ba014 > Migrate Flink ML to

[jira] [Assigned] (FLINK-28673) Migrate Flink ML to Flink 1.15.1

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-28673: - Assignee: Yunfeng Zhou > Migrate Flink ML to Flink 1.15.1 > ---

[jira] [Updated] (FLINK-28571) Add AlgoOperator for Chi-squared test

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-28571: -- Fix Version/s: ml-2.2.0 > Add AlgoOperator for Chi-squared test >

[GitHub] [flink] JesseAtSZ commented on pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

2022-07-25 Thread GitBox
JesseAtSZ commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1194920838 @rkhachatryan Sry, I'm a little busy recently, I'll update the PR in this week. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571171#comment-17571171 ] Huang Xingbo commented on FLINK-28680: -- 1.14 SQL Client end-to-end test: https://d

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571170#comment-17571170 ] Huang Xingbo commented on FLINK-28680: -- TPC-DS end-to-end test: https://dev.azure.

[jira] [Updated] (FLINK-28571) Add AlgoOperator for Chi-squared test

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-28571: -- Summary: Add AlgoOperator for Chi-squared test (was: Add Chi-squared test as Transformer to m

[jira] [Assigned] (FLINK-28571) Add AlgoOperator for Chi-squared test

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-28571: - Assignee: Simon Tao > Add AlgoOperator for Chi-squared test > -

[jira] [Created] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

2022-07-25 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28680: Summary: No space left on device on Azure e2e_2_ci tests Key: FLINK-28680 URL: https://issues.apache.org/jira/browse/FLINK-28680 Project: Flink Issue Type: B

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #133: [FLINK-28601] Support FeatureHasher in FlinkML

2022-07-25 Thread GitBox
zhipeng93 commented on code in PR #133: URL: https://github.com/apache/flink-ml/pull/133#discussion_r929467717 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/featurehasher/FeatureHasher.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #133: [FLINK-28601] Support FeatureHasher in FlinkML

2022-07-25 Thread GitBox
zhipeng93 commented on code in PR #133: URL: https://github.com/apache/flink-ml/pull/133#discussion_r929467717 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/featurehasher/FeatureHasher.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #131: [FLINK-28563] Add Transformer for VectorSlicer

2022-07-25 Thread GitBox
yunfengzhou-hub commented on code in PR #131: URL: https://github.com/apache/flink-ml/pull/131#discussion_r929461602 ## flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java: ## @@ -38,6 +38,22 @@ public static ParamValidator gtEq(double lowerBound) {

[GitHub] [flink-ml] zhipeng93 merged pull request #128: [hotfix] Fix configuration requirement in quick start

2022-07-25 Thread GitBox
zhipeng93 merged PR #128: URL: https://github.com/apache/flink-ml/pull/128 -- 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

[GitHub] [flink-ml] zhipeng93 commented on pull request #128: [hotfix] fix configuration requirement in quick start

2022-07-25 Thread GitBox
zhipeng93 commented on PR #128: URL: https://github.com/apache/flink-ml/pull/128#issuecomment-1194897926 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] dependabot[bot] commented on pull request #106: Bump hadoop-common from 2.10.1 to 3.2.3

2022-07-25 Thread GitBox
dependabot[bot] commented on PR #106: URL: https://github.com/apache/flink-ml/pull/106#issuecomment-1194897365 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-ml] zhipeng93 closed pull request #106: Bump hadoop-common from 2.10.1 to 3.2.3

2022-07-25 Thread GitBox
zhipeng93 closed pull request #106: Bump hadoop-common from 2.10.1 to 3.2.3 URL: https://github.com/apache/flink-ml/pull/106 -- 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

[GitHub] [flink-ml] zhipeng93 commented on pull request #106: Bump hadoop-common from 2.10.1 to 3.2.3

2022-07-25 Thread GitBox
zhipeng93 commented on PR #106: URL: https://github.com/apache/flink-ml/pull/106#issuecomment-1194897335 Closed since the checks failed. -- 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 specif

[GitHub] [flink] flinkbot commented on pull request #20357: [hotfix] [docs] Update gradle build script in the overview.md

2022-07-25 Thread GitBox
flinkbot commented on PR #20357: URL: https://github.com/apache/flink/pull/20357#issuecomment-1194893757 ## CI report: * f5326f39cf88e2c7514eb24c759d148cf4af3a9a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] grossws opened a new pull request, #20357: [hotfix] [docs] Update gradle build script in the overview.md

2022-07-25 Thread GitBox
grossws opened a new pull request, #20357: URL: https://github.com/apache/flink/pull/20357 Use `flink-shaded-force-shanding` instead of `force-shading` in the excludes since at least 1.15.x use that naming. ## Brief change log * Just an artifactId update in the `flinkShadowJar`

[jira] [Commented] (FLINK-28679) HiveServer2Endpoint compile failed

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571166#comment-17571166 ] Huang Xingbo commented on FLINK-28679: -- [~fsk119] Could you help take a look? > Hi

[jira] [Created] (FLINK-28679) HiveServer2Endpoint compile failed

2022-07-25 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28679: Summary: HiveServer2Endpoint compile failed Key: FLINK-28679 URL: https://issues.apache.org/jira/browse/FLINK-28679 Project: Flink Issue Type: Bug

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #132: [FLINK-28571]Add Chi-squared test as Transformer to ml.feature

2022-07-25 Thread GitBox
zhipeng93 commented on code in PR #132: URL: https://github.com/apache/flink-ml/pull/132#discussion_r929460234 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/chisqtest/ChiSqTestTransformer.java: ## @@ -0,0 +1,498 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [flink-ml] zhipeng93 merged pull request #136: [FLINK-28673] Migrate Flink ML to Flink 1.15.1

2022-07-25 Thread GitBox
zhipeng93 merged PR #136: URL: https://github.com/apache/flink-ml/pull/136 -- 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] [Resolved] (FLINK-28501) Add Transformer and Estimator for VectorIndexer

2022-07-25 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-28501. --- Resolution: Fixed fixed via e31101fdb614ea6366111f761e3176c5c2ab6ef0 > Add Transformer and

[GitHub] [flink-ml] zhipeng93 merged pull request #134: [FLINK-28501] Add Transformer and Estimator for VectorIndexer

2022-07-25 Thread GitBox
zhipeng93 merged PR #134: URL: https://github.com/apache/flink-ml/pull/134 -- 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-28668) Fail to create Spark table without primary key

2022-07-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28668. Resolution: Fixed master: e48d9b00ecf29d89aee0c1765a69ca55db86f2f4 release-0.2: a8559f9e159ee82198

[jira] [Updated] (FLINK-28668) Fail to create Spark table without primary key

2022-07-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28668: --- Labels: pull-request-available (was: ) > Fail to create Spark table without primary key > -

[jira] [Commented] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

2022-07-25 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571157#comment-17571157 ] Huang Xingbo commented on FLINK-24261: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] jjiey commented on pull request #20316: [FLINK-27292][docs-zh] Translate the "Data Type Extraction" section of "Data Types" to Chinese

2022-07-25 Thread GitBox
jjiey commented on PR #20316: URL: https://github.com/apache/flink/pull/20316#issuecomment-1194883817 Thanks for @ChengkaiYang2022‘s review, I've finished the modification. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #131: [FLINK-28563] Add Transformer for VectorSlicer

2022-07-25 Thread GitBox
zhipeng93 commented on code in PR #131: URL: https://github.com/apache/flink-ml/pull/131#discussion_r929449313 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorslicer/VectorSlicer.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-table-store] JingsongLi merged pull request #236: [FLINK-28668] Fail to create Spark table without primary key

2022-07-25 Thread GitBox
JingsongLi merged PR #236: URL: https://github.com/apache/flink-table-store/pull/236 -- 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...@

[GitHub] [flink] swuferhong commented on pull request #20084: [FLINK-27988][table-planner] Let HiveTableSource extend from SupportStatisticsReport

2022-07-25 Thread GitBox
swuferhong commented on PR #20084: URL: https://github.com/apache/flink/pull/20084#issuecomment-1194882181 @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] wangyang0918 commented on pull request #19772: [FLINK-27579][client] The param client.timeout can not be set by dyna…

2022-07-25 Thread GitBox
wangyang0918 commented on PR #19772: URL: https://github.com/apache/flink/pull/19772#issuecomment-1194881107 @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 comme

[jira] [Created] (FLINK-28678) Support SQL hint for Filter, SetOp, Sort, Window, Values

2022-07-25 Thread xuyang (Jira)
xuyang created FLINK-28678: -- Summary: Support SQL hint for Filter, SetOp, Sort, Window, Values Key: FLINK-28678 URL: https://issues.apache.org/jira/browse/FLINK-28678 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-28353) Exclude unschedulable nodes using IP addresses of kubernetes nodes

2022-07-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571154#comment-17571154 ] Yang Wang commented on FLINK-28353: --- Thanks [~Suxing Lee] for your contribution. > Ex

[jira] [Closed] (FLINK-28353) Exclude unschedulable nodes using IP addresses of kubernetes nodes

2022-07-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-28353. - Fix Version/s: 1.16.0 Assignee: Suxing Lee Resolution: Fixed Fixed via: master: 48acc1c

  1   2   3   >