[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

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

[GitHub] [flink] flinkbot edited a comment on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

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

[jira] [Closed] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19400. --- Resolution: Fixed > Removed unused BufferPoolOwner > -- > >

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205297#comment-17205297 ] Arvid Heise commented on FLINK-19400: - Merged into master as part of FLINK-16972. >

[jira] [Updated] (FLINK-16972) Fix non-blocking output availability logic.

[ https://issues.apache.org/jira/browse/FLINK-16972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16972: Affects Version/s: 1.12.0 > Fix non-blocking output availability logic. >

[jira] [Commented] (FLINK-16972) Fix non-blocking output availability logic.

[ https://issues.apache.org/jira/browse/FLINK-16972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205295#comment-17205295 ] Arvid Heise commented on FLINK-16972: - Merged into master as e17dbab24f4f71c5472d272

[GitHub] [flink-web] shudhanshubisht08 opened a new pull request #383: Update .gitignore

shudhanshubisht08 opened a new pull request #383: URL: https://github.com/apache/flink-web/pull/383 Nice work. Can I Do some Changes in this This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] AHeise merged pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink-web] shudhanshubisht08 opened a new pull request #382: Update .gitignore

shudhanshubisht08 opened a new pull request #382: URL: https://github.com/apache/flink-web/pull/382 I want to make some contribution to this project This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

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

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Issue Type: Improvement (was: Bug) > Job would wait sometime(~10 min) before failover if so

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Priority: Critical (was: Blocker) > Job would wait sometime(~10 min) before failover if som

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Fix Version/s: (was: 1.11.3) > Job would wait sometime(~10 min) before failover if some

[GitHub] [flink] flinkbot commented on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

flinkbot commented on pull request #13528: URL: https://github.com/apache/flink/pull/13528#issuecomment-701909456 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-19477) Translate page 'python_table_api_connectors' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19477: --- Labels: pull-request-available (was: ) > Translate page 'python_table_api_connectors' into

[GitHub] [flink] wangxlong opened a new pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

wangxlong opened a new pull request #13528: URL: https://github.com/apache/flink/pull/13528 ## What is the purpose of the change Translate page "python_table_api_connectors" into Chinese ## Brief change log Translate page "python_table_api_connectors" into Chinese

[GitHub] [flink-web] Saurabh299 opened a new pull request #381: improve doc.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN * 4d2d57b8c2f6810c03d284fdd5807b81a2b5

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN * 4d2d57b8c2f6810c03d284fdd5807b81a2b5

[GitHub] [flink] senegalo commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

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

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[jira] [Comment Edited] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205177#comment-17205177 ] Dian Fu edited comment on FLINK-19483 at 10/1/20, 1:02 AM: --- It

[jira] [Issue Comment Deleted] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Comment: was deleted (was: cc [~zhongwei]) > PyFlink Table end-to-end test failed with "FileExistsError:

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205177#comment-17205177 ] Dian Fu commented on FLINK-19483: - It seems because the directory "/home/vsts/work/1/s/

[jira] [Updated] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Summary: PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/w

[jira] [Updated] (FLINK-19483) PyFlink Table end-to-end test failed with "The current user does not have write permissions to a required path"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Summary: PyFlink Table end-to-end test failed with "The current user does not have write permissions to a

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205172#comment-17205172 ] Dian Fu commented on FLINK-19388: - [~azagrebin] Thanks a lot for the quick fix! > Strea

[jira] [Updated] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19484: Issue Type: Bug (was: Improvement) > Kubernetes pyflink application test failed with "error executing jso

[jira] [Commented] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

[ https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205169#comment-17205169 ] Dian Fu commented on FLINK-19469: - [~gyfora] Agree with you. I think we can leave this i

[jira] [Commented] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205166#comment-17205166 ] Dian Fu commented on FLINK-19484: - cc [~csq] > Kubernetes pyflink application test fail

[jira] [Updated] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19484: Component/s: Tests > Kubernetes pyflink application test failed with "error executing jsonpath > "{range

[jira] [Created] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

Dian Fu created FLINK-19484: --- Summary: Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang" Key: FLINK-19484

[jira] [Updated] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19484: Labels: test-stability (was: ) > Kubernetes pyflink application test failed with "error executing jsonpat

[jira] [Created] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'"

Dian Fu created FLINK-19483: --- Summary: PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'" Key: FLINK-19483 URL: https://issues.

[jira] [Updated] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Issue Type: Bug (was: Improvement) > PyFlink Table end-to-end test failed with "FileExistsError: [Errno 1

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205162#comment-17205162 ] Dian Fu commented on FLINK-19483: - cc [~zhongwei] > PyFlink Table end-to-end test faile

[jira] [Updated] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Component/s: Tests > PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File > exists

[jira] [Updated] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19483: Labels: test-stability (was: ) > PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] F

[GitHub] [flink] becketqin commented on a change in pull request #13512: [FLINK-19457][core] Add a number sequence generating source for the New Source API.

becketqin commented on a change in pull request #13512: URL: https://github.com/apache/flink/pull/13512#discussion_r497868184 ## File path: flink-core/src/test/java/org/apache/flink/api/connector/source/lib/NumberSequenceSourceTest.java ## @@ -0,0 +1,91 @@ +/* + * Licensed to

[GitHub] [flink] dianfu commented on a change in pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

dianfu commented on a change in pull request #13525: URL: https://github.com/apache/flink/pull/13525#discussion_r497865775 ## File path: flink-connectors/flink-connector-hbase-2.2/pom.xml ## @@ -45,6 +45,9 @@ under the License. maven-surefire-plu

[GitHub] [flink] becketqin commented on pull request #13512: [FLINK-19457][core] Add a number sequence generating source for the New Source API.

becketqin commented on pull request #13512: URL: https://github.com/apache/flink/pull/13512#issuecomment-701705339 @StephanEwen Personally speaking, I think usually people either put both API and implementation in the same package or completely separate them. The weird part here is that we

[jira] [Comment Edited] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205146#comment-17205146 ] Dian Fu edited comment on FLINK-19447 at 9/30/20, 11:40 PM:

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205146#comment-17205146 ] Dian Fu commented on FLINK-19447: - [~mgergely] Have attached another two screenshots. Ho

[jira] [Issue Comment Deleted] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Comment: was deleted (was: !screenshot-2.png! ) > HBaseConnectorITCase.HBaseTestingClusterAutoStarter fa

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Attachment: screenshot-3.png > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19447: Attachment: screenshot-2.png > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205141#comment-17205141 ] Dian Fu commented on FLINK-19447: - !screenshot-2.png! > HBaseConnectorITCase.HBaseTes

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] AHeise commented on a change in pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

AHeise commented on a change in pull request #13499: URL: https://github.com/apache/flink/pull/13499#discussion_r497817669 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java ## @@ -296,6 +296,11 @@ private MemorySegment re

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17205020#comment-17205020 ] Dominik Wosiński commented on FLINK-2491: - Ah, sure :) No worries, Yeah it is qui

[GitHub] [flink] flinkbot edited a comment on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

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

[jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19482: - Fix Version/s: 1.11.0 > OrcRowInputFormat does not define serialVersionUID > ---

[jira] [Created] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

hailong wang created FLINK-19482: Summary: OrcRowInputFormat does not define serialVersionUID Key: FLINK-19482 URL: https://issues.apache.org/jira/browse/FLINK-19482 Project: Flink Issue Type

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

Ben Augarten created FLINK-19481: Summary: Add support for a flink native GCS FileSystem Key: FLINK-19481 URL: https://issues.apache.org/jira/browse/FLINK-19481 Project: Flink Issue Type: Imp

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

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

[GitHub] [flink] flinkbot edited a comment on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

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

[GitHub] [flink] flinkbot edited a comment on pull request #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

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

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

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

[GitHub] [flink] flinkbot edited a comment on pull request #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

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

[GitHub] [flink] flinkbot commented on pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

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

[GitHub] [flink] flinkbot commented on pull request #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

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

[GitHub] [flink] flinkbot commented on pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

flinkbot commented on pull request #13527: URL: https://github.com/apache/flink/pull/13527#issuecomment-701489008 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 #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

flinkbot commented on pull request #13526: URL: https://github.com/apache/flink/pull/13526#issuecomment-701487982 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] azagrebin opened a new pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

azagrebin opened a new pull request #13527: URL: https://github.com/apache/flink/pull/13527 NOT FOR REVIEW. This is just to run CI with AWS credentials. The PR will be closed afterwards. This is an automated message fro

[jira] [Updated] (FLINK-19426) Streaming File Sink end-to-end test sometimes fails with "Could not assign resource ... to current execution ..."

[ https://issues.apache.org/jira/browse/FLINK-19426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19426: --- Labels: pull-request-available test-stability (was: test-stability) > Streaming File Sink e

[GitHub] [flink] azagrebin opened a new pull request #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

azagrebin opened a new pull request #13526: URL: https://github.com/apache/flink/pull/13526 NOT FOR REVIEW. This is just to run CI with AWS credentials. The PR will be closed afterwards. This is an automated message fro

[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

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

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204827#comment-17204827 ] Till Rohrmann commented on FLINK-19401: --- No, the 3 operator chains are recovered t

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204824#comment-17204824 ] Till Rohrmann commented on FLINK-19154: --- At the moment there is no easy distinctio

[GitHub] [flink] tillrohrmann commented on a change in pull request #13511: [FLINK-19388][coordination] Do not remove logical slots from SharedSlot if it is releasing

tillrohrmann commented on a change in pull request #13511: URL: https://github.com/apache/flink/pull/13511#discussion_r497610206 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharedSlot.java ## @@ -215,10 +218,19 @@ public void release(Throwable

[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

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

[GitHub] [flink] flinkbot edited a comment on pull request #13509: [FLINK-19317] Make EventTime the default TimeCharacteristic

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

[GitHub] [flink] flinkbot edited a comment on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

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

[jira] [Comment Edited] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204791#comment-17204791 ] Kostas Kloudas edited comment on FLINK-19154 at 9/30/20, 2:57 PM:

[GitHub] [flink-statefun] tzulitai closed pull request #161: Add Haskell SDK to 3rd party SDKs

tzulitai closed pull request #161: URL: https://github.com/apache/flink-statefun/pull/161 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

[GitHub] [flink] flinkbot commented on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

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

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204791#comment-17204791 ] Kostas Kloudas commented on FLINK-19154: Yes, I agree. This is what we have to d

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

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

[GitHub] [flink-statefun] tzulitai commented on pull request #161: Add Haskell SDK to 3rd party SDKs

tzulitai commented on pull request #161: URL: https://github.com/apache/flink-statefun/pull/161#issuecomment-701443973 Thanks @tdbgamer! Glad to have the Haskell SDK on the list of 3rd party SDKs. Merging this now ... This

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204790#comment-17204790 ] Till Rohrmann commented on FLINK-19154: --- I think the causing problem is {code} 2

[GitHub] [flink-web] rmetzger opened a new pull request #380: Add flink-shaded 12.0 release

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

[jira] [Commented] (FLINK-19456) sql client execute insert sql with comment ahead

[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204780#comment-17204780 ] ledong Lin commented on FLINK-19456: Yes, I think it should work like that.:D [~ZhuS

[GitHub] [flink] flinkbot edited a comment on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

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

[GitHub] [flink] flinkbot edited a comment on pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

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

[GitHub] [flink] HuangXingBo commented on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

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

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204778#comment-17204778 ] Miklos Gergely commented on FLINK-19447: [~dian.fu] , [~gyfora] , [~bamrabi] it

[GitHub] [flink] flinkbot commented on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

flinkbot commented on pull request #13525: URL: https://github.com/apache/flink/pull/13525#issuecomment-701430487 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] [Closed] (FLINK-19258) Fix the wrong example of "csv.line-delimiter" in CSV documentation

[ https://issues.apache.org/jira/browse/FLINK-19258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19258. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master : 237b5e02ba2ee43d8d33b6f5c0fa04710b3088be >

[jira] [Commented] (FLINK-19443) runtime function 'splitIndex'

[ https://issues.apache.org/jira/browse/FLINK-19443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204775#comment-17204775 ] Jark Wu commented on FLINK-19443: - Agree with [~nicholasjiang]. Null arguments are filte

[GitHub] [flink] wuchong merged pull request #13524: [FLINK-19258][docs] Fix the wrong example of "csv.line-delimiter" in CSV documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN * 4d2d57b8c2f6810c03d284fdd5807b81a2b5

[jira] [Updated] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

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

[jira] [Commented] (FLINK-19452) statistics of group by CDC data is always 1

[ https://issues.apache.org/jira/browse/FLINK-19452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204774#comment-17204774 ] Jark Wu commented on FLINK-19452: - Got. Thank you [~tinny]. > statistics of group by CD

  1   2   3   4   >