[jira] [Updated] (FLINK-28929) Add built-in datediff function.

2022-08-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-28929: - Description: Syntax: {code:java} DATEDIFF(expr1,expr2){code} Returns: returns _{{expr1}}_ − 

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958015488 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java: ## @@ -106,15 +126,24 @@ public RecordReader

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958013297 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java: ## @@ -87,15 +94,28 @@ public

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958013575 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTable.java: ## @@ -164,19 +164,22 @@ public TableRead

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958013297 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java: ## @@ -87,15 +94,28 @@ public

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958013575 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTable.java: ## @@ -164,19 +164,22 @@ public TableRead

[jira] [Commented] (FLINK-28940) Release Testing: Verify FLIP-248 Dynamic Partition Prunning

2022-08-29 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597529#comment-17597529 ] Godfrey He commented on FLINK-28940: [~zhuzh]  Thanks for your effort > Release Testing: Verify

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #280: [FLINK-29129] Try best to push down value filters

2022-08-29 Thread GitBox
JingsongLi commented on code in PR #280: URL: https://github.com/apache/flink-table-store/pull/280#discussion_r958012117 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTable.java: ## @@ -164,19 +164,22 @@ public TableRead

[GitHub] [flink] masteryhx commented on a diff in pull request #20708: [FLINK-29130][state] Correct the description of state.backend.local-recovery

2022-08-29 Thread GitBox
masteryhx commented on code in PR #20708: URL: https://github.com/apache/flink/pull/20708#discussion_r957999092 ## docs/layouts/shortcodes/generated/checkpointing_configuration.html: ## @@ -18,7 +18,7 @@ state.backend.local-recovery false

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #146: [FLINK-29011] Add Transformer for Binarizer

2022-08-29 Thread GitBox
zhipeng93 commented on code in PR #146: URL: https://github.com/apache/flink-ml/pull/146#discussion_r957985954 ## flink-ml-python/pyflink/ml/lib/feature/tests/test_binarizer.py: ## @@ -0,0 +1,105 @@

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #146: [FLINK-29011] Add Transformer for Binarizer

2022-08-29 Thread GitBox
zhipeng93 commented on code in PR #146: URL: https://github.com/apache/flink-ml/pull/146#discussion_r957985591 ## flink-ml-python/pyflink/ml/lib/feature/tests/test_binarizer.py: ## @@ -0,0 +1,105 @@

[jira] [Updated] (FLINK-29132) SubtaskMetricStore causes memory leak.

2022-08-29 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yue Ma updated FLINK-29132: --- Attachment: image-2022-08-30-11-57-59-325.png > SubtaskMetricStore causes memory leak. >

[jira] [Commented] (FLINK-29132) SubtaskMetricStore causes memory leak.

2022-08-29 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597513#comment-17597513 ] Yue Ma commented on FLINK-29132:  i think u may add some log or heap dump analysis to better describe

[jira] [Updated] (FLINK-29132) SubtaskMetricStore causes memory leak.

2022-08-29 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yue Ma updated FLINK-29132: --- Attachment: image-2022-08-30-11-56-34-608.png > SubtaskMetricStore causes memory leak. >

[jira] [Updated] (FLINK-27374) Fix using wrong Flink type for Hive's void type

2022-08-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27374: --- Labels: pull-request-available (was: ) > Fix using wrong Flink type for Hive's void type

[GitHub] [flink] luoyuxia commented on pull request #19253: [FLINK-27374][hive] Fix using wrong Flink type for Hive's void type

2022-08-29 Thread GitBox
luoyuxia commented on PR #19253: URL: https://github.com/apache/flink/pull/19253#issuecomment-1231106098 @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] luoyuxia commented on pull request #19216: [FLINK-27017][hive] Fix divide by zero exception in Hive dialect

2022-08-29 Thread GitBox
luoyuxia commented on PR #19216: URL: https://github.com/apache/flink/pull/19216#issuecomment-1231105310 @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] luoyuxia commented on pull request #18975: [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant pass

2022-08-29 Thread GitBox
luoyuxia commented on PR #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1231103829 @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] WencongLiu commented on a diff in pull request #20622: [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway

2022-08-29 Thread GitBox
WencongLiu commented on code in PR #20622: URL: https://github.com/apache/flink/pull/20622#discussion_r957973694 ## docs/layouts/shortcodes/generated/rest_v1_dispatcher.html: ## @@ -4151,6 +4151,13 @@ } } }, +

[GitHub] [flink] WencongLiu commented on a diff in pull request #20622: [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway

2022-08-29 Thread GitBox
WencongLiu commented on code in PR #20622: URL: https://github.com/apache/flink/pull/20622#discussion_r957973525 ## flink-docs/pom.xml: ## @@ -173,6 +173,19 @@ under the License. ${project.version} + +

[jira] [Updated] (FLINK-29110) Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet.

2022-08-29 Thread Peng Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Yuan updated FLINK-29110: -- Description: Use StatefulSet instead of Deployment to deploy JM and TM to support mount a

[GitHub] [flink] luoyuxia commented on pull request #20665: [FLINK-28938][hive] Fix HiveServer2 Endpoint can not set variable correctly

2022-08-29 Thread GitBox
luoyuxia commented on PR #20665: URL: https://github.com/apache/flink/pull/20665#issuecomment-1231096780 @fsk119 Thanks for the appended commit. The commit 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

[GitHub] [flink] Myasuka commented on pull request #20708: [FLINK-29130][state] Correct the description of state.backend.local-recovery

2022-08-29 Thread GitBox
Myasuka commented on PR #20708: URL: https://github.com/apache/flink/pull/20708#issuecomment-1231092767 @masteryhx Thanks for your suggestions, I will also modify them in this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] Myasuka commented on a diff in pull request #20708: [FLINK-29130][state] Correct the description of state.backend.local-recovery

2022-08-29 Thread GitBox
Myasuka commented on code in PR #20708: URL: https://github.com/apache/flink/pull/20708#discussion_r957965849 ## docs/layouts/shortcodes/generated/checkpointing_configuration.html: ## @@ -18,7 +18,7 @@ state.backend.local-recovery false

[jira] [Commented] (FLINK-28926) Release Testing: Verify flip-235 hybrid shuffle mode

2022-08-29 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597496#comment-17597496 ] Yu Chen commented on FLINK-28926: - Hi [~hxb] [~Weijie Guo] , I have finished the setup work of the tests

[jira] [Updated] (FLINK-29132) SubtaskMetricStore causes memory leak.

2022-08-29 Thread Sitan Pang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sitan Pang updated FLINK-29132: --- Description: In [FLINK-28588], MetricStore supports multiple attempts of a subtask. However,

[jira] [Commented] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-29 Thread Jun He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597493#comment-17597493 ] Jun He commented on FLINK-28953: Hi Xingbo Huang, about 30% progress. > Release Testing: Verify FLIP-91

[jira] [Created] (FLINK-29132) SubtaskMetricStore causes memory leak.

2022-08-29 Thread Sitan Pang (Jira)
Sitan Pang created FLINK-29132: -- Summary: SubtaskMetricStore causes memory leak. Key: FLINK-29132 URL: https://issues.apache.org/jira/browse/FLINK-29132 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-29120) Unexpected join hint propagation into view

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29120: - Affects Version/s: 1.16.0 > Unexpected join hint propagation into view >

[jira] [Assigned] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-29038: Assignee: lincoln lee >

[jira] [Closed] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29038. Resolution: Fixed Merged into master via a1d74c131b0fd10f34436463077fd5c7a7984a2b >

[jira] [Commented] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597485#comment-17597485 ] Xingbo Huang commented on FLINK-29038: -- Thanks [~lincoln.86xy] and [~gaoyunhaii] for the fix. >

[GitHub] [flink] HuangXingBo closed pull request #20702: [FLINK-29038][runtime] Fix unstable case AsyncWaitOperatorTest#testProcessingTimeRepeatedCompleteOrderedWithRetry

2022-08-29 Thread GitBox
HuangXingBo closed pull request #20702: [FLINK-29038][runtime] Fix unstable case AsyncWaitOperatorTest#testProcessingTimeRepeatedCompleteOrderedWithRetry URL: https://github.com/apache/flink/pull/20702 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-kubernetes-operator] Grypse commented on pull request #357: [FLINK-29110] Use StatefulSet instead of Deployment to deploy JM and …

2022-08-29 Thread GitBox
Grypse commented on PR #357: URL: https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1231076842 @gyfora @wangyang0918 Please help me review this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-29120) Unexpected join hint propagation into view

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29120: - Fix Version/s: 1.16.0 > Unexpected join hint propagation into view >

[jira] [Updated] (FLINK-29120) Unexpected join hint propagation into view

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29120: - Component/s: Table SQL / Planner > Unexpected join hint propagation into view >

[jira] [Closed] (FLINK-28425) E2E tests run out of disk space on Azure

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28425. Resolution: Fixed Fixed in FLINK-28680 > E2E tests run out of disk space on Azure >

[jira] [Closed] (FLINK-28609) Flink-Pulsar connector fails on larger schemas

2022-08-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28609. - Resolution: Fixed master via d9bcbffc006481c09a8d2e04aa05cc92cd5c80d2 1.15 via

[jira] [Commented] (FLINK-28609) Flink-Pulsar connector fails on larger schemas

2022-08-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597479#comment-17597479 ] Zili Chen commented on FLINK-28609: --- Thank you for reporting and taking care of this issue! >

[GitHub] [flink] tisonkun merged pull request #20700: [BK-1.14][FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
tisonkun merged PR #20700: URL: https://github.com/apache/flink/pull/20700 -- 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] [Assigned] (FLINK-28609) Flink-Pulsar connector fails on larger schemas

2022-08-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-28609: - Assignee: Yufan Sheng > Flink-Pulsar connector fails on larger schemas >

[GitHub] [flink] tisonkun merged pull request #20699: [BK-1.15][FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
tisonkun merged PR #20699: URL: https://github.com/apache/flink/pull/20699 -- 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-29124) Redundant checkNotNull in cli Package

2022-08-29 Thread ivan Qing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ivan Qing updated FLINK-29124: -- Priority: Minor (was: Not a Priority) > Redundant checkNotNull in cli Package >

[jira] [Updated] (FLINK-28609) Flink-Pulsar connector fails on larger schemas

2022-08-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-28609: -- Fix Version/s: 1.16.0 1.14.6 1.15.3 > Flink-Pulsar connector

[GitHub] [flink] tisonkun merged pull request #20698: [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
tisonkun merged PR #20698: URL: https://github.com/apache/flink/pull/20698 -- 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] tisonkun commented on pull request #20698: [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
tisonkun commented on PR #20698: URL: https://github.com/apache/flink/pull/20698#issuecomment-1231069706 Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Commented] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

2022-08-29 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597470#comment-17597470 ] dalongliu commented on FLINK-28989: --- Sorry, I haven't started it due to some other work, I will start

[GitHub] [flink] reswqa commented on pull request #20647: [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled

2022-08-29 Thread GitBox
reswqa commented on PR #20647: URL: https://github.com/apache/flink/pull/20647#issuecomment-1231064064 @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-29068) Release Testing: Verify FLIP-214 Create function using jar syntax

2022-08-29 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597467#comment-17597467 ] Qingsheng Ren commented on FLINK-29068: --- [~hxb] I'll start testing this feature today. Thanks for

[jira] [Commented] (FLINK-29068) Release Testing: Verify FLIP-214 Create function using jar syntax

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597463#comment-17597463 ] Xingbo Huang commented on FLINK-29068: -- Hi [~renqs] , any progress on the issue? > Release

[jira] [Commented] (FLINK-29069) Release Testing: Verify FLIP-218 Create table as select syntax

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597464#comment-17597464 ] Xingbo Huang commented on FLINK-29069: -- Hi [~renqs] any progress on the issue? > Release Testing:

[jira] [Commented] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597461#comment-17597461 ] Xingbo Huang commented on FLINK-28989: -- Hi [~lsy]  any progress on the issue? > Release Testing:

[jira] [Commented] (FLINK-28964) Release Testing: Verify FLIP-205 Cache in DataStream for Batch Processing

2022-08-29 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597462#comment-17597462 ] Xuannan Su commented on FLINK-28964: Thank [~jessionX] for your testing. I think you have run the

[jira] [Assigned] (FLINK-29129) Try best to push down value filter

2022-08-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29129: Assignee: Jane Chan > Try best to push down value filter >

[jira] [Commented] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597459#comment-17597459 ] Shengkai Fang commented on FLINK-28953: --- [~junhe] If  you have any questions, please connect to

[jira] [Closed] (FLINK-28939) Release Testing: Verify FLIP-241 ANALYZE TABLE

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28939. Resolution: Done > Release Testing: Verify FLIP-241 ANALYZE TABLE >

[jira] [Commented] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

2022-08-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597458#comment-17597458 ] luoyuxia commented on FLINK-28954: -- Just has done some simple tests. I think I still need some to test

[jira] [Commented] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

2022-08-29 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597454#comment-17597454 ] Yunhong Zheng commented on FLINK-28981: --- [~hxb] , I have completed one-third of the

[jira] [Commented] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597453#comment-17597453 ] Xingbo Huang commented on FLINK-28953: -- Hi [~junhe] ,any progress on the test ? > Release Testing:

[jira] [Commented] (FLINK-28981) Release Testing: Verify FLIP-245 sources speculative execution

2022-08-29 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597449#comment-17597449 ] Xingbo Huang commented on FLINK-28981: -- Hi [~337361...@qq.com] , any progress on the issue? >

[jira] [Assigned] (FLINK-29097) Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-29097: - Assignee: Wencong Liu > Moving json se/deserializers from sql-gateway-api to

[jira] [Closed] (FLINK-29097) Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-29 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-29097. - Resolution: Fixed Merged into master: e18782f9bb8ae9320742fb0cedad889661f82c78 > Moving json

[GitHub] [flink] YesOrNo828 closed pull request #20703: [hotfix] Fix the wrong grammar in the java doc

2022-08-29 Thread GitBox
YesOrNo828 closed pull request #20703: [hotfix] Fix the wrong grammar in the java doc URL: https://github.com/apache/flink/pull/20703 -- 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

[GitHub] [flink] YesOrNo828 commented on pull request #20703: [hotfix] Fix the wrong grammar in the java doc

2022-08-29 Thread GitBox
YesOrNo828 commented on PR #20703: URL: https://github.com/apache/flink/pull/20703#issuecomment-1231047537 I close it because it has been fixed by https://github.com/apache/flink/pull/20631 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] fsk119 closed pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-29 Thread GitBox
fsk119 closed pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway URL: https://github.com/apache/flink/pull/20678 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #146: [FLINK-29011] Add Transformer for Binarizer

2022-08-29 Thread GitBox
zhipeng93 commented on code in PR #146: URL: https://github.com/apache/flink-ml/pull/146#discussion_r957922602 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/binarizer/Binarizer.java: ## @@ -0,0 +1,159 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] Aitozi commented on pull request #20397: [FLINK-28751][Table SQL/Runtime] Optimize the performance of the json…

2022-08-29 Thread GitBox
Aitozi commented on PR #20397: URL: https://github.com/apache/flink/pull/20397#issuecomment-1230996709 Rebase and force pushed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-25413) Use append dfs.nameservices hadoop config to replace override

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25413: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-28224) Add document for algorithms and features in Flink ML 2.1

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28224: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25814: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-25877) Update the copyright year in NOTICE files

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25877: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-6757) Investigate Apache Atlas integration

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6757: -- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27741: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-28321) HiveDialectQueryITCase fails with error code 137

2022-08-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28321: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20708: [FLINK-29130][state] Correct the description of state.backend.local-recovery

2022-08-29 Thread GitBox
rkhachatryan commented on code in PR #20708: URL: https://github.com/apache/flink/pull/20708#discussion_r957727218 ## docs/layouts/shortcodes/generated/checkpointing_configuration.html: ## @@ -18,7 +18,7 @@ state.backend.local-recovery false

[jira] [Commented] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

2022-08-29 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597313#comment-17597313 ] Mason Chen commented on FLINK-29128: I wonder if we did not solve "empty partitions" correctly.   

[GitHub] [flink] XComp commented on pull request #20709: [FLINK-28078] Dirty fix to reduce the likelihood of the ZooKeeperMultipleComponentLeaderElectionDriverTest#testLeaderElectionWithMultipleDriver

2022-08-29 Thread GitBox
XComp commented on PR #20709: URL: https://github.com/apache/flink/pull/20709#issuecomment-1230555616 @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] [Comment Edited] (FLINK-28078) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout

2022-08-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597279#comment-17597279 ] Matthias Pohl edited comment on FLINK-28078 at 8/29/22 4:24 PM:

[jira] [Comment Edited] (FLINK-28078) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout

2022-08-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597279#comment-17597279 ] Matthias Pohl edited comment on FLINK-28078 at 8/29/22 4:22 PM:

[jira] [Commented] (FLINK-28078) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers runs into timeout

2022-08-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597279#comment-17597279 ] Matthias Pohl commented on FLINK-28078: --- CURATOR-645 is probably caused by some issue where we

[jira] [Updated] (FLINK-29110) Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet.

2022-08-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29110: --- Labels: pull-request-available (was: ) > Support to mount a dynamically-created pvc for JM

[GitHub] [flink-kubernetes-operator] Grypse opened a new pull request, #357: [FLINK-29110] Use StatefulSet instead of Deployment to deploy JM and …

2022-08-29 Thread GitBox
Grypse opened a new pull request, #357: URL: https://github.com/apache/flink-kubernetes-operator/pull/357 ## What is the purpose of the change This pull request make an improvement for standalone mode to use StatefulSet instead of Deployment to deploy JM and TM to support mount a

[GitHub] [flink] gyfora commented on pull request #20642: [FLINK-29047][k8s] Shade fabric8 kubernetes with org.apache.flink.shaded prefix in flink-kubernetes

2022-08-29 Thread GitBox
gyfora commented on PR #20642: URL: https://github.com/apache/flink/pull/20642#issuecomment-1230529865 Could we simply shade everything under `io.fabric8.` @wangyang0918 ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] pvary commented on pull request #20710: [FLINK-29123][k8s] Dynamic paramters are not pushed to working with kubernetes

2022-08-29 Thread GitBox
pvary commented on PR #20710: URL: https://github.com/apache/flink/pull/20710#issuecomment-1230507823 > I think you miss the doc change part. ;-) Done, thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] XComp commented on pull request #20709: [FLINK-28078] Dirty fix to reduce the likelihood of the ZooKeeperMultipleComponentLeaderElectionDriverTest#testLeaderElectionWithMultipleDriver

2022-08-29 Thread GitBox
XComp commented on PR #20709: URL: https://github.com/apache/flink/pull/20709#issuecomment-1230502875 force-push needed because of missing `-DfailIfNoTests`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] gyfora commented on pull request #20710: [FLINK-29123][k8s] Dynamic paramters are not pushed to working with kubernetes

2022-08-29 Thread GitBox
gyfora commented on PR #20710: URL: https://github.com/apache/flink/pull/20710#issuecomment-1230479842 Other than the missing docs generation the changes look good -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-28988) Incorrect result for filter after temporal join

2022-08-29 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597255#comment-17597255 ] Shuiqiang Chen commented on FLINK-28988: [~xuannan] Thank you for reporting the issue. I have

[jira] [Closed] (FLINK-27030) RpcEndpointTest.testCancelScheduledTask failed

2022-08-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27030. Fix Version/s: 1.16.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-27030) RpcEndpointTest.testCancelScheduledTask failed

2022-08-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27030: - Issue Type: Technical Debt (was: Bug) > RpcEndpointTest.testCancelScheduledTask failed

[GitHub] [flink] zentol merged pull request #20706: [FLINK-27030][tests] Prevent race-condition

2022-08-29 Thread GitBox
zentol merged PR #20706: URL: https://github.com/apache/flink/pull/20706 -- 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] syhily commented on pull request #20698: [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
syhily commented on PR #20698: URL: https://github.com/apache/flink/pull/20698#issuecomment-1230406936 The CI failed on Kafka tests. I don't want to trigger the test again. Since this is a trivial change and tests passed on [1.15

[GitHub] [flink] syhily commented on pull request #20698: [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
syhily commented on PR #20698: URL: https://github.com/apache/flink/pull/20698#issuecomment-1230406433 The CI failed on Kafka tests. I don't want to trigger the test again. Since this is a trivial change and tests passed on [1.15

[GitHub] [flink] syhily commented on pull request #20698: [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized

2022-08-29 Thread GitBox
syhily commented on PR #20698: URL: https://github.com/apache/flink/pull/20698#issuecomment-1230406214 The CI failed on Kafka tests. I don't want to trigger the test again. Since this is a trivial change and tests passed on [1.15

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20705: [FLINK-29113][table-planner] throw exception when finding at least one invalid table name in join hints

2022-08-29 Thread GitBox
lincoln-lil commented on code in PR #20705: URL: https://github.com/apache/flink/pull/20705#discussion_r957413254 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/JoinHintResolver.java: ## @@ -99,10 +105,14 @@ private RelNode

[GitHub] [flink] bzhaoopenstack commented on pull request #20710: [FLINK-29123][k8s] Dynamic paramters are not pushed to working with kubernetes

2022-08-29 Thread GitBox
bzhaoopenstack commented on PR #20710: URL: https://github.com/apache/flink/pull/20710#issuecomment-1230389275 I think you miss the doc change part. ;-) -- 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-kubernetes-operator] tweise commented on pull request #356: [FLINK-29100] Relax upgrade checks to allow stateless restart when no stable spec is present

2022-08-29 Thread GitBox
tweise commented on PR #356: URL: https://github.com/apache/flink-kubernetes-operator/pull/356#issuecomment-1230376193 > Unfortunately even then it's possible that the job simply started but FAILED completely (that would delete HA metadata) and we cannot be sure whether checkpoints were

[jira] [Closed] (FLINK-29062) Protobuf-plugin should download protoc via maven on flink-protobuf module

2022-08-29 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29062. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] MartijnVisser merged pull request #20656: [FLINK-29062][build] Fix protobuf plugin proxy issue on flink-protobuf module.

2022-08-29 Thread GitBox
MartijnVisser merged PR #20656: URL: https://github.com/apache/flink/pull/20656 -- 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] [Assigned] (FLINK-29062) Protobuf-plugin should download protoc via maven on flink-protobuf module

2022-08-29 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29062: -- Assignee: Jiabao Sun > Protobuf-plugin should download protoc via maven on

[jira] [Assigned] (FLINK-29067) Replace deprecated Calcite's SqlParser#configBuilder with SqlParser#config

2022-08-29 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29067: -- Assignee: Sergey Nuyanzin > Replace deprecated Calcite's SqlParser#configBuilder

  1   2   3   >