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

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

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

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

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 #15664: [FLINK-22155][table-api][parser] fix explain insert or select two case,sql convert separate selection.

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 #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

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

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

[ 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 >

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

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

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

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 commented on pull request #15889: [BP-1.13][FLINK-17857]Make K8s e2e tests could run on Mac

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

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] wangyang0918 opened a new pull request #15889: [BP-1.13][FLINK-17857]Make K8s e2e tests could run on Mac

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] wangyang0918 commented on pull request #14012: [FLINK-17857][test] Make K8s e2e tests could run on Mac

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 edited a comment on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

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.

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 #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

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 #15858: [FLINK-22067][tests] Wait for vertices to start using API

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

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

[ 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 -

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

[ 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] wuchong merged pull request #15874: [FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT-08:00

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 #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

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 #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

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] hehuiyuan commented on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

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 #15813: [FLINK-22519][flink-python] support tar python archives

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

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

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

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

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

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

[ 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

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

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 #15877: [FLINK-22612][python] Restructure the coders in PyFlink

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 edited a comment on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

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 #15813: [FLINK-22519][flink-python] support tar python archives

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

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

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 commented on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

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 edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

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

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 #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

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

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] YikSanChan commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar python archives

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] [Updated] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

[ 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] KarmaGYZ opened a new pull request #15888: [FLINK-22624][runtime] Utilize the remain resource of new pending tas…

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] [Assigned] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand

[ 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

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

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] [Closed] (FLINK-22523) TUMBLE TVF should throw helpful exception when specifying second interval parameter

[ 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

[ 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

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

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] wuchong commented on pull request #15803: [FLINK-22523][table-planner-blink] TUMBLE TVF should throw helpful exception when specifying second interval parameter

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

[ 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] wuchong merged pull request #15806: [FLINK-22313][table-planner-blink] Redundant CAST in plan when selecting window start and window end in window agg

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,

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

[ 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] flinkbot commented on pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

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

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

[ 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

[GitHub] [flink] paul8263 opened a new pull request #15887: [FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…

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] cshuo commented on pull request #15848: [FLINK-22586][table] Improve the precision dedivation for decimal ari…

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

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

[ 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] [Closed] (FLINK-22353) Add CPU metrics of TaskManager and JobManager into Flink WebUI

[ 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 >

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

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 #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

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

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

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 #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

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] [Assigned] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ 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 >

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

[ 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. >

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

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-web] AHeise opened a new pull request #446: Added release 1.12.4

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 #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

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

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

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 #15858: [WIP][FLINK-22067][tests] Wait for vertices to start using API

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 #15886: [hotfix] [docs] Fix typo in k8s docs

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

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

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

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

[ 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] flinkbot edited a comment on pull request #15886: [hotfix] [docs] Fix typo in k8s docs

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

[jira] [Commented] (FLINK-22133) SplitEmumerator does not provide checkpoint id in snapshot

[ https://issues.apache.org/jira/browse/FLINK-22133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342063#comment-17342063 ] Thomas Weise commented on FLINK-22133: -- Hi Becket, I think the suggestion from Stephan would be the

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

flinkbot commented on pull request #15886: URL: https://github.com/apache/flink/pull/15886#issuecomment-837066644 ## CI report: * c78d77a6effa454bc4c4a02b05d9037b5f4c5059 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342055#comment-17342055 ] Robert Metzger commented on FLINK-20498:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] rmetzger commented on pull request #15883: [FLINK-22556][ci] Extend JarFileChecker to search for traces of incompatible licenses

rmetzger commented on pull request #15883: URL: https://github.com/apache/flink/pull/15883#issuecomment-837057278 I tested the functionality of this change here:

[GitHub] [flink] rmetzger commented on a change in pull request #15883: [FLINK-22556][ci] Extend JarFileChecker to search for traces of incompatible licenses

rmetzger commented on a change in pull request #15883: URL: https://github.com/apache/flink/pull/15883#discussion_r629561789 ## File path: tools/ci/java-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/JarFileChecker.java ## @@ -134,6 +140,91 @@ private static

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

flinkbot commented on pull request #15886: URL: https://github.com/apache/flink/pull/15886#issuecomment-837043855 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-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342044#comment-17342044 ] Matthias commented on FLINK-22613: --

[GitHub] [flink] kbohinski opened a new pull request #15886: [hotfix] [docs] Fix typo in k8s docs

kbohinski opened a new pull request #15886: URL: https://github.com/apache/flink/pull/15886 -- 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

[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

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 #15873: [FLINK-22413][runtime-web] Hide Checkpointing page in the UI for batch jobs

flinkbot edited a comment on pull request #15873: URL: https://github.com/apache/flink/pull/15873#issuecomment-836246953 ## CI report: * 162666773fa72d571a08b1b0d55e49355f2dcca6 Azure:

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

flinkbot commented on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * ffab5d3ccda17f4ec347528d851ba39d5a59cca6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * 61748f522c99468ce7c5b3dd37b11319f3c7b977 Azure:

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

flinkbot commented on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-836966255 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] [Updated] (FLINK-22376) SequentialChannelStateReaderImpl may recycle buffer twice

[ https://issues.apache.org/jira/browse/FLINK-22376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22376: --- Labels: pull-request-available (was: ) > SequentialChannelStateReaderImpl may recycle

[GitHub] [flink] akalash opened a new pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed as para

akalash opened a new pull request #15885: URL: https://github.com/apache/flink/pull/15885 ## What is the purpose of the change *PR organizes the order of recycling of buffer inside of RecoveredChannelStateHandler * ## Brief change log - *BufferBuilder is able

[GitHub] [flink] flinkbot edited a comment on pull request #15880: [BP-1.13][FLINK-22566][test] Adds NodeManager log extraction to YARN-related e2e tests

flinkbot edited a comment on pull request #15880: URL: https://github.com/apache/flink/pull/15880#issuecomment-836553806 ## CI report: * 632e575bb187fbde54ef7660f341feda590494a9 Azure:

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

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * 61748f522c99468ce7c5b3dd37b11319f3c7b977 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15881: [BP-1.12][FLINK-22566][test] Adds NodeManager log extraction to YARN-related e2e tests

flinkbot edited a comment on pull request #15881: URL: https://github.com/apache/flink/pull/15881#issuecomment-836553947 ## CI report: * 52fa6b853cb34075be048e970d5195e48481dd84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

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

sjwiesman commented on a change in pull request #15858: URL: https://github.com/apache/flink/pull/15858#discussion_r629482995 ## 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] sjwiesman commented on a change in pull request #15858: [WIP][FLINK-22067][tests] Wait for vertices to start using API

sjwiesman commented on a change in pull request #15858: URL: https://github.com/apache/flink/pull/15858#discussion_r629482322 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/SavepointTestBase.java ## @@ -33,15 +35,21 @@

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

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341983#comment-17341983 ] Seth Wiesman commented on FLINK-22067: -- [~roman_khachatryan] I agree FLINK-22481 is likely a

[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

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 4f4ce33b815167b23c8ee3dc8d65e1e97cc0cd07 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

tillrohrmann commented on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-836866043 Feel free to also open the PRs for the backports so that we get CI. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] tillrohrmann commented on a change in pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

tillrohrmann commented on a change in pull request #15832: URL: https://github.com/apache/flink/pull/15832#discussion_r628363445 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/persistence/PossibleInconsistentStateException.java ## @@ -0,0 +1,36 @@ +/* + *

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

flinkbot edited a comment on pull request #15882: URL: https://github.com/apache/flink/pull/15882#issuecomment-836740251 ## CI report: * 36372cc0645878382994753f450bbb7ace00142f Azure:

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

flinkbot commented on pull request #15884: URL: https://github.com/apache/flink/pull/15884#issuecomment-836859750 ## CI report: * e28e6f0fae5e5688149d613d93aa621d24923de4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15883: [FLINK-22556][ci] Extend JarFileChecker to search for traces of incompatible licenses

flinkbot edited a comment on pull request #15883: URL: https://github.com/apache/flink/pull/15883#issuecomment-836815823 ## CI report: * d6632569dd2adc8ce52aee2fd2f728425137e0f0 Azure:

  1   2   3   4   5   >