[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * e3269ea84366f74f9c04a6b3f7be723207958e1e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MartijnVisser commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

MartijnVisser commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-971329553 @maosuhan I can find a committer for a review. I do see two things currently standing out: 1. It would be good to make sure that the commits are meeting the commit

[jira] [Commented] (FLINK-24727) Running Kerberized YARN per-job on Docker test (no fat-jar) fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444996#comment-17444996 ] Arseniy Tashoyan commented on FLINK-24727: -- [~guoyangze] thank you for this poi

[GitHub] [flink-ml] HuangXingBo opened a new pull request #36: [FLINK-24933][ML] Support ML Python API

HuangXingBo opened a new pull request #36: URL: https://github.com/apache/flink-ml/pull/36 ## What is the purpose of the change This PR adds the ML python API. ## Brief change log This PR adds classes in the package of api/core and param. ## Verifying this change `test

[jira] [Commented] (FLINK-24894) Flink on k8s, open the HA mode based on KubernetesHaServicesFactory ，When I deleted the job, the config map created under the HA mechanism was not deleted.

[ https://issues.apache.org/jira/browse/FLINK-24894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444997#comment-17444997 ] Yangze Guo commented on FLINK-24894: > I think whether it is `delete deployment` or

[jira] [Updated] (FLINK-24933) Support ML Python API

[ https://issues.apache.org/jira/browse/FLINK-24933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24933: --- Labels: pull-request-available (was: ) > Support ML Python API > - > >

[jira] [Closed] (FLINK-24727) Running Kerberized YARN per-job on Docker test (no fat-jar) fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-24727. -- Resolution: Not A Problem > Running Kerberized YARN per-job on Docker test (no fat-jar) fails on Azure

[jira] [Created] (FLINK-24934) Python CI job fails with exit code 143

Matthias created FLINK-24934: Summary: Python CI job fails with exit code 143 Key: FLINK-24934 URL: https://issues.apache.org/jira/browse/FLINK-24934 Project: Flink Issue Type: Bug Comp

[jira] [Updated] (FLINK-24934) Python CI job fails with exit code 143

[ https://issues.apache.org/jira/browse/FLINK-24934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24934: - Labels: test-stability (was: ) > Python CI job fails with exit code 143 > -

[GitHub] [flink] xiangqiao123 opened a new pull request #17816: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

xiangqiao123 opened a new pull request #17816: URL: https://github.com/apache/flink/pull/17816 ## What is the purpose of the change Fix the spelling error of "parallism" in the document of SQL client. ## Brief change log - Replace "parallism" to "parallelism" in the document

[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r701627280 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/architecture/ArchitectureTests.java ## @@ -0,0 +1,100 @@ +/* + * Lice

[jira] [Commented] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445000#comment-17445000 ] Arseniy Tashoyan commented on FLINK-24851: -- [~renqs] thank you for your proposa

[GitHub] [flink] flinkbot commented on pull request #17816: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

flinkbot commented on pull request #17816: URL: https://github.com/apache/flink/pull/17816#issuecomment-971338462 ## CI report: * 251f55c950101b10454bfb031469e8cd643ea512 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17816: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17816: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink] xiangqiao123 opened a new pull request #17817: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

xiangqiao123 opened a new pull request #17817: URL: https://github.com/apache/flink/pull/17817 ## What is the purpose of the change Fix the spelling error of "parallism" in the document of SQL client. ## Brief change log - Replace "parallism" to "parallelism" in the document

[GitHub] [flink] flinkbot commented on pull request #17817: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink] flinkbot commented on pull request #17817: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

flinkbot commented on pull request #17817: URL: https://github.com/apache/flink/pull/17817#issuecomment-971344993 ## CI report: * 999fa42b698ec2d652d9e9b7c7db32b946231797 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17817: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink-statefun] igalshilman closed pull request #275: Use JDK 8 Optional instead of shaded Optional class from Guava.

igalshilman closed pull request #275: URL: https://github.com/apache/flink-statefun/pull/275 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issue

[jira] [Commented] (FLINK-24903) AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable

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

[jira] [Commented] (FLINK-24495) Python installdeps hangs

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

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445010#comment-17445010 ] Yun Gao commented on FLINK-24763: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail

[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445014#comment-17445014 ] Timo Walther commented on FLINK-24924: -- I agree that exceptions are not optimal for

[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r751018743 ## File path: flink-architecture-tests/src/test/resources/archunit.properties ## @@ -0,0 +1,24 @@ +# +# Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] Myasuka commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

Myasuka commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r751022321 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointSubsumeHelper.java ## @@ -46,18 +46,24 @@ class CheckpointSubsum

[GitHub] [flink] flinkbot edited a comment on pull request #17810: [BP-1.13][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

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

[GitHub] [flink] flinkbot edited a comment on pull request #17809: [BP-1.14][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17810: [BP-1.13][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

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

[jira] [Created] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

Yun Gao created FLINK-24935: --- Summary: Python module failed to compile due to "Could not create local repository" Key: FLINK-24935 URL: https://issues.apache.org/jira/browse/FLINK-24935 Project: Flink

[GitHub] [flink] Myasuka commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

Myasuka commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r751027356 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -1405,59 +1406,80 @@ private void declineCheckpoint(

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

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

[GitHub] [flink] flinkbot edited a comment on pull request #17809: [BP-1.14][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

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

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445019#comment-17445019 ] Yun Gao commented on FLINK-24935: - Hi [~chesnay] ~~ Might this issue also related to the

[jira] [Updated] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24800: Affects Version/s: 1.13.3 > BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure > -

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-24936) Python test_data_stream.py hangs on azure

Yun Gao created FLINK-24936: --- Summary: Python test_data_stream.py hangs on azure Key: FLINK-24936 URL: https://issues.apache.org/jira/browse/FLINK-24936 Project: Flink Issue Type: Bug Com

[GitHub] [flink] Airblader commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-971381711 I've rebased the PR and addressed most of the feedback; in particular, I've changed it to not check API annotations on the enclosing class anymore but on the classes directly.

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24936) Python test_data_stream.py hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445029#comment-17445029 ] Yun Gao commented on FLINK-24936: - Hi [~hxbks2ks] , could you also have a look at this i

[jira] [Assigned] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-15816: Assignee: Alexander Preuss > Limit the maximum length of the value of kubernetes.

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-24138) Automated architectural tests

[ https://issues.apache.org/jira/browse/FLINK-24138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24138: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Automated architectural

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[jira] [Created] (FLINK-24937) "kubernetes application HA test" hangs on azure

Yun Gao created FLINK-24937: --- Summary: "kubernetes application HA test" hangs on azure Key: FLINK-24937 URL: https://issues.apache.org/jira/browse/FLINK-24937 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 4527c1d3c6f5113b4e345845a2ec08a90954c8d5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24937) "kubernetes application HA test" hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445034#comment-17445034 ] Yun Gao commented on FLINK-24937: - Hi [~wangyang0918] ~ Are you convenient to have a loo

[GitHub] [flink] flinkbot edited a comment on pull request #17815: [FLINK-22702][tests] Add test data supplier which provide null timestamp field to kafka connector tests

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

[GitHub] [flink] akalash opened a new pull request #17818: [FLINK-24800][runtime] Changed the assert condition for checking buff…

akalash opened a new pull request #17818: URL: https://github.com/apache/flink/pull/17818 …er timeout disabling test ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/17758 ## Does this pull request potentially affect one of th

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17815: [FLINK-22702][tests] Add test data supplier which provide null timestamp field to kafka connector tests

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

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445039#comment-17445039 ] Anton Kalashnikov commented on FLINK-24800: --- [~gaoyunhaii] , yes, sure, I have

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot commented on pull request #17818: [FLINK-24800][runtime] Changed the assert condition for checking buff…

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

[GitHub] [flink] flinkbot commented on pull request #17818: [FLINK-24800][runtime] Changed the assert condition for checking buff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17818: [FLINK-24800][runtime] Changed the assert condition for checking buff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-24938) Checkpoint cleaner is closed before checkpoints are discarded

Roman Khachatryan created FLINK-24938: - Summary: Checkpoint cleaner is closed before checkpoints are discarded Key: FLINK-24938 URL: https://issues.apache.org/jira/browse/FLINK-24938 Project: Flin

[GitHub] [flink] maver1ck commented on pull request #17795: [FLINK-23230] Upgrade frontend-maven-plugin

maver1ck commented on pull request #17795: URL: https://github.com/apache/flink/pull/17795#issuecomment-971410229 @rmetzger I think the best solution for protoc will be adding this file to maven central. Do we have any friends in protobuf project ? https://developers.google.com/proto

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24938) Checkpoint cleaner is closed before checkpoints are discarded

[ https://issues.apache.org/jira/browse/FLINK-24938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445046#comment-17445046 ] Roman Khachatryan commented on FLINK-24938: --- Doesn't happen without FLINK-2364

[jira] [Updated] (FLINK-24938) Checkpoint cleaner is closed before checkpoints are discarded

[ https://issues.apache.org/jira/browse/FLINK-24938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-24938: -- Priority: Critical (was: Major) > Checkpoint cleaner is closed before checkpoints are

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24433) "No space left on device" in Azure e2e tests

[ https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445048#comment-17445048 ] Roman Khachatryan commented on FLINK-24433: --- Probably caused by FLINK-24938.

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17817: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17773: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for t…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17773: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for t…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17816: [FLINK-24922][docs] Backport fix spelling errors in the word "parallism"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 2471d36bd4c3a7a91c9651e32a836f3b045dbb7f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17799: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17799: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-24936) Python test_data_stream.py hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445063#comment-17445063 ] Huang Xingbo commented on FLINK-24936: -- [~gaoyunhaii] Thanks for the reporting this

[jira] [Assigned] (FLINK-24936) Python test_data_stream.py hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-24936: Assignee: Huang Xingbo > Python test_data_stream.py hangs on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] alpreu opened a new pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

alpreu opened a new pull request #17819: URL: https://github.com/apache/flink/pull/17819 ## What is the purpose of the change Kubernetes labels have a maximum length of 63 characters. The longest created label is {cluster-id}-resourcemanager-leader, therefore the cluster-id has to b

[jira] [Comment Edited] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-24921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444592#comment-17444592 ] Etienne Chauchot edited comment on FLINK-24921 at 11/17/21, 10:31 AM:

[GitHub] [flink-ml] zhipeng93 commented on pull request #34: [hotfix] fix nullpointer exception when broadcast variables are cleaned

zhipeng93 commented on pull request #34: URL: https://github.com/apache/flink-ml/pull/34#issuecomment-971445800 Hi @gaoyunhaii and @lindong28 , Thanks for the review. I have added a unit test. Please check out for `BroadcastVariableReceiverOperatorTest`. -- This is an automated me

[GitHub] [flink] flinkbot commented on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

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

[GitHub] [flink] flinkbot commented on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

flinkbot commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * 7f0824c6027e9fdd23acd9c6f742614662e2fba2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * baebf8dcd90968968de5d6363449fa39345b2f55 Azure: [FAILURE](https://dev.azure.com/apache-fl

  1   2   3   4   5   >