[GitHub] [flink-statefun-playground] tillrohrmann commented on pull request #25: [FLINK-26155] Add Playground ingress/egress that allows to ingest and consume messages via curl

2022-02-15 Thread GitBox
tillrohrmann commented on pull request #25: URL: https://github.com/apache/flink-statefun-playground/pull/25#issuecomment-1041213981 Merging this PR now. -- 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

[jira] [Commented] (FLINK-26151) inprogressfileRecoverable not be clean up after restoring the bucket

2022-02-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493046#comment-17493046 ] Yun Gao commented on FLINK-26151: - Thanks [~lovewin99] for reporting the issue! I'll hav

[GitHub] [flink] flinkbot edited a comment on pull request #18786: [hotfix][test] add support for field assignability

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18786: URL: https://github.com/apache/flink/pull/18786#issuecomment-1040539589 ## CI report: * 6fa8c290984d253ef7408abb6d23d49370c0f4b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-25290) Add table source and sink test suite in connector testing framework

2022-02-15 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 7:57 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18749: URL: https://github.com/apache/flink/pull/18749#issuecomment-1038986916 ## CI report: * 75d766a6e13db2b93605a3d7f13fee0abb56aca8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25290) Add table source and sink test suite in connector testing framework

2022-02-15 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493045#comment-17493045 ] Hang Ruan commented on FLINK-25290: --- [~syhily] The feature about the dataStream sink t

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * Unknown: [CANCELED](TBD) * 2ffd741d316346745bd8fe754bb02a73cbf0d0ba Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[jira] [Updated] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

2022-02-15 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26174: Affects Version/s: (was: 1.15.0) > KinesisDataStreamsSink.restoreWriter failed due to Architecture Vio

[jira] [Updated] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

2022-02-15 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26174: Affects Version/s: 1.15.0 > KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation > --

[GitHub] [flink] XComp commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
XComp commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r807639403 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/LocallyCleanableResource.java ## @@ -24,12 +24,11 @@ import java.uti

[GitHub] [flink] XComp commented on a change in pull request #18749: [FLINK-26117] Adds GloballyCleanableResource to JobManagerMetricGroup

2022-02-15 Thread GitBox
XComp commented on a change in pull request #18749: URL: https://github.com/apache/flink/pull/18749#discussion_r807639403 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/LocallyCleanableResource.java ## @@ -24,12 +24,11 @@ import java.uti

[jira] [Assigned] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

2022-02-15 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-26174: --- Assignee: Jing Ge > KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation > ---

[GitHub] [flink] ruanhang1993 commented on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
ruanhang1993 commented on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1041208998 > This is closed in the commit https://github.com/apache/flink/commit/57e3f03ccd719ed772c983ba335517d95f8f3e6a. You could find it in the events at this PR.

[GitHub] [flink] flinkbot edited a comment on pull request #18786: [hotfix][test] add support for field assignability

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18786: URL: https://github.com/apache/flink/pull/18786#issuecomment-1040539589 ## CI report: * 6fa8c290984d253ef7408abb6d23d49370c0f4b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 1e885d354bb156b1598601a9fa6d06cb7972e15c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 62fe6e2dd02a8d41517588b4fe302678d7875ec2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-26166) flink-runtime-web fails to compile if newline is cr lf

2022-02-15 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-26166: - Assignee: Gabor Somogyi > flink-runtime-web fails to compile if newline is cr lf >

[GitHub] [flink] JingGe commented on pull request #18774: [FLINK-25701][kafka] Add Flink API annotation to all connector classes based on the new Source/Sink design

2022-02-15 Thread GitBox
JingGe commented on pull request #18774: URL: https://github.com/apache/flink/pull/18774#issuecomment-1041207940 @fapaul would you like to merge this PR? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] pltbkd commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1041207282 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-26175) Make local cleanup being called in global cleanup situations

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26175: -- Description: We introduce new interfaces for local cleanup and global cleanup in FLINK-25432.

[jira] [Created] (FLINK-26175) Make local cleanup being called in global cleanup situations

2022-02-15 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26175: - Summary: Make local cleanup being called in global cleanup situations Key: FLINK-26175 URL: https://issues.apache.org/jira/browse/FLINK-26175 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18790: [FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18790: URL: https://github.com/apache/flink/pull/18790#issuecomment-1041025841 ## CI report: * f11bc4e5c50b90d5410db10c4ae532ca888a3a48 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 62fe6e2dd02a8d41517588b4fe302678d7875ec2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

2022-02-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26033: --- Affects Version/s: 1.12.7 1.11.6 > In KafkaConnector, when 'sink.part

[GitHub] [flink] flinkbot edited a comment on pull request #18790: [FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18790: URL: https://github.com/apache/flink/pull/18790#issuecomment-1041025841 ## CI report: * f11bc4e5c50b90d5410db10c4ae532ca888a3a48 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MartijnVisser commented on pull request #18790: [FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

2022-02-15 Thread GitBox
MartijnVisser commented on pull request #18790: URL: https://github.com/apache/flink/pull/18790#issuecomment-1041200353 @flinkbot run azure -- 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 sp

[jira] [Resolved] (FLINK-26015) FileSystemJobResultStore fails to access Minio

2022-02-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26015. --- Fix Version/s: 1.15.0 Resolution: Fixed master: * [d62be2e4465f93a21d077acc34972358

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp merged pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-15 Thread GitBox
XComp merged pull request #18692: URL: https://github.com/apache/flink/pull/18692 -- 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: issues-unsubscr.

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18794: [hotfix] Refactor the name of builder method

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18794: URL: https://github.com/apache/flink/pull/18794#issuecomment-1041190242 ## CI report: * a2c7b54f6037934901e399450cb2b71d1bf82175 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot commented on pull request #18794: [hotfix] Refactor the name of builder method

2022-02-15 Thread GitBox
flinkbot commented on pull request #18794: URL: https://github.com/apache/flink/pull/18794#issuecomment-1041190232 -- 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 unsubs

[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core

2022-02-15 Thread Aiden Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493033#comment-17493033 ] Aiden Gong commented on FLINK-25537: Hi,[~renqs] ,I am willing to resolve this.Can y

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] leo65535 opened a new pull request #18794: [hotfix] Refactor the name of builder method

2022-02-15 Thread GitBox
leo65535 opened a new pull request #18794: URL: https://github.com/apache/flink/pull/18794 ## What is the purpose of the change It's better use `build` in builder class. ## Verifying this change This change is a trivial rework / code cleanup without any test

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request #59: [hotfix] Fix version and branch info of docs in release 2.0

2022-02-15 Thread GitBox
yunfengzhou-hub opened a new pull request #59: URL: https://github.com/apache/flink-ml/pull/59 ## What is the purpose of the change Fix version and branch info of docs in release 2.0 ## Brief change log - Change version number from `2.0.0` to `2.0` - Change references to Flin

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18721: URL: https://github.com/apache/flink/pull/18721#issuecomment-1035971992 ## CI report: * 16573d2282376f1f4049a18d285fbece4569683b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 896383d69cc23dc38fa73e124538644de4db15aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18721: URL: https://github.com/apache/flink/pull/18721#issuecomment-1035971992 ## CI report: * 16573d2282376f1f4049a18d285fbece4569683b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] wangyang0918 merged pull request #18450: [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader

2022-02-15 Thread GitBox
wangyang0918 merged pull request #18450: URL: https://github.com/apache/flink/pull/18450 -- 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: issues-un

[GitHub] [flink] wangyang0918 commented on pull request #18450: [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader

2022-02-15 Thread GitBox
wangyang0918 commented on pull request #18450: URL: https://github.com/apache/flink/pull/18450#issuecomment-1041180839 Merging this PR now. -- 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 sp

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request #58: [FLINK-26100][docs] Set up Flink ML Document Website

2022-02-15 Thread GitBox
yunfengzhou-hub opened a new pull request #58: URL: https://github.com/apache/flink-ml/pull/58 ## What is the purpose of the change - Set up Flink ML Document Website ## Brief change log - Add `docs` folder containing all configurations needed to setup the framework for

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * cdab9f7d140989714263bc2a4e1a0908bb444a12 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * cdab9f7d140989714263bc2a4e1a0908bb444a12 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] wanglijie95 commented on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-15 Thread GitBox
wanglijie95 commented on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1041174285 @flinkbot run azure -- 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 spec

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * cdab9f7d140989714263bc2a4e1a0908bb444a12 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] imaffe commented on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-02-15 Thread GitBox
imaffe commented on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1041169942 Curious is this merged ? I saw the status is closed but not merged, did it get merged in somewhere else @leonardBang ? Thanks~ -- This is an automated message from the Apache

[GitHub] [flink] MrWhiteSike commented on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
MrWhiteSike commented on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1041169110 [@RocMarshal](https://github.com/RocMarshal) Thanks for the suggestions. All comments so far are resolved and keep other original contents. Please review it again. -- T

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 1ee0663ffc935ad0e96f39b7adb98216eb560fb1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18778: [FLINK-26150][connector/pulsar] enable requestTimeoutMs configuration.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18778: URL: https://github.com/apache/flink/pull/18778#issuecomment-1040181291 ## CI report: * ec04c584781c49959082f49aadaa447ae0313b9d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 7a1348562f2d0b0c83f0cb7a3cb9931987ad24e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

2022-02-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493028#comment-17493028 ] Yun Gao commented on FLINK-26174: - cc [~fpaul] > KinesisDataStreamsSink.restoreWriter f

[jira] [Created] (FLINK-26174) KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation

2022-02-15 Thread Yun Gao (Jira)
Yun Gao created FLINK-26174: --- Summary: KinesisDataStreamsSink.restoreWriter failed due to Architecture Violation Key: FLINK-26174 URL: https://issues.apache.org/jira/browse/FLINK-26174 Project: Flink

[GitHub] [flink] pltbkd commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
pltbkd commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1041157963 > Thanks @pltbkd for the update! I try to fixed some tests. Also, could you have a look that if the two `*StateHandle` needs `snapshotState` ? Cleaning up of the state is

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 7a1348562f2d0b0c83f0cb7a3cb9931987ad24e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] GOODBOY008 commented on pull request #18778: [FLINK-26150][connector/pulsar] enable requestTimeoutMs configuration.

2022-02-15 Thread GitBox
GOODBOY008 commented on pull request #18778: URL: https://github.com/apache/flink/pull/18778#issuecomment-1041156008 @flinkbot run azure -- 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 speci

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18792: [FLINK-26172][docs] sql doc improvements

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18792: URL: https://github.com/apache/flink/pull/18792#issuecomment-1041051783 ## CI report: * 7eae7b10d497d3f007e9fd142c0419e28b040b85 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18718: URL: https://github.com/apache/flink/pull/18718#issuecomment-1035898573 ## CI report: * 7a1348562f2d0b0c83f0cb7a3cb9931987ad24e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-26152) Translate the page of SQL/queries/WITH clause

2022-02-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26152: --- Assignee: wenyibo > Translate the page of SQL/queries/WITH clause > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18450: [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18450: URL: https://github.com/apache/flink/pull/18450#issuecomment-1019472598 ## CI report: * cddbb308222430731528284ee045e25f19966563 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

2022-02-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493019#comment-17493019 ] Jark Wu commented on FLINK-18652: - [~afedulov], I closed this issue. [~mzz_q] please re

[jira] [Closed] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

2022-02-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18652. --- Resolution: Not A Problem > JDBCAppendTableSink to ClickHouse (data always repeating) > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Closed] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

2022-02-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-15455. -- Resolution: Fixed > Enable TCP connection reuse across multiple jobs. > --

[jira] [Commented] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

2022-02-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493018#comment-17493018 ] Yangze Guo commented on FLINK-15455: master: c0cca2e16430758950627068306c7bf6056c98c

[jira] [Commented] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large

2022-02-15 Thread Kyle (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493017#comment-17493017 ] Kyle commented on FLINK-25670: -- Hi Igal, with increasing "client_max_size", the memory size

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] KarmaGYZ closed pull request #18417: [FLINK-15455][network] Enabled tcp connection reuse across multi jobs.

2022-02-15 Thread GitBox
KarmaGYZ closed pull request #18417: URL: https://github.com/apache/flink/pull/18417 -- 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: issues-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051889 ## CI report: * 15943be65b1842a4f6568133435196081e01ce9d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 2ceef38711255737eba93cdb7803b41fcf87c49a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051889 ## CI report: * 15943be65b1842a4f6568133435196081e01ce9d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * d6511df39e333c9f57e2dee94504d7769c66a1a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 05023f3a4797bc482c773722fab5d90b4fc4d102 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 38e9475b405df3004c00b216fe2edf552cb8c029 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * 3e49b45d560685de73d09b81154065515f9e15ca Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

2022-02-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493009#comment-17493009 ] Yang Wang commented on FLINK-26142: --- I would like to enable the github actions and add

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][coordination] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * ebf17a50343fe5cd13cfddb1154428753b4d29b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18791: [FLINK-26169][runtime] There is a typo in the annotation for the WatermarkAlignmentParams class

2022-02-15 Thread GitBox
flinkbot edited a comment on pull request #18791: URL: https://github.com/apache/flink/pull/18791#issuecomment-1041038528 ## CI report: * ebf17a50343fe5cd13cfddb1154428753b4d29b3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26171) pyFlink -py options has issue with path that starts with //

2022-02-15 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493008#comment-17493008 ] Xuannan Su commented on FLINK-26171: After some research, I found that the leading t

[jira] [Assigned] (FLINK-26171) pyFlink -py options has issue with path that starts with //

2022-02-15 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-26171: Assignee: Huang Xingbo > pyFlink -py options has issue with path that starts with // > --

  1   2   3   4   5   6   7   8   9   10   >