[GitHub] [flink] flinkbot edited a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoi

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024137450 ## CI report: * 2aff2a86a56cc8f9a893e43f178511184a4e397f Azure:

[jira] [Commented] (FLINK-25874) PyFlink package dependencies conflict

2022-01-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484095#comment-17484095 ] Nicholas Jiang commented on FLINK-25874: [~hflhmartin], IMO, you could contribute a PR to

[GitHub] [flink] flinkbot edited a comment on pull request #18462: [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18462: URL: https://github.com/apache/flink/pull/18462#issuecomment-1019928259 ## CI report: * d6151cbb9fe8146686df7b9eea917cc57a0559fe Azure:

[jira] [Updated] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

2022-01-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25152: --- Labels: pull-request-available (was: ) > FLIP-188: Introduce Built-in Dynamic Table

[GitHub] [flink-table-store] tsreaper opened a new pull request #16: [FLINK-25152] Implement overwrite in FlinkStoreCommitImpl

2022-01-28 Thread GitBox
tsreaper opened a new pull request #16: URL: https://github.com/apache/flink-table-store/pull/16 Overwrite is a useful transaction for batch jobs to completely update a partition for data correction. Currently FileStoreScanImpl doesn't implement this transaction so we need to implement

[jira] [Created] (FLINK-25876) Implement overwrite in FileStoreScanImpl

2022-01-28 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-25876: --- Summary: Implement overwrite in FileStoreScanImpl Key: FLINK-25876 URL: https://issues.apache.org/jira/browse/FLINK-25876 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * 226244d961f749ff16d7d8e8c33a4debc2170334 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 97ea9cbcb9b2fb6e4678af46dde55ff1593097f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoi

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024137450 ## CI report: * Unknown: [CANCELED](TBD) * 2aff2a86a56cc8f9a893e43f178511184a4e397f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoi

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024137450 ## CI report: * Unknown: [CANCELED](TBD) * 2aff2a86a56cc8f9a893e43f178511184a4e397f UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] TanYuxin-tyx removed a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to

2022-01-28 Thread GitBox
TanYuxin-tyx removed a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024141845 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] TanYuxin-tyx commented on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid b

2022-01-28 Thread GitBox
TanYuxin-tyx commented on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024837817 @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

[GitHub] [flink] SomberOfShadow commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2022-01-28 Thread GitBox
SomberOfShadow commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-1024832797 @gaoyunhaii Thanks for your reply. I found this dependency in maven by searching "flink" and then try one by one . It is really a hard process since yesterday . I

[jira] [Resolved] (FLINK-25767) Translation of page 'Working with State' is incomplete

2022-01-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-25767. -- Fix Version/s: 1.14.4 Resolution: Fixed Merged master:

[GitHub] [flink] Myasuka closed pull request #18460: [FLINK-25767][doc] Totally translated state.md into Chinese

2022-01-28 Thread GitBox
Myasuka closed pull request #18460: URL: https://github.com/apache/flink/pull/18460 -- 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:

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-01-28 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r794995618 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java ## @@ -271,7

[jira] [Created] (FLINK-25875) "StatsDReporter. FilterCharacters" for special processing of the characters are comprehensive enough

2022-01-28 Thread Jira
赵富午 created FLINK-25875: --- Summary: "StatsDReporter. FilterCharacters" for special processing of the characters are comprehensive enough Key: FLINK-25875 URL: https://issues.apache.org/jira/browse/FLINK-25875

[GitHub] [flink] Aitozi commented on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

2022-01-28 Thread GitBox
Aitozi commented on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1024821242 Thanks for your review, Happy Lunar New Year :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484059#comment-17484059 ] Lyn Zhang edited comment on FLINK-25695 at 1/29/22, 3:12 AM: - [~wenlong.lwl]

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484059#comment-17484059 ] Lyn Zhang edited comment on FLINK-25695 at 1/29/22, 3:12 AM: - [~wenlong.lwl]

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-31-967.png > TemporalJoin cause state leak in some cases >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-27-550.png > TemporalJoin cause state leak in some cases >

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Attachment: image-2022-01-29-11-11-11-705.png > TemporalJoin cause state leak in some cases >

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-01-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484059#comment-17484059 ] Lyn Zhang commented on FLINK-25695: --- [~wenlong.lwl] We can debug the unit test on 

[GitHub] [flink] flinkbot edited a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoi

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024137450 ## CI report: * 533bc50b38f2c9e5c755b2b77d2d0c12bd212715 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2022-01-28 Thread GitBox
gaoyunhaii commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-1024817265 Hi @SomberOfShadow it should be org.apache.flink:flink-connector-files:. We'll update the document about that. -- This is an automated message from the Apache Git

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

2022-01-28 Thread GitBox
wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024817221 I still believe this is a working fix. And no more complex than yours. They are on the same level. If the decision is made, then all I can say is that it takes a lot efforts

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

2022-01-28 Thread GitBox
wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024815295 If the `Complete` indicates the input future completion. (Thats a little different in my graph. In the graph it refers to the line the calls the `complete` on the result

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

2022-01-28 Thread GitBox
wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024815295 If the `Complete` indicates the input future completion. (Thats a little different in my graph. In the graph it refers to the line the calls the `complete` on the result

[GitHub] [flink] Sxnan commented on a change in pull request #18395: [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

2022-01-28 Thread GitBox
Sxnan commented on a change in pull request #18395: URL: https://github.com/apache/flink/pull/18395#discussion_r794988000 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java ## @@ -357,7 +357,8 @@ public void close() {

[GitHub] [flink] flinkbot edited a comment on pull request #18462: [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18462: URL: https://github.com/apache/flink/pull/18462#issuecomment-1019928259 ## CI report: * 452eb5b9035acbe052290af017632157406a2ba2 Azure:

[GitHub] [flink] SomberOfShadow commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2022-01-28 Thread GitBox
SomberOfShadow commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-1024814333 Hello, If I want to use org.apache.flink.connector.file.sink.FileSink which dependency I should import in my pomx.ml ? I can not find answer until now.

[jira] [Closed] (FLINK-25803) Implement partition and bucket filter of FileStoreScanImpl

2022-01-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25803. Resolution: Fixed master: b647508352eec54051550e2da9852fc144579824 > Implement partition and

[GitHub] [flink-table-store] JingsongLi merged pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

2022-01-28 Thread GitBox
JingsongLi merged pull request #14: URL: https://github.com/apache/flink-table-store/pull/14 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18462: [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18462: URL: https://github.com/apache/flink/pull/18462#issuecomment-1019928259 ## CI report: * 452eb5b9035acbe052290af017632157406a2ba2 Azure:

[jira] [Closed] (FLINK-25861) Move states of AbstractAvroBulkFormat into its reader

2022-01-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25861. Assignee: Caizhi Weng Resolution: Fixed master: b2011e59221aa40728748676c3a947f6f7ed3a60 >

[GitHub] [flink] zhuzhurk commented on pull request #18462: [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

2022-01-28 Thread GitBox
zhuzhurk commented on pull request #18462: URL: https://github.com/apache/flink/pull/18462#issuecomment-1024812248 Squashing and merging. -- 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

[jira] [Updated] (FLINK-25874) PyFlink package dependencies conflict

2022-01-28 Thread Martin Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Liu updated FLINK-25874: --- Description: I need to install PyFlink with some other libraries in a project, and I found there's

[jira] [Updated] (FLINK-25874) PyFlink package dependencies conflict

2022-01-28 Thread Martin Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Liu updated FLINK-25874: --- Description: I need to install PyFlink with some other libraries in a project, and I found there's

[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 97ea9cbcb9b2fb6e4678af46dde55ff1593097f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoi

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024137450 ## CI report: * 533bc50b38f2c9e5c755b2b77d2d0c12bd212715 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 97ea9cbcb9b2fb6e4678af46dde55ff1593097f8 Azure:

[GitHub] [flink] TanYuxin-tyx commented on pull request #18554: [FLINK-25860][network] Move read buffer allocation and output file creation to setup method for sort-shuffle result partition to avoid b

2022-01-28 Thread GitBox
TanYuxin-tyx commented on pull request #18554: URL: https://github.com/apache/flink/pull/18554#issuecomment-1024804719 @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

[GitHub] [flink] TanYuxin-tyx commented on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-28 Thread GitBox
TanYuxin-tyx commented on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024804232 @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

[jira] [Updated] (FLINK-25820) Introduce Table Store Flink Source

2022-01-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25820: --- Labels: pull-request-available (was: ) > Introduce Table Store Flink Source >

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

2022-01-28 Thread GitBox
tsreaper commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r794979738 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReader.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * 477c124ae1a19477f1a34f720f7baeea358f2a53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * 477c124ae1a19477f1a34f720f7baeea358f2a53 Azure:

[jira] [Created] (FLINK-25874) PyFlink package dependencies conflict

2022-01-28 Thread Martin Liu (Jira)
Martin Liu created FLINK-25874: -- Summary: PyFlink package dependencies conflict Key: FLINK-25874 URL: https://issues.apache.org/jira/browse/FLINK-25874 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * 1972fcf715b1e0ac2b4b433a0f366fde5eff4f82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1024689876 ## CI report: * 1e3b6a5f6914d4e91d7fe39aab84dcbe1eafc8cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * e135c4f6208fb5efe5c0c0640f90d82f588e244d Azure:

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

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 3afcff5b776774f579127bf1960875d4ae1a64f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18555: [FLINK-25492][state/changelog] Place metadata at the beginning of the in-memory state changelog

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18555: URL: https://github.com/apache/flink/pull/18555#issuecomment-1024279714 ## CI report: * adc44f9b1dfd20f8fd7ffb105611cb436257c824 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * e463ae39a706021b1d3a33439ecdb9e2b4412ca0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18465: [FLINK-24978][build] Upgrade ASM to 9.2

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18465: URL: https://github.com/apache/flink/pull/18465#issuecomment-1019940899 ## CI report: * e463ae39a706021b1d3a33439ecdb9e2b4412ca0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1024689876 ## CI report: * 1e3b6a5f6914d4e91d7fe39aab84dcbe1eafc8cf Azure:

[jira] [Closed] (FLINK-24339) Remove guard against CRLF split across chunks

2022-01-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24339. Resolution: Fixed master: 8f16fb071b9c1aa41cca25f7c8c7f81d79af4814 > Remove guard

[jira] [Comment Edited] (FLINK-25016) Bump netty to 4.1.70

2022-01-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483993#comment-17483993 ] Chesnay Schepler edited comment on FLINK-25016 at 1/28/22, 10:12 PM: -

[jira] [Closed] (FLINK-25016) Bump netty to 4.1.70

2022-01-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25016. Fix Version/s: 1.15.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #18466: [FLINK-25016][build] Upgrade to Netty 4.1.70

2022-01-28 Thread GitBox
zentol merged pull request #18466: URL: https://github.com/apache/flink/pull/18466 -- 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:

[GitHub] [flink] flinkbot commented on pull request #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-28 Thread GitBox
flinkbot commented on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1024689876 ## CI report: * 1e3b6a5f6914d4e91d7fe39aab84dcbe1eafc8cf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-28 Thread GitBox
flinkbot commented on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1024689341 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-23559) Randomize periodic materialisation interval in tests

2022-01-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23559: --- Labels: pull-request-available (was: ) > Randomize periodic materialisation interval in

[GitHub] [flink] rkhachatryan opened a new pull request #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-28 Thread GitBox
rkhachatryan opened a new pull request #18556: URL: https://github.com/apache/flink/pull/18556 Depends on #18552 (merged) and #18555 (under review). Please ignore all the commits except the last. cc: @curcur -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #18223: [FLINK-25423][state-processor-api] Enable loading state backend via configuration in state processor api

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18223: URL: https://github.com/apache/flink/pull/18223#issuecomment-1002308432 ## CI report: * c470184d9639c7879153fed7a55816446d395abb Azure:

[jira] [Resolved] (FLINK-25479) Changlog materialization with incremental checkpoint cannot work well in local tests

2022-01-28 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25479. --- Assignee: Roman Khachatryan Resolution: Fixed Merged as

[GitHub] [flink] rkhachatryan commented on pull request #18552: [FLINK-25479][rpc] Serialize TaskStateSnapshot when sending to JM from TM

2022-01-28 Thread GitBox
rkhachatryan commented on pull request #18552: URL: https://github.com/apache/flink/pull/18552#issuecomment-1024663663 Build failure unrelated (FLINK-25771), build [passed](https://dev.azure.com/khachatryanroman/flink/_build/results?buildId=1351=results) for private branch, merging. --

[GitHub] [flink] rkhachatryan merged pull request #18552: [FLINK-25479][rpc] Serialize TaskStateSnapshot when sending to JM from TM

2022-01-28 Thread GitBox
rkhachatryan merged pull request #18552: URL: https://github.com/apache/flink/pull/18552 -- 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:

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

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 0a425720f8936008cd7982a1481f23459e0491f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1020104543 ## CI report: * db2210c8ec60f9a5608d3fdea53a753d623d896d Azure:

[GitHub] [flink] pnowojski commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

2022-01-28 Thread GitBox
pnowojski commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1024637122 > I would say without volatile notifyCompletion see a obsolete future could happen. But, before entry the notifyCompletion, the input's future is already completed. In the

[GitHub] [flink] flinkbot edited a comment on pull request #18542: [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18542: URL: https://github.com/apache/flink/pull/18542#issuecomment-1023357489 ## CI report: * 4a09114fa22331aa07ee938603098c4e5c9dd0f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 6c5e8781c20bcee5fb18d0f8524dd970c5ff2d9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18543: [FLINK-25431] Implement a file-based JobResultStore

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18543: URL: https://github.com/apache/flink/pull/18543#issuecomment-1023364026 ## CI report: * f62cd51ea1ab1d39834611586a7509fc0ecab7c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 162d5e33edf01aae1fe06fa72542b763d2b65e56 Azure:

[jira] [Resolved] (FLINK-25024) Add ChangelogBackend documentation

2022-01-28 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25024. --- Resolution: Fixed f74a28b81447955c4d696c5d11494137adc12aaa > Add ChangelogBackend

[GitHub] [flink] rkhachatryan merged pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

2022-01-28 Thread GitBox
rkhachatryan merged pull request #18431: URL: https://github.com/apache/flink/pull/18431 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18431: URL: https://github.com/apache/flink/pull/18431#issuecomment-1017952324 ## CI report: * 480987ed4a563ed50095cba131e5de92f05fda63 Azure:

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

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 59f46a383a5cca968faf82f8c260217649a6f825 Azure:

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

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 59f46a383a5cca968faf82f8c260217649a6f825 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * 176a27c492a14373848921916e7ab64dcabf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * 3160e1d83687a15d9a602922aecc2d38f6891afa Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r794708252 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java ## @@ -17,95 +17,173 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-XXXX][connectors] Change scope of connector-base dependency to provided

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * 4ce7d031d7a36e2a96261578ee896fc852bedc03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * 3b172e6de001227e6e383b5e7431eed5b529f8be Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
gaoyunhaii commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1024526229 Very thanks @fapaul for the update and explanation! For the `execute` method, sorry I has some misunderstandings initially that the clear happens before compile

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * 3b172e6de001227e6e383b5e7431eed5b529f8be Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r794777402 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -19,250

[GitHub] [flink] flinkbot edited a comment on pull request #18552: [FLINK-25479][rpc] Serialize TaskStateSnapshot when sending to JM from TM

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18552: URL: https://github.com/apache/flink/pull/18552#issuecomment-1024068426 ## CI report: * 6467efa71bec285b6679b9c3b696f85ae26c74dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18535: [FLINK-25835][Runtime]Adding Task Initialization Logs

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18535: URL: https://github.com/apache/flink/pull/18535#issuecomment-1023143132 ## CI report: * b3ed1f16efd880ec6dbcbca692b432f243f9d883 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18479: URL: https://github.com/apache/flink/pull/18479#issuecomment-1020172062 ## CI report: * 1c866a4904ff05c59f38cf4e873f5523186605b9 Azure:

[jira] [Updated] (FLINK-25871) "License Check failed" on AZP

2022-01-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25871: - Issue Type: Technical Debt (was: Bug) > "License Check failed" on AZP >

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * 3b172e6de001227e6e383b5e7431eed5b529f8be Azure:

[GitHub] [flink] JingGe commented on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-28 Thread GitBox
JingGe commented on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1024509107 Thanks @Airblader. I have pushed the changes and squashed the commits. Please help merging it. Thanks. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] fapaul commented on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
fapaul commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1024508742 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18439: [hotfix][table-planner][test] Test fromValues() watermark propagation

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18439: URL: https://github.com/apache/flink/pull/18439#issuecomment-1018359750 ## CI report: * 7aed7db01be40edf33c1ad44917b381a33eb36f4 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
JingGe commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r793812428 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/Committables.java ## @@ -0,0 +1,52 @@ +/*

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-28 Thread GitBox
gaoyunhaii commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r794763092 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/SinkTransformationTranslator.java ## @@ -7,7 +7,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18462: [FLINK-25045][runtime] Introduce AdaptiveBatchScheduler

2022-01-28 Thread GitBox
flinkbot edited a comment on pull request #18462: URL: https://github.com/apache/flink/pull/18462#issuecomment-1019928259 ## CI report: * 452eb5b9035acbe052290af017632157406a2ba2 Azure:

  1   2   3   4   5   6   7   >