[jira] [Updated] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18675: -- Fix Version/s: 1.11.2 1.12.0 > Checkpoint not maintaining m

[GitHub] [flink] klion26 commented on a change in pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

klion26 commented on a change in pull request #13091: URL: https://github.com/apache/flink/pull/13091#discussion_r467544272 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -318,6 +318,7 @@ public CheckpointCoordina

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173755#comment-17173755 ] Congxian Qiu(klion26) commented on FLINK-18675: --- Seems there is a similar

[jira] [Commented] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

[ https://issues.apache.org/jira/browse/FLINK-18856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173754#comment-17173754 ] Congxian Qiu(klion26) commented on FLINK-18856: --- Seems this issue is simil

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 707c67f554cf59d2ba1e848e05cef0aea1fe7a89 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 707c67f554cf59d2ba1e848e05cef0aea1fe7a89 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zenfenan commented on a change in pull request #12823: FLINK-18013: Refactor Hadoop utils to a single module

zenfenan commented on a change in pull request #12823: URL: https://github.com/apache/flink/pull/12823#discussion_r467537692 ## File path: flink-hadoop-utils/src/main/java/org/apache/flink/hadoop/utils/HadoopUtils.java ## @@ -16,7 +16,7 @@ * limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 707c67f554cf59d2ba1e848e05cef0aea1fe7a89 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 707c67f554cf59d2ba1e848e05cef0aea1fe7a89 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lonelyGhostisdog commented on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

lonelyGhostisdog commented on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-671003019 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18766: Component/s: API / Python > Support add_sink() for Python DataStream API > ---

[jira] [Updated] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18765: Component/s: API / Python > Support map() and flat_map() for Python DataStream API > -

[jira] [Updated] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18763: Component/s: API / Python > Support basic TypeInformation for Python DataStream API >

[jira] [Updated] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18765: Fix Version/s: 1.12.0 > Support map() and flat_map() for Python DataStream API > -

[jira] [Updated] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18763: Fix Version/s: 1.12.0 > Support basic TypeInformation for Python DataStream API >

[jira] [Closed] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18764. --- Resolution: Resolved > Support from_collection for Python DataStream API > -

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18764: Component/s: API / Python > Support from_collection for Python DataStream API > --

[jira] [Commented] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173738#comment-17173738 ] Hequn Cheng commented on FLINK-18764: - Resolved in 1.12.0 via c966182ee051e4f21d8490

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18764: Fix Version/s: 1.12.0 > Support from_collection for Python DataStream API > --

[jira] [Closed] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18763. --- Resolution: Resolved > Support basic TypeInformation for Python DataStream API > ---

[jira] [Commented] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173737#comment-17173737 ] Hequn Cheng commented on FLINK-18763: - Resolved in 1.12.0 via ea9f44985ab387f1a234f2

[jira] [Closed] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18765. --- Resolution: Resolved > Support map() and flat_map() for Python DataStream API >

[jira] [Assigned] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18849: --- Assignee: Wei Zhong > Improve the code tabs of the Flink documents > --

[jira] [Commented] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173735#comment-17173735 ] Hequn Cheng commented on FLINK-18765: - Resolved in 1.12.0 via 862c9eb0f48f57f8f420d0

[GitHub] [flink] hequn8128 merged pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

hequn8128 merged pull request #13066: URL: https://github.com/apache/flink/pull/13066 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 t

[GitHub] [flink] dianfu edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

dianfu edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-671000990 What about also updating the existing documentation to use the functionality provided in this PR? It could provide an example on how to use the functionalities provided in

[GitHub] [flink] dianfu commented on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

dianfu commented on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-671000990 What about also updating the existing documentation to use the functionality provided in this PR? It could provide an example on how to use the functionalities provided in this P

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173734#comment-17173734 ] Dian Fu commented on FLINK-16720: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173733#comment-17173733 ] Dian Fu commented on FLINK-16947: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173730#comment-17173730 ] Dian Fu commented on FLINK-17274: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Updated] (FLINK-18859) ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout."

[ https://issues.apache.org/jira/browse/FLINK-18859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18859: Labels: test-stability (was: ) > ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnou

[jira] [Created] (FLINK-18859) ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout."

Dian Fu created FLINK-18859: --- Summary: ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout." Key: FLINK-18859 URL: https://issues.apac

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * 30c7fa20d57633b62a3e28ddf4256193e6439ec2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

flinkbot edited a comment on pull request #13091: URL: https://github.com/apache/flink/pull/13091#issuecomment-670949094 ## CI report: * 6339ff6f9b1acdb6f7cd163c9f866f77fd65c708 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * f85e2aed8e736a6b384063518d72ca0cb44869ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * f85e2aed8e736a6b384063518d72ca0cb44869ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

flinkbot edited a comment on pull request #13091: URL: https://github.com/apache/flink/pull/13091#issuecomment-670949094 ## CI report: * 6339ff6f9b1acdb6f7cd163c9f866f77fd65c708 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

flinkbot commented on pull request #13091: URL: https://github.com/apache/flink/pull/13091#issuecomment-670949094 ## CI report: * 6339ff6f9b1acdb6f7cd163c9f866f77fd65c708 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

flinkbot commented on pull request #13091: URL: https://github.com/apache/flink/pull/13091#issuecomment-670947770 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 pro

[jira] [Updated] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

[ https://issues.apache.org/jira/browse/FLINK-18856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18856: --- Labels: pull-request-available (was: ) > CheckpointCoordinator ignores checkpointing.min-pa

[GitHub] [flink] rkhachatryan opened a new pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

rkhachatryan opened a new pull request #13091: URL: https://github.com/apache/flink/pull/13091 ## What is the purpose of the change `CheckpointRequestDecider` uses lastCheckpointCompletionTime and pendingRequests.size to make a decision. While latter is currently checked under a l

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lonelyGhostisdog commented on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

lonelyGhostisdog commented on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670932013 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18858) Kinesis Flink SQL Connector

[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Waldemar Hummer updated FLINK-18858: Description: Hi all, as far as I can see in the [list of connectors|https://github.com/a

[jira] [Updated] (FLINK-18858) Kinesis Flink SQL Connector

[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Waldemar Hummer updated FLINK-18858: Summary: Kinesis Flink SQL Connector (was: Kinesis SQL Connector) > Kinesis Flink SQL Con

[jira] [Created] (FLINK-18858) Kinesis SQL Connector

Waldemar Hummer created FLINK-18858: --- Summary: Kinesis SQL Connector Key: FLINK-18858 URL: https://issues.apache.org/jira/browse/FLINK-18858 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN * 0f6489c64935c086c4cc980bc7f5cf858f85

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 14d53ae063d5875b5b4b104b4b6005b2f755446e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * abe0926d30fc18a2b0ba2834ba7ff74c4e669743 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-17503) Make memory configuration logging more user-friendly

[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-17503. - Resolution: Fixed Fixed via master: b856047f554856c1d910f34db01343076aa2f7d4 1.11.2: fab025d84a

[GitHub] [flink] tillrohrmann closed pull request #13086: [FLINK-17503][runtime] [logs] Refactored log output.

tillrohrmann closed pull request #13086: URL: https://github.com/apache/flink/pull/13086 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 g

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * abe0926d30fc18a2b0ba2834ba7ff74c4e669743 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API

[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173617#comment-17173617 ] Ying Z commented on FLINK-15719: Hi, [~tzulitai] , I want to help to modify the doc [1]

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * f85e2aed8e736a6b384063518d72ca0cb44869ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN * 97ee7a057155f9317a7890d405cb1f2ad363

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * cccf1bd4390323e70e998f819975fa9c29e0e4e5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * abe0926d30fc18a2b0ba2834ba7ff74c4e669743 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * cccf1bd4390323e70e998f819975fa9c29e0e4e5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

[ https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-18857: -- Description: Currently when we use code below {code:java} new ElasticSearchSink.Builder(...).b

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18822] [umbrella] Improve and complete Change Data Capture formats

flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * abe0926d30fc18a2b0ba2834ba7ff74c4e669743 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

[ https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173603#comment-17173603 ] Shengkai Fang commented on FLINK-18857: --- cc [~jark] > Invalid lambda deserializat

[jira] [Created] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink

Shengkai Fang created FLINK-18857: - Summary: Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink Key: FLINK-18857 URL: https://issues.apache.org/jira/browse/FLINK-18857

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN * 97ee7a057155f9317a7890d405cb1f2ad363

[jira] [Updated] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

[ https://issues.apache.org/jira/browse/FLINK-18856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18856: -- Issue Type: Bug (was: Improvement) > CheckpointCoordinator ignores checkpointing.min-

[jira] [Created] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

Roman Khachatryan created FLINK-18856: - Summary: CheckpointCoordinator ignores checkpointing.min-pause Key: FLINK-18856 URL: https://issues.apache.org/jira/browse/FLINK-18856 Project: Flink

[GitHub] [flink] SteNicholas commented on a change in pull request #13017: [FLINK-18258][hive] Implement SHOW PARTITIONS for Hive dialect

SteNicholas commented on a change in pull request #13017: URL: https://github.com/apache/flink/pull/13017#discussion_r467372833 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java ## @@ -465,6 +465,49 @@ pub