[GitHub] [flink] flinkbot commented on pull request #18248: [FLINK-25477][docs] Make the directory structure of the State Backend…

2021-12-30 Thread GitBox
flinkbot commented on pull request #18248: URL: https://github.com/apache/flink/pull/18248#issuecomment-1003301042 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 #18248: [FLINK-25477][docs] Make the directory structure of the State Backend…

2021-12-30 Thread GitBox
flinkbot commented on pull request #18248: URL: https://github.com/apache/flink/pull/18248#issuecomment-1003300867 ## CI report: * 5a11d1fbfe8fcc416bd6f827d49b9576eba76c76 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * b7283bf3bb378559403df63696ccf1effd5e080c Azure:

[jira] [Updated] (FLINK-25477) The directory structure of the State Backends document is not standardized

2021-12-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25477: --- Labels: pull-request-available (was: ) > The directory structure of the State Backends

[GitHub] [flink] masteryhx opened a new pull request #18248: [FLINK-25477][docs] Make the directory structure of the State Backend…

2021-12-30 Thread GitBox
masteryhx opened a new pull request #18248: URL: https://github.com/apache/flink/pull/18248 …s document display correctly ## What is the purpose of the change The State Backends document uses multiple first-level headings. It may cause the directory structure

[jira] [Closed] (FLINK-25489) mac m1 built flink from source failed cause of couldn't download nodejs

2021-12-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25489. -- Resolution: Duplicate This is a duplicate of

[GitHub] [flink] flinkbot edited a comment on pull request #18239: [flink-25426][runtime] Calling super#onStop for all RpcEndpoint children to be sure that all resources close correctly

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18239: URL: https://github.com/apache/flink/pull/18239#issuecomment-1002763066 ## CI report: * c40102d1aeea75e74a55dee000482fc54458c864 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18239: [flink-25426][runtime] Calling super#onStop for all RpcEndpoint children to be sure that all resources close correctly

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18239: URL: https://github.com/apache/flink/pull/18239#issuecomment-1002763066 ## CI report: * c40102d1aeea75e74a55dee000482fc54458c864 Azure:

[jira] [Commented] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure

2021-12-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467129#comment-17467129 ] Yun Gao commented on FLINK-25496: -

[jira] [Commented] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure

2021-12-30 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467128#comment-17467128 ] Junfan Zhang commented on FLINK-25496: -- Sorry for that. I'll correct it asap. >

[jira] [Commented] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure

2021-12-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467127#comment-17467127 ] Yun Gao commented on FLINK-25496: - [~zuston] Hello~ This case seems to be not stable, could you have a

[jira] [Created] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure

2021-12-30 Thread Yun Gao (Jira)
Yun Gao created FLINK-25496: --- Summary: ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure Key: FLINK-25496 URL: https://issues.apache.org/jira/browse/FLINK-25496 Project: Flink

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

2021-12-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467126#comment-17467126 ] Yun Gao commented on FLINK-18356: -

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

2021-12-30 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467125#comment-17467125 ] Junfan Zhang commented on FLINK-25495: -- Could you help check this feature [~trohrmann]? If

[jira] [Updated] (FLINK-25495) Client support attach mode when using the deployment of application mode

2021-12-30 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25495: - Description: h2. Why In our internal data platform, we support flink batch and streaming job

[jira] [Created] (FLINK-25495) Client support attach mode when using the deployment of application mode

2021-12-30 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-25495: Summary: Client support attach mode when using the deployment of application mode Key: FLINK-25495 URL: https://issues.apache.org/jira/browse/FLINK-25495 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 3542eed0bfa4727c33c6b408118089f4966029c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * c7e641391ced193b29426cca7a14baaed22b1d9d Azure:

[jira] [Updated] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25494: - Description: Currently, during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources, it

[jira] [Updated] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25494: - Description: Currently, during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources, it

[jira] [Created] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources

2021-12-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-25494: Summary: Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources Key: FLINK-25494 URL: https://issues.apache.org/jira/browse/FLINK-25494

[GitHub] [flink] dianfu closed pull request #18099: [FLINK-25294][python] Fix cloudpickle import

2021-12-30 Thread GitBox
dianfu closed pull request #18099: URL: https://github.com/apache/flink/pull/18099 -- 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] flinkbot edited a comment on pull request #18235: Test change default batch configuration

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18235: URL: https://github.com/apache/flink/pull/18235#issuecomment-1002631269 ## CI report: * f3f9bd225560dfefede9c83e7ae3964661fdde25 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] dianfu edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-30 Thread GitBox
dianfu edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1003285345 @MartijnVisser Oh, just missed that the source package for Py4J should also be updated: https://github.com/apache/flink/tree/master/flink-python/lib/ -- This is an

[GitHub] [flink] dianfu commented on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-30 Thread GitBox
dianfu commented on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1003285345 @MartijnVisser Oh, just missed that the source package for Py4J is also needed to be updated: https://github.com/apache/flink/tree/master/flink-python/lib/ -- This is an

[GitHub] [flink] KarmaGYZ commented on pull request #18239: [flink-25426][runtime] Calling super#onStop for all RpcEndpoint children to be sure that all resources close correctly

2021-12-30 Thread GitBox
KarmaGYZ commented on pull request #18239: URL: https://github.com/apache/flink/pull/18239#issuecomment-1003285303 @akalash Please take a look at the failed tests. -- 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] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] dianfu commented on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-30 Thread GitBox
dianfu commented on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1003284621 @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

[jira] [Assigned] (FLINK-25492) Changelog with InMemoryStateChangelogStorage cannot work well

2021-12-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-25492: Assignee: Hangxiang Yu > Changelog with InMemoryStateChangelogStorage cannot work well >

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

2021-12-30 Thread GitBox
ruanhang1993 commented on a change in pull request #18246: URL: https://github.com/apache/flink/pull/18246#discussion_r776641725 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/annotations/Topic.java ## @@ -0,0

[jira] [Closed] (FLINK-25294) Incorrect cloudpickle import

2021-12-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25294. --- Fix Version/s: 1.15.0 1.14.3 Assignee: arya Resolution: Fixed Merged to

[jira] [Updated] (FLINK-25493) The date type data is NULL and the reason for the SQL verification failure is null(日期类型数据为空导致SQL校验失败原因为null)

2021-12-30 Thread kunghsu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kunghsu updated FLINK-25493: Summary: The date type data is NULL and the reason for the SQL verification failure is

[jira] [Updated] (FLINK-25493) 日期类型数据为空导致SQL校验失败原因为null

2021-12-30 Thread kunghsu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kunghsu updated FLINK-25493: Description: English Description  The date type data is NULL and the reason for the SQL verification

[GitHub] [flink] dianfu closed pull request #18186: [FLINK-25418][python] Install dependencies completely offline

2021-12-30 Thread GitBox
dianfu closed pull request #18186: URL: https://github.com/apache/flink/pull/18186 -- 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] [Closed] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-10954. Resolution: Information Provided After FLINK-25468, we can at least not fail the job. > Hardlink from

[jira] [Updated] (FLINK-25493) 日期类型数据为空导致SQL校验失败原因为null

2021-12-30 Thread kunghsu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kunghsu updated FLINK-25493: Description: 英文版   中文版 日期类型数据为空导致SQL校验失败原因为null 假如数据表中date类型的数值为空,在执行sql

[jira] [Updated] (FLINK-25493) 日期类型数据为空导致SQL校验失败原因为null

2021-12-30 Thread kunghsu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kunghsu updated FLINK-25493: Issue Type: Bug (was: Improvement) > 日期类型数据为空导致SQL校验失败原因为null > > >

[jira] [Closed] (FLINK-25418) The dir_cache is specified in the flink task. When there is no network, you will still download the python third-party library

2021-12-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25418. --- Fix Version/s: 1.15.0 1.14.3 Resolution: Fixed Merged to - master via 

[jira] [Created] (FLINK-25493) 日期类型数据为空导致SQL校验失败原因为null

2021-12-30 Thread kunghsu (Jira)
kunghsu created FLINK-25493: --- Summary: 日期类型数据为空导致SQL校验失败原因为null Key: FLINK-25493 URL: https://issues.apache.org/jira/browse/FLINK-25493 Project: Flink Issue Type: Improvement Components:

[jira] [Commented] (FLINK-25464) Python tests hangs on install dependencies

2021-12-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467105#comment-17467105 ] Yun Gao commented on FLINK-25464: -

[jira] [Comment Edited] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

2021-12-30 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467081#comment-17467081 ] ChangjiGuo edited comment on FLINK-25475 at 12/31/21, 5:55 AM: --- Are there

[jira] [Updated] (FLINK-25482) Hive Lookup Join with decimal type failed

2021-12-30 Thread miaojianlong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] miaojianlong updated FLINK-25482: - Description: Hive Lookup Join with decimal type failed. {code:java}

[jira] [Updated] (FLINK-25478) Same materialized state handle should not register multi times

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25478: - Summary: Same materialized state handle should not register multi times (was: Same materialized state

[jira] [Updated] (FLINK-25478) Same materialized state handle should register multi times

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25478: - Parent: FLINK-21352 Issue Type: Sub-task (was: Bug) > Same materialized state handle should

[jira] [Updated] (FLINK-25478) Same materialized state handle should register multi times

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25478: - Description: Currently, changelog materialization would call RocksDB state backend's snapshot method

[jira] [Updated] (FLINK-25478) Same materialized state handle should register multi times

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25478: - Summary: Same materialized state handle should register multi times (was: Changelog materialization

[jira] [Updated] (FLINK-25478) Changelog materialization with incremental checkpoint could cause checkpointed data lost

2021-12-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25478: - Description: Currently, changelog materialization would call RocksDB state backend's snapshot method

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 13e02d58b77feccf266adebd8b7993b27e7ba476 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18247: [FLINK-25119][runtime] Modify the name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method.

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18247: URL: https://github.com/apache/flink/pull/18247#issuecomment-1003265634 ## CI report: * 32f859d7cd7764ef305e76b0662dfdd42b8f8a24 Azure:

[GitHub] [flink] flinkbot commented on pull request #18247: [FLINK-25119][runtime] Modify the name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method.

2021-12-30 Thread GitBox
flinkbot commented on pull request #18247: URL: https://github.com/apache/flink/pull/18247#issuecomment-1003266017 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 #18247: [FLINK-25119][runtime] Modify the name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method.

2021-12-30 Thread GitBox
flinkbot commented on pull request #18247: URL: https://github.com/apache/flink/pull/18247#issuecomment-1003265634 ## CI report: * 32f859d7cd7764ef305e76b0662dfdd42b8f8a24 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25119) The name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method is named incorrectly.

2021-12-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25119: --- Labels: pull-request-available (was: ) > The name of freeSlots parameter in >

[GitHub] [flink] wxy7 opened a new pull request #18247: [FLINK-25119][runtime] Modify the name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method.

2021-12-30 Thread GitBox
wxy7 opened a new pull request #18247: URL: https://github.com/apache/flink/pull/18247 ## What is the purpose of the change *This pull request modify the name of freeSlot parameter in SlotSharingSlotAllocator#determineParallelism method* ## Brief change log -

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1003257853 Thanks @tillrohrmann for your suggestions. Sorry for the late reply. Now I introduce two class of `YarnAsyncClusterClientProviderFactory` and `AsyncClusterClientProvider`

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * bac1ff6ec6cda565eaf7ac9585cc8179c6c00ce9 Azure:

[GitHub] [flink] wangzhuoz closed pull request #18200: [hotfix][doc] Remove duplicate dot in generating_watermarks.md

2021-12-30 Thread GitBox
wangzhuoz closed pull request #18200: URL: https://github.com/apache/flink/pull/18200 -- 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] [Created] (FLINK-25492) Changelog with InMemoryStateChangelogStorage cannot work well

2021-12-30 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-25492: Summary: Changelog with InMemoryStateChangelogStorage cannot work well Key: FLINK-25492 URL: https://issues.apache.org/jira/browse/FLINK-25492 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * bac1ff6ec6cda565eaf7ac9585cc8179c6c00ce9 Azure:

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r776918452 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r776918413 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -613,21 +617,42 @@ public void killCluster(ApplicationId

[GitHub] [flink] zuston commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-30 Thread GitBox
zuston commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r776918240 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1195,9 +1220,21 @@ private ApplicationReport

[GitHub] [flink] flinkbot edited a comment on pull request #18200: [hotfix][doc] Remove duplicate dot in generating_watermarks.md

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18200: URL: https://github.com/apache/flink/pull/18200#issuecomment-1000717422 ## CI report: * c924bbaf8a91fff918da92300308d35ea9a12c9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 89d75be44b0c222749150970de40f095124de244 Azure:

[jira] [Commented] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

2021-12-30 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467081#comment-17467081 ] ChangjiGuo commented on FLINK-25475: Are there any side effects if the StreamExecMiniBatchAssigner

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 89d75be44b0c222749150970de40f095124de244 Azure:

[jira] [Commented] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

2021-12-30 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467078#comment-17467078 ] Rui Li commented on FLINK-25023: Hey [~keremulutas], when I investigated FLINK-15239, moving hadoop deps

[GitHub] [flink] imaffe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

2021-12-30 Thread GitBox
imaffe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-1003253983 @fapaul Hi Paul, I've already rebased the branch~ -- 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] flinkbot edited a comment on pull request #18200: [hotfix][doc] Remove duplicate dot in generating_watermarks.md

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18200: URL: https://github.com/apache/flink/pull/18200#issuecomment-1000717422 ## CI report: * c924bbaf8a91fff918da92300308d35ea9a12c9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18200: [hotfix][doc] Remove duplicate dot in generating_watermarks.md

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18200: URL: https://github.com/apache/flink/pull/18200#issuecomment-1000717422 ## CI report: * c924bbaf8a91fff918da92300308d35ea9a12c9e Azure:

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2021-12-30 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467074#comment-17467074 ] ranqiqiang commented on FLINK-14902: [~ana4]  I don‘t want to modify too much code.I jush create a 

[GitHub] [flink] godfreyhe closed pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

2021-12-30 Thread GitBox
godfreyhe closed pull request #17845: URL: https://github.com/apache/flink/pull/17845 -- 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] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 13e02d58b77feccf266adebd8b7993b27e7ba476 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 13e02d58b77feccf266adebd8b7993b27e7ba476 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2021-12-30 Thread GitBox
wanglijie95 commented on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-1003248967 @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

[jira] [Closed] (FLINK-24352) Lookup join + WITH clause throws NPE

2021-12-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24352. -- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in 1.15.0:

[GitHub] [flink] godfreyhe commented on pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

2021-12-30 Thread GitBox
godfreyhe commented on pull request #17845: URL: https://github.com/apache/flink/pull/17845#issuecomment-1003247727 @YuvalItzchakov I add `assert ns.getTable() != null` before calling `ns.getTable().isTemporal()` and merge the pr. Thanks for the contribution -- This is an automated

[GitHub] [flink-ml] zhipeng93 commented on pull request #51: [hotfix] Update setup.py to throw error if python version > 3.8

2021-12-30 Thread GitBox
zhipeng93 commented on pull request #51: URL: https://github.com/apache/flink-ml/pull/51#issuecomment-1003245860 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

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2021-12-30 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467071#comment-17467071 ] Ada Wong commented on FLINK-14902: -- [~michael ran] What do you want to implement async using

[jira] [Closed] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2021-12-30 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-20641. Resolution: Not A Bug > flink-connector-elasticsearch6 will deadlock >

[jira] [Closed] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM

2021-12-30 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-20643. Resolution: Not A Bug > flink-connector-elasticsearch7 causes Direct buffer memory OOM >

[GitHub] [flink-ml] lindong28 commented on pull request #51: [hotfix] Update setup.py to throw error if python version > 3.8

2021-12-30 Thread GitBox
lindong28 commented on pull request #51: URL: https://github.com/apache/flink-ml/pull/51#issuecomment-1003240537 @HuangXingBo Could you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-ml] lindong28 opened a new pull request #51: [hotfix] Update setup.py to throw error if python version > 3.8

2021-12-30 Thread GitBox
lindong28 opened a new pull request #51: URL: https://github.com/apache/flink-ml/pull/51 ## What is the purpose of the change User should see more explicit error when installing `apache-flink-ml` with un-supported python version. ## Brief change log Update setup.py to

[jira] [Updated] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

2021-12-30 Thread Daniel Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Cheng updated FLINK-25491: - Description: When using Table API (Blink planner), if you are filtering using an IN filter

[GitHub] [flink] lipusheng commented on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

2021-12-30 Thread GitBox
lipusheng commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-1003239349 Ok, thanks. -- 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-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

2021-12-30 Thread Daniel Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Cheng updated FLINK-25491: - Description: When using Table API, if you are filtering using an IN filter with a lot of

[jira] [Updated] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

2021-12-30 Thread Daniel Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Cheng updated FLINK-25491: - Description: When using Table API, if you are filtering using an IN filter with a lot of

[jira] [Created] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

2021-12-30 Thread Daniel Cheng (Jira)
Daniel Cheng created FLINK-25491: Summary: Code generation: init method exceeds 64 KB when there is a large IN filter with Table API Key: FLINK-25491 URL: https://issues.apache.org/jira/browse/FLINK-25491

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18235: URL: https://github.com/apache/flink/pull/18235#issuecomment-1002631269 ## CI report: * ee582b4af0a7c5212bb0014bd146bafc78d41128 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18235: URL: https://github.com/apache/flink/pull/18235#issuecomment-1002631269 ## CI report: * ee582b4af0a7c5212bb0014bd146bafc78d41128 Azure:

[jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2747: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2824) Iteration feedback partitioning does not work as expected

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2824: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3037: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2609) Automatic type registration is only called from the batch execution environment

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2609: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2546) The webclient does not allow users to save the execution plan

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2546: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2657) Fix WebClient and CLI interaction

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2657: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2620) StreamPartitioner is not properly initialized for shuffle and rebalance

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2620: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2838) Inconsistent use of URL and Path classes for resources

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2838: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

2021-12-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2899: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

2021-12-30 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 097cbda5db4e5a91cab71f2daff384bc3843c29c Azure:

  1   2   3   4   5   >