[GitHub] [flink] flinkbot edited a comment on pull request #15882: [FLINK-22574] Adaptive Scheduler: Fix cancellation while in Restarting state

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15882: URL: https://github.com/apache/flink/pull/15882#issuecomment-836740251 ## CI report: * 89dbb13e84a099927fe0eb1ac7e5e7bcdb79f08f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * ffab5d3ccda17f4ec347528d851ba39d5a59cca6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 16e61d4169ad70214e2d8a503e100ac566b6800e Azure:

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-10 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342087#comment-17342087 ] Galen Warren commented on FLINK-19481: -- I wanted to check in here. Should I wait until this

[GitHub] [flink] rkhachatryan commented on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
rkhachatryan commented on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-837356465 Thanks for reviewing @sjwiesman. I've removed `WaitingFunction`, `WaitingWindowAssigner` and unnecessary now arguments, PTAL. -- This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 16e61d4169ad70214e2d8a503e100ac566b6800e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 16e61d4169ad70214e2d8a503e100ac566b6800e Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15858: [WIP][FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
rkhachatryan commented on a change in pull request #15858: URL: https://github.com/apache/flink/pull/15858#discussion_r629647704 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/SavepointTestBase.java ## @@ -56,16 +64,33

[GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * b979ed53178630a7bf881d3e021993d0ae803449 Azure:

[GitHub] [flink-web] AHeise opened a new pull request #446: Added release 1.12.4

2021-05-10 Thread GitBox
AHeise opened a new pull request #446: URL: https://github.com/apache/flink-web/pull/446 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15886: [hotfix] [docs] Fix typo in k8s docs

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15886: URL: https://github.com/apache/flink/pull/15886#issuecomment-837066644 ## CI report: * c78d77a6effa454bc4c4a02b05d9037b5f4c5059 Azure:

[jira] [Closed] (FLINK-22481) RocksDBStateBackendWindowITCase times out on Azure

2021-05-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-22481. - Resolution: Duplicate Closing as duplicate of FLINK-22067. >

[jira] [Assigned] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

2021-05-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-22067: - Assignee: Roman Khachatryan >

[GitHub] [flink] flinkbot edited a comment on pull request #15884: [FLINK-22266] Fix stop-with-savepoint operation in AdaptiveScheduler

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15884: URL: https://github.com/apache/flink/pull/15884#issuecomment-836859750 ## CI report: * e28e6f0fae5e5688149d613d93aa621d24923de4 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-05-10 Thread GitBox
rkhachatryan commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r629693902 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWindowReaderITCase.java ## @@ -348,24

[jira] [Closed] (FLINK-22353) Add CPU metrics of TaskManager and JobManager into Flink WebUI

2021-05-10 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal closed FLINK-22353. --- Resolution: Abandoned > Add CPU metrics of TaskManager and JobManager into Flink WebUI >

[jira] [Updated] (FLINK-22618) Fix incorrect free resource metrics of task managers

2021-05-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22618: --- Labels: pull-request-available (was: ) > Fix incorrect free resource metrics of task

[jira] [Closed] (FLINK-22523) TUMBLE TVF should throw helpful exception when specifying second interval parameter

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22523. --- Resolution: Fixed Fixed in - master: 3d201442cee372856f2c919dee38d29bf08b77f4 - release-1.13:

[jira] [Updated] (FLINK-22523) TUMBLE TVF should throw helpful exception when specifying second interval parameter

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22523: Component/s: Table SQL / API > TUMBLE TVF should throw helpful exception when specifying second interval

[jira] [Comment Edited] (FLINK-22525) The zone id in exception message should be GMT+08:00 instead of GMT+8:00

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341718#comment-17341718 ] Jark Wu edited comment on FLINK-22525 at 5/11/21, 4:23 AM: --- Fixed in -

[GitHub] [flink] flinkbot edited a comment on pull request #15664: [FLINK-22155][table-api][parser] fix explain insert or select two case,sql convert separate selection.

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15664: URL: https://github.com/apache/flink/pull/15664#issuecomment-822263432 ## CI report: * ed977f98e6c66aba497c85379927cd677461c6c2 Azure:

[GitHub] [flink] wuchong merged pull request #15806: [FLINK-22313][table-planner-blink] Redundant CAST in plan when selecting window start and window end in window agg

2021-05-10 Thread GitBox
wuchong merged pull request #15806: URL: https://github.com/apache/flink/pull/15806 -- 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. For queries about this service,

[GitHub] [flink] wuchong commented on pull request #15803: [FLINK-22523][table-planner-blink] TUMBLE TVF should throw helpful exception when specifying second interval parameter

2021-05-10 Thread GitBox
wuchong commented on pull request #15803: URL: https://github.com/apache/flink/pull/15803#issuecomment-837655471 The failed test case is not related to this PR. Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-22313) Redundant CAST in plan when selecting window start and window end in window agg

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22313. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 3c342c93ea56a326e13fd3caf48b6a46e6604de7 >

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * ae350a48301e7483cdd6b2856f674e7628b80bce Azure:

[GitHub] [flink] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
YikSanChan commented on a change in pull request #15813: URL: https://github.com/apache/flink/pull/15813#discussion_r629809218 ## File path: flink-python/src/main/java/org/apache/flink/python/util/DecompressUtils.java ## @@ -0,0 +1,12 @@ +package org.apache.flink.python.util;

[GitHub] [flink] flinkbot commented on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

2021-05-10 Thread GitBox
flinkbot commented on pull request #15887: URL: https://github.com/apache/flink/pull/15887#issuecomment-837684409 ## CI report: * 791cd20391c7bc64f3d2ca77ba6d73c56c3acc79 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

2021-05-10 Thread GitBox
flinkbot commented on pull request #15888: URL: https://github.com/apache/flink/pull/15888#issuecomment-837682553 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] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
YikSanChan commented on a change in pull request #15813: URL: https://github.com/apache/flink/pull/15813#discussion_r629337523 ## File path: flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java ## @@ -326,9 +327,21 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-829753030 ## CI report: * f1a3fdefdb723f03636fb7a73a185b69bd93b57d Azure:

[GitHub] [flink] wuchong merged pull request #15874: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

2021-05-10 Thread GitBox
wuchong merged pull request #15874: URL: https://github.com/apache/flink/pull/15874 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15858: [FLINK-22067][tests] Wait for vertices to start using API

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15858: URL: https://github.com/apache/flink/pull/15858#issuecomment-834799316 ## CI report: * 536a3f0e34b5840b019cf571cf85d4459b52c3a7 UNKNOWN * 2740e54220264d446e0640b4ec46eaf0b4bb1db0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[GitHub] [flink] wangyang0918 opened a new pull request #15889: [BP-1.13][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
wangyang0918 opened a new pull request #15889: URL: https://github.com/apache/flink/pull/15889 Backport #14012 to release-1.13. -- 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] cshuo commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

2021-05-10 Thread GitBox
cshuo commented on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-837638785 > @cshuo Can you take a look to test failure? I'm checking... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
YikSanChan commented on a change in pull request #15813: URL: https://github.com/apache/flink/pull/15813#discussion_r629808846 ## File path: flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java ## @@ -326,9 +327,21 @@ private void

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

2021-05-10 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342268#comment-17342268 ] Junfan Zhang commented on FLINK-22534: -- Any ideas on it? [~lirui] [~mapohl] > Set delegation

[jira] [Closed] (FLINK-22525) The zone id in exception message should be GMT+08:00 instead of GMT+8:00

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22525. --- Assignee: Leonard Xu Resolution: Fixed > The zone id in exception message should be GMT+08:00 instead

[GitHub] [flink] rmetzger commented on a change in pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-05-10 Thread GitBox
rmetzger commented on a change in pull request #15728: URL: https://github.com/apache/flink/pull/15728#discussion_r629857371 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWindowReaderITCase.java ## @@ -348,24

[jira] [Updated] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

2021-05-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22464: --- Component/s: Runtime / Coordination >

[jira] [Created] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

2021-05-10 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22624: -- Summary: Default resource allocation strategy will allocate more pending task managers than demand Key: FLINK-22624 URL: https://issues.apache.org/jira/browse/FLINK-22624

[jira] [Assigned] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

2021-05-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22624: Assignee: Yangze Guo > Default resource allocation strategy will allocate more pending

[GitHub] [flink] flinkbot commented on pull request #15889: [BP-1.13][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
flinkbot commented on pull request #15889: URL: https://github.com/apache/flink/pull/15889#issuecomment-837835694 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] wangyang0918 opened a new pull request #15890: [BP-1.12][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
wangyang0918 opened a new pull request #15890: URL: https://github.com/apache/flink/pull/15890 Backport #14012 to release-1.12. -- 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] paul8263 opened a new pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

2021-05-10 Thread GitBox
paul8263 opened a new pull request #15887: URL: https://github.com/apache/flink/pull/15887 ## What is the purpose of the change Fix incorrect free resource metrics of task managers ## Brief change log Changed method "getFreeResourceOf" in

[GitHub] [flink] flinkbot commented on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

2021-05-10 Thread GitBox
flinkbot commented on pull request #15887: URL: https://github.com/apache/flink/pull/15887#issuecomment-837644601 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] wuchong merged pull request #15803: [FLINK-22523][table-planner-blink] TUMBLE TVF should throw helpful exception when specifying second interval parameter

2021-05-10 Thread GitBox
wuchong merged pull request #15803: URL: https://github.com/apache/flink/pull/15803 -- 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. For queries about this service,

[GitHub] [flink] KarmaGYZ commented on pull request #15812: remove slotpoolImpl

2021-05-10 Thread GitBox
KarmaGYZ commented on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-837699726 @tillrohrmann Hi, I think now we can remove the `SlotManagerImpl`. As this PR is large enough, we can move that effort out of the scope of this PR. WDYT? If so, I'd like to

[GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-829753030 ## CI report: * f1a3fdefdb723f03636fb7a73a185b69bd93b57d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15888: URL: https://github.com/apache/flink/pull/15888#issuecomment-837704287 ## CI report: * 327482a8fb754651f21f27eb7d3e277c4861 Azure:

[GitHub] [flink] hehuiyuan commented on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-05-10 Thread GitBox
hehuiyuan commented on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-837753830 > Hi @hehuiyuan , I mean you could include the parquet file in your PR, and use it in the test. The file should contain minimum data that is sufficient to reproduce the

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * f2fe08ada02c5c9e20ed397163d3ab7a34594994 UNKNOWN * ce0e120bbd288c77f3dd5e2befc30b117123e75f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
wangyang0918 commented on pull request #14012: URL: https://github.com/apache/flink/pull/14012#issuecomment-837827708 Rebase latest master since FLINK-22577 is merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #15890: [BP-1.12][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
flinkbot commented on pull request #15890: URL: https://github.com/apache/flink/pull/15890#issuecomment-83783 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 edited a comment on pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #14012: URL: https://github.com/apache/flink/pull/14012#issuecomment-724568763 ## CI report: * ec6bda8748f9a4ab81fe59cb1e41beeb53df263e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-829753030 ## CI report: * fd020167f550e9c4c3b70d0a1dbe9d35b600d7cf Azure:

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

2021-05-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342242#comment-17342242 ] Xintong Song commented on FLINK-19481: -- [~galenwarren], I think the RecoverableWriter

[jira] [Updated] (FLINK-22618) Fix incorrect free resource metrics of task managers

2021-05-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22618: --- Labels: pull-request-available starter (was: pull-request-available) > Fix incorrect free resource

[GitHub] [flink] KarmaGYZ opened a new pull request #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

2021-05-10 Thread GitBox
KarmaGYZ opened a new pull request #15888: URL: https://github.com/apache/flink/pull/15888 …k managers to fulfill requirement in DefaultResourceAllocationStrategy ## What is the purpose of the change *(For example: This pull request makes task deployment go through the

[jira] [Updated] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

2021-05-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22624: --- Labels: pull-request-available (was: ) > Default resource allocation strategy will

[GitHub] [flink] flinkbot edited a comment on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15887: URL: https://github.com/apache/flink/pull/15887#issuecomment-837684409 ## CI report: * 791cd20391c7bc64f3d2ca77ba6d73c56c3acc79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * ae350a48301e7483cdd6b2856f674e7628b80bce Azure:

[GitHub] [flink] flinkbot commented on pull request #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

2021-05-10 Thread GitBox
flinkbot commented on pull request #15888: URL: https://github.com/apache/flink/pull/15888#issuecomment-837704287 ## CI report: * 327482a8fb754651f21f27eb7d3e277c4861 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15848: URL: https://github.com/apache/flink/pull/15848#issuecomment-833490569 ## CI report: * 99a21fd00339a5c0f0700c493095c745ac1935c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15664: [FLINK-22155][table-api][parser] fix explain insert or select two case,sql convert separate selection.

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15664: URL: https://github.com/apache/flink/pull/15664#issuecomment-822263432 ## CI report: * ed977f98e6c66aba497c85379927cd677461c6c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * f2fe08ada02c5c9e20ed397163d3ab7a34594994 UNKNOWN * ce0e120bbd288c77f3dd5e2befc30b117123e75f Azure:

[GitHub] [flink] flinkbot commented on pull request #15890: [BP-1.12][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
flinkbot commented on pull request #15890: URL: https://github.com/apache/flink/pull/15890#issuecomment-837869596 ## CI report: * a3b9bae7fb2a6e4e8b65c3a78b0c1d12591a44ce UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15889: [BP-1.13][FLINK-17857]Make K8s e2e tests could run on Mac

2021-05-10 Thread GitBox
flinkbot commented on pull request #15889: URL: https://github.com/apache/flink/pull/15889#issuecomment-837869382 ## CI report: * e2e703b430cbdfd387de4e2437a981307731027b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

2021-05-10 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341677#comment-17341677 ] lynn1.zhang commented on FLINK-21345: - Hi [~Leonard Xu], I have updated this PR. >

[jira] [Commented] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341684#comment-17341684 ] Guowei Ma commented on FLINK-21431: ---

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341688#comment-17341688 ] Guowei Ma commented on FLINK-22559: ---

[jira] [Commented] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

2021-05-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341689#comment-17341689 ] Nicholas Jiang commented on FLINK-22413: [~rmetzger], I have added the JobGraph.jobType to the

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341700#comment-17341700 ] Guowei Ma commented on FLINK-22593: ---

[GitHub] [flink] flinkbot commented on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs

2021-05-10 Thread GitBox
flinkbot commented on pull request #15873: URL: https://github.com/apache/flink/pull/15873#issuecomment-836246953 ## CI report: * 35b7df969a633d3ae010a369636ef6f5a20f0b57 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15872: [FLINK-21469] Implement advanceToEndOfEventTime for MultipleInputStreamTask

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15872: URL: https://github.com/apache/flink/pull/15872#issuecomment-836202475 ## CI report: * e383716ae9a94a138f347a8bdf35795bc65a206d Azure:

[jira] [Created] (FLINK-22614) Provide build artifacts for YARN e2e tests

2021-05-10 Thread Matthias (Jira)
Matthias created FLINK-22614: Summary: Provide build artifacts for YARN e2e tests Key: FLINK-22614 URL: https://issues.apache.org/jira/browse/FLINK-22614 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #15873: URL: https://github.com/apache/flink/pull/15873#issuecomment-836246953 ## CI report: * 35b7df969a633d3ae010a369636ef6f5a20f0b57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 86af5b748a70ba9bb997d654b6f76c0f3a343bc0 Azure:

[jira] [Comment Edited] (FLINK-19670) Query on a view of temporal join throws ParseException

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341740#comment-17341740 ] Jark Wu edited comment on FLINK-19670 at 5/10/21, 7:26 AM: --- [~yr], you can

[jira] [Commented] (FLINK-19670) Query on a view of temporal join throws ParseException

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341740#comment-17341740 ] Jark Wu commented on FLINK-19670: - [~yr], you can copy {{SqlSnapshot}} to Flink under directory

[jira] [Commented] (FLINK-9844) PackagedProgram does not close URLClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341739#comment-17341739 ] Bo Cui commented on FLINK-9844: --- yes Do you want to fix it? [~chesnay] > PackagedProgram does not close

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341743#comment-17341743 ] Jark Wu commented on FLINK-22113: - cc [~godfreyhe] > UniqueKey constraint is lost with multiple sources

[GitHub] [flink] AHeise commented on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-05-10 Thread GitBox
AHeise commented on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-836298080 > > Thank you very much for you contribution! The Pulsar connector has been highly anticipated by quite a lot of users, so this PR will have a big impact. > > The design

[jira] [Comment Edited] (FLINK-9844) PackagedProgram does not close URLClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341739#comment-17341739 ] Bo Cui edited comment on FLINK-9844 at 5/10/21, 7:30 AM: - yes Do you want to fix

[jira] [Commented] (FLINK-22614) Provide build artifacts for YARN e2e tests

2021-05-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341754#comment-17341754 ] Chesnay Schepler commented on FLINK-22614: -- [~mapohl] let's include the yarn logs also in the

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341761#comment-17341761 ] Guowei Ma commented on FLINK-22480: ---

[GitHub] [flink] flinkbot commented on pull request #15876: [Flink-22588][docs] Removed the unnecessary space between the number …

2021-05-10 Thread GitBox
flinkbot commented on pull request #15876: URL: https://github.com/apache/flink/pull/15876#issuecomment-836351341 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] HuangXingBo opened a new pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

2021-05-10 Thread GitBox
HuangXingBo opened a new pull request #15877: URL: https://github.com/apache/flink/pull/15877 ## What is the purpose of the change *This pull request will restructure the coders in PyFlink* ## Brief change log - *After restructuring the coders in PyFlink, there

[GitHub] [flink] flinkbot commented on pull request #15878: [hotfix] Disable broken savepoint tests tracked in FLINK-22067

2021-05-10 Thread GitBox
flinkbot commented on pull request #15878: URL: https://github.com/apache/flink/pull/15878#issuecomment-836424814 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

[jira] [Commented] (FLINK-9844) PackagedProgram does not close URLClassLoader

2021-05-10 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341685#comment-17341685 ] Bo Cui commented on FLINK-9844: --- The reason for this exception is that when userCodeClassLoader is closed,

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-05-10 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * 4834e5537c314f51245ead122d8cded98997e758 Azure:

[jira] [Commented] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341695#comment-17341695 ] Guowei Ma commented on FLINK-22464: ---

[jira] [Updated] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22464: -- Description:

[jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

2021-05-10 Thread Xu Guangheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341696#comment-17341696 ] Xu Guangheng commented on FLINK-22113: -- Hello [~jark], The PR was submitted half month ago, can

[GitHub] [flink-web] twalthr merged pull request #445: [hotfix] Fix formatting and invalid link in 1.13 release announcement

2021-05-10 Thread GitBox
twalthr merged pull request #445: URL: https://github.com/apache/flink-web/pull/445 -- 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. For queries about this service,

[jira] [Commented] (FLINK-22588) There is a configuration description error in the document

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341731#comment-17341731 ] Jark Wu commented on FLINK-22588: - Both are fine, but we can also keep them consistent here. > There

[jira] [Commented] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure

2021-05-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341730#comment-17341730 ] Guowei Ma commented on FLINK-22595: ---

[jira] [Updated] (FLINK-22588) There is a configuration description error in the document

2021-05-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22588: Component/s: Table SQL / Ecosystem Documentation Connectors / FileSystem

[jira] [Commented] (FLINK-9844) PackagedProgram does not close URLClassLoader

2021-05-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341745#comment-17341745 ] Chesnay Schepler commented on FLINK-9844: - Not in the way you proposed. I wrote down some

  1   2   3   4   5   >