[jira] [Created] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

2022-02-24 Thread Yang Wang (Jira)
Yang Wang created FLINK-26367: - Summary: Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator Key: FLINK-26367 URL: https://issues.apache.org/jira/browse/FLINK-26367 Project: Flink

[jira] [Updated] (FLINK-26334) when the (timestamp - offset + windowSize) is less than 0 the calculation result of TimeWindow.getWindowSTartWithOffset is incorrect

2022-02-24 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Priority: Blocker (was: Major) > when the (timestamp - offset + windowSize) is less than 0 the

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * ce34627cabe844f0af69ddca6f1b5599e5bf1ef8 Azure:

[jira] [Closed] (FLINK-26141) Support last-state upgrade mode

2022-02-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26141. - Resolution: Fixed Fixed via: main: baaed88b21a27df0eb26a5bdce4516ec3c7510c1 > Support last-state

[GitHub] [flink-ml] lindong28 closed pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
lindong28 closed pull request #66: URL: https://github.com/apache/flink-ml/pull/66 -- 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-ml] lindong28 commented on pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
lindong28 commented on pull request #66: URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050616922 Thanks for the update! 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

[GitHub] [flink] flinkbot edited a comment on pull request #18917: error

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18917: URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613556 ## CI report: * 7bd2b6a4ebda7ea5b727984a4b4877c0dbf8432b Azure:

[GitHub] [flink] flinkbot commented on pull request #18917: error

2022-02-24 Thread GitBox
flinkbot commented on pull request #18917: URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613861 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18917: error

2022-02-24 Thread GitBox
flinkbot commented on pull request #18917: URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613556 ## CI report: * 7bd2b6a4ebda7ea5b727984a4b4877c0dbf8432b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zhaishujie opened a new pull request #18917: error

2022-02-24 Thread GitBox
zhaishujie opened a new pull request #18917: URL: https://github.com/apache/flink/pull/18917 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink-ml] lindong28 commented on pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
lindong28 commented on pull request #66: URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050611807 @zhipeng93 It is generally preferred to have a test to reproduce this bug with high likelihood, or be able to reproduce this bug manually. This is generally done on a

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

2022-02-24 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497959#comment-17497959 ] Konstantin Knauf commented on FLINK-26354: -- >From my perspective consistency with existing

[jira] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:39 AM: # Why using a

[GitHub] [flink] flinkbot edited a comment on pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18915: URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121 ## CI report: * acc2bffef19cb00ce33dac3330cd0e1b7d692835 Azure:

[jira] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:32 AM: # Why using a

[jira] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:32 AM: # Why using a

[jira] [Closed] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects

2022-02-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26136. -- Resolution: Fixed Merged: 85d997eaa0310a298bb3a3a704afacf3844635f7 > Implement shared validation

[jira] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:25 AM: The severity of

[jira] [Commented] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947 ] Yuan Mei commented on FLINK-26306: -- >From the number shared, I do agree that this is an

[jira] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:12 AM: >From the number

[GitHub] [flink] wangyang0918 commented on a change in pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-02-24 Thread GitBox
wangyang0918 commented on a change in pull request #18739: URL: https://github.com/apache/flink/pull/18739#discussion_r814522068 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1829,4 +1809,41 @@ public static void

[GitHub] [flink] 1996fanrui commented on pull request #18852: [FLINK-26049][checkpoint] Improve logic after checkpoint trigger fails

2022-02-24 Thread GitBox
1996fanrui commented on pull request #18852: URL: https://github.com/apache/flink/pull/18852#issuecomment-1050574741 > @1996fanrui , thanks a lot for these changes. I left a several comments in the PR, please, take a look. I also have an one question: According to ticket, you had a

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 684cc9586eed1e214683ea3d881e30bbc1065670 Azure:

[jira] [Assigned] (FLINK-18229) Pending worker requests should be properly cleared

2022-02-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-18229: Assignee: huweihua > Pending worker requests should be properly cleared >

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

2022-02-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497938#comment-17497938 ] Xintong Song commented on FLINK-18229: -- Thanks for volunteering, [~huwh]. You are assigned. >

[jira] [Commented] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497937#comment-17497937 ] Yang Wang commented on FLINK-26356: --- I think we could always use the {{-rest.}} to access the Flink

[jira] [Updated] (FLINK-26334) when the (timestamp - offset + windowSize) is less than 0 the calculation result of TimeWindow.getWindowSTartWithOffset is incorrect

2022-02-24 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Affects Version/s: 1.15.0 > when the (timestamp - offset + windowSize) is less than 0 the

[jira] [Commented] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

2022-02-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497933#comment-17497933 ] Yang Wang commented on FLINK-25963: --- FYI: I have enabled the auto link reference for

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

2022-02-24 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497929#comment-17497929 ] huweihua commented on FLINK-18229: -- Hi [~xtsong] , I would like to deal with this issue, could you

[GitHub] [flink] RocMarshal edited a comment on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

2022-02-24 Thread GitBox
RocMarshal edited a comment on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1037264660 @gaoyunhaii @wuchong Could you help me to merge it if there's nothing Inappropriate? Thank you very much. -- This is an automated message from the Apache Git

[jira] [Comment Edited] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497923#comment-17497923 ] luoyuxia edited comment on FLINK-26355 at 2/25/22, 6:14 AM: [~zoucao]

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497923#comment-17497923 ] luoyuxia commented on FLINK-26355: -- [~zoucao] HiveTableSqlFunction is deprecated. I think the better

[GitHub] [flink] wangyang0918 commented on pull request #17502: [FLINK-24538][runtime][tests] Fix ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-02-24 Thread GitBox
wangyang0918 commented on pull request #17502: URL: https://github.com/apache/flink/pull/17502#issuecomment-1050551870 Sorry for the late response. @dmvk I think your suggestion makes sense to me. Then we will have only one place `waitForNewLeader` or `waitForEmptyLeaderInformation` to

[GitHub] [flink-table-store] shenzhu commented on pull request #24: [FLINK-26217] Introduce manifest.merge-min-count in commit

2022-02-24 Thread GitBox
shenzhu commented on pull request #24: URL: https://github.com/apache/flink-table-store/pull/24#issuecomment-1050550061 Hey @tsreaper , I updated this PR and added some tests, would you mind taking a look again when you have a moment? Thanks! -- This is an automated message from the

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497918#comment-17497918 ] zoucao commented on FLINK-26355: I use default dialect with hive module rather than hive dialect. Is it

[GitHub] [flink] schumiyi commented on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

2022-02-24 Thread GitBox
schumiyi commented on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1050529549 @wuchong @JingsongLi Would you like to review this pr? Thanks for your time. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #18916: [FLINK-26314] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18916: URL: https://github.com/apache/flink/pull/18916#issuecomment-1050514075 ## CI report: * be996b8c559bb17a7a4f3c3d397b79ed70d8ec9b Azure:

[GitHub] [flink] flinkbot commented on pull request #18916: [FLINK-26314] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

2022-02-24 Thread GitBox
flinkbot commented on pull request #18916: URL: https://github.com/apache/flink/pull/18916#issuecomment-1050515056 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18916: [FLINK-26314] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

2022-02-24 Thread GitBox
flinkbot commented on pull request #18916: URL: https://github.com/apache/flink/pull/18916#issuecomment-1050514075 ## CI report: * be996b8c559bb17a7a4f3c3d397b79ed70d8ec9b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure

2022-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26314: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] pltbkd opened a new pull request #18916: [FLINK-26314] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

2022-02-24 Thread GitBox
pltbkd opened a new pull request #18916: URL: https://github.com/apache/flink/pull/18916 ## What is the purpose of the change This pull request fixes the unstable test case of StreamingCompactingFileSinkITCase since the compactor of FileSink can't work with unaligned

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26360: - Description: Currently, we have a support for hive synatax compatibility in flink as described in

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26360: - Description: Currently, we have a support for hive synatax compatibility in flink as described in

[jira] [Updated] (FLINK-26366) Support "insert directory"

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26366: - Description: In hive, it allow to write data into the filesystem from queries using the following sql

[GitHub] [flink] flinkbot edited a comment on pull request #18891: [FLINK-25243][k8s] Increase the k8s transactional operation max retries in the integration tests

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18891: URL: https://github.com/apache/flink/pull/18891#issuecomment-1048391421 ## CI report: * 4a1e6f20a8703f2fa59879da3d287e5ad5e284c5 Azure:

[jira] [Created] (FLINK-26366) Support "insert directory"

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26366: Summary: Support "insert directory" Key: FLINK-26366 URL: https://issues.apache.org/jira/browse/FLINK-26366 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18891: [FLINK-25243][k8s] Increase the k8s transactional operation max retries in the integration tests

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18891: URL: https://github.com/apache/flink/pull/18891#issuecomment-1048391421 ## CI report: * 4a1e6f20a8703f2fa59879da3d287e5ad5e284c5 Azure:

[jira] [Assigned] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26360: --- Assignee: luoyuxia > [Umbrella] Improvement for Hive Query Syntax Compatibility >

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26360: Fix Version/s: 1.16.0 > [Umbrella] Improvement for Hive Query Syntax Compatibility >

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497891#comment-17497891 ] luoyuxia commented on FLINK-26355: -- [~zoucao] Thanks for reporting it. Seems you're using hive

[GitHub] [flink] v-qiunan commented on pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
v-qiunan commented on pull request #18915: URL: https://github.com/apache/flink/pull/18915#issuecomment-1050498632 hello -- 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] [Updated] (FLINK-26365) improve hive udaf

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26365: - Description: Currently we can't get call Hive UDAF that requires constant arguments like

[jira] [Commented] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure

2022-02-24 Thread Gen Luo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497887#comment-17497887 ] Gen Luo commented on FLINK-26314: - I found that the PseudoRandomValueSelector is selecting PT0S for

[jira] [Created] (FLINK-26365) improve hive udaf

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26365: Summary: improve hive udaf Key: FLINK-26365 URL: https://issues.apache.org/jira/browse/FLINK-26365 Project: Flink Issue Type: Sub-task Components:

[jira] [Updated] (FLINK-26364) Improve hive udtf

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26364: - Description: There're some issue sreported releated to calling hive udft like

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497885#comment-17497885 ] zoucao commented on FLINK-26355: Hi, [~luoyuxia], I found this problem in the process of driving the

[jira] [Updated] (FLINK-26364) Improve hive udtf

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26364: - Description: There're some issue sreported releated to calling hive udft like

[jira] [Updated] (FLINK-26364) Improve hive udtf

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26364: - Description: There're some issue sreported releated to calling hive udft like

[GitHub] [flink] flinkbot edited a comment on pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18915: URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121 ## CI report: * acc2bffef19cb00ce33dac3330cd0e1b7d692835 Azure:

[jira] [Created] (FLINK-26364) Improve hive udtf

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26364: Summary: Improve hive udtf Key: FLINK-26364 URL: https://issues.apache.org/jira/browse/FLINK-26364 Project: Flink Issue Type: Sub-task Reporter:

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
zhipeng93 edited a comment on pull request #66: URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249 Hi Dong, Thanks for the review. > Could you confirm that the flaky test could be reproduced before this patch but not after this patch? I have repeatedly

[GitHub] [flink] flinkbot commented on pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
flinkbot commented on pull request #18915: URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485301 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
flinkbot commented on pull request #18915: URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121 ## CI report: * acc2bffef19cb00ce33dac3330cd0e1b7d692835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497881#comment-17497881 ] luoyuxia commented on FLINK-26363: -- There're are some issue like

[jira] [Updated] (FLINK-26351) After scaling a flink task running on k8s, the flink web ui graph always shows the parallelism of the first deployment.

2022-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26351: --- Labels: pull-request-available (was: ) > After scaling a flink task running on k8s, the

[jira] [Updated] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26363: - Description: Using hive dialect, can be reproduced using the following sql {code:sql} select if(1=1,

[GitHub] [flink] v-qiunan opened a new pull request #18915: [FLINK-26351][k8s/web ui] After scaling a flink task running on k8s, …

2022-02-24 Thread GitBox
v-qiunan opened a new pull request #18915: URL: https://github.com/apache/flink/pull/18915 …the flink web ui graph always shows the parallelism of the first deployment. ## What is the purpose of the change *(After scaling a flink task running on k8s, the flink web ui

[jira] [Updated] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26363: - Description: Using hive dialect, can be reproduced using the following sql {code:sql} select if(1=1,

[jira] [Created] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26363: Summary: Fail to use such expression like if(1= 1, 2, 3) Key: FLINK-26363 URL: https://issues.apache.org/jira/browse/FLINK-26363 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

2022-02-24 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497878#comment-17497878 ] Yun Tang commented on FLINK-26354: -- Since the latest version of commons-cli is 1.5.0, which is what we

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 4324aa57719c8e0f0e408daaa4dd7064109bc5fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 4324aa57719c8e0f0e408daaa4dd7064109bc5fa Azure:

[GitHub] [flink] MrWhiteSike commented on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-24 Thread GitBox
MrWhiteSike commented on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1050465364 [@RocMarshal](https://github.com/RocMarshal) Thanks for the comments. Please review it again. Thanks -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26356: --- Description: The clusterClient is built as below. The config is mixed up with the FlinkDeploymentSpec and

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26360: - Description: Currently, we have a support for hive synatax compatibility in flink as described in

[jira] [Commented] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497857#comment-17497857 ] luoyuxia commented on FLINK-26362: -- We should add a extra project node when type conversion is

[jira] [Updated] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26362: - Description: With hive dialect, can be reproduced using following code: {code:java}

[GitHub] [flink] flinkbot edited a comment on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1050372877 ## CI report: * a591d1c40b987902427e7692e208e972b70bcb33 Azure:

[jira] [Updated] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26362: - Description: With hive dialect, can be reproduced using following code: {code:java}

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:

[jira] [Updated] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26362: - Summary: "IndexOutOfBoundsException" when subquery select all field from using hive dialect (was:

[jira] [Created] (FLINK-26362) IndexOutOfBoundsException when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26362: Summary: IndexOutOfBoundsException when subquery select all field from using hive dialect Key: FLINK-26362 URL: https://issues.apache.org/jira/browse/FLINK-26362 Project:

[jira] [Closed] (FLINK-26343) IndexOutOfBoundsException when subquery select all field from using hive dialect

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-26343. Resolution: Duplicate > IndexOutOfBoundsException when subquery select all field from using hive >

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:

[GitHub] [flink] MrWhiteSike commented on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-24 Thread GitBox
MrWhiteSike commented on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1050452261 [@RocMarshal](https://github.com/RocMarshal) Thanks for the comments.I updated this pr based on your comments. Please review it again. Thanks -- This is an automated

[jira] [Commented] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497850#comment-17497850 ] luoyuxia commented on FLINK-26361: -- I'll fix it. > "Unexpected correlate variable $cor0" when using

[jira] [Updated] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26361: - Description: With hive dialect, can be reproduced using such code: {code:java}

[jira] [Commented] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497848#comment-17497848 ] Aitozi commented on FLINK-26356: I have not make it very clear yet, I will do more investigation first.

[jira] [Created] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26361: Summary: "Unexpected correlate variable $cor0" when using hive dialect to write a subquery Key: FLINK-26361 URL: https://issues.apache.org/jira/browse/FLINK-26361 Project:

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26360: - Description: Currently, we have a support for hive synatax compatibility in flink as described in

[jira] [Commented] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497847#comment-17497847 ] luoyuxia commented on FLINK-25727: -- I will fix it in

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-02-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497845#comment-17497845 ] luoyuxia commented on FLINK-26355: -- [~zoucao] The answer is yes. There's a similar issue

[jira] [Created] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-26360: Summary: [Umbrella] Improvement for Hive Query Syntax Compatibility Key: FLINK-26360 URL: https://issues.apache.org/jira/browse/FLINK-26360 Project: Flink Issue

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
zhipeng93 edited a comment on pull request #66: URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249 Not ready.. -- 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] [Comment Edited] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-02-24 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408 ] Yuan Mei edited comment on FLINK-26306 at 2/25/22, 1:42 AM: # Why using a

[GitHub] [flink-ml] zhipeng93 commented on pull request #66: [FLINK-26263] (followup) Check data size in LogisticRegression

2022-02-24 Thread GitBox
zhipeng93 commented on pull request #66: URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249 Hi Dong, Thanks for the review. > Could you confirm that the flaky test could be reproduced before this patch but not after this patch? I have repeatedly run this

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * 0ba635c5ae44773c15a90e8c668007e744b37251 Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

2022-02-24 Thread GitBox
afedulov commented on a change in pull request #18903: URL: https://github.com/apache/flink/pull/18903#discussion_r814220659 ## File path: docs/content/docs/connectors/datastream/formats/csv.md ## @@ -0,0 +1,87 @@ +--- +title: "CSV" +weight: 4 +type: docs +aliases: +-

[jira] [Commented] (FLINK-26334) when the (timestamp - offset + windowSize) is less than 0 the calculation result of TimeWindow.getWindowSTartWithOffset is incorrect

2022-02-24 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497832#comment-17497832 ] realdengziqi commented on FLINK-26334: -- I want to work on this:D > when the (timestamp - offset +

[GitHub] [flink] afedulov commented on a change in pull request #18911: [FLINK-26357][format] add FLINK API annotations

2022-02-24 Thread GitBox
afedulov commented on a change in pull request #18911: URL: https://github.com/apache/flink/pull/18911#discussion_r814275794 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -42,7 +43,17 @@

  1   2   3   4   5   6   >