[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 64754bd5f4e51ea7679b67cceb7b49e0e86808f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 2830d54980890a81ca8ad4a3e3c27bebc6448bca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 5d6e58afe6c78826c56e5cd802f2f3ef10a0133f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 ## CI report: * 7cc1ae5427d4e5571af7a0842d49dea1445760ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * d12c135ebf7dcc56e9c26695ecc2a2c3f4853176 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * e3a0766cb731672fd5be68b79bf380c8577ea068 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-29 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d Azure:

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2022-01-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484307#comment-17484307 ] Yuan Mei edited comment on FLINK-21564 at 1/30/22, 5:52 AM: [~pedrosbs]

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2022-01-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484307#comment-17484307 ] Yuan Mei commented on FLINK-21564: -- [~pedrosbs] assigned to you It seems there is already an accepted

[jira] [Assigned] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2022-01-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-21564: Assignee: Pedro Silva > CommonTestUtils.waitUntilCondition could fail with condition meets

[GitHub] [flink] flinkbot edited a comment on pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18561: URL: https://github.com/apache/flink/pull/18561#issuecomment-1025075470 ## CI report: * 8fd795009f123e2b799a50735a616231a5bbbc87 Azure:

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

2022-01-29 Thread GitBox
curcur edited a comment on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1025075490 I've accepted the PR with some comments. LGTM You can decide with your own judgement whether to keep the last two or not. -- This is an automated message from

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

2022-01-29 Thread GitBox
curcur commented on pull request #18556: URL: https://github.com/apache/flink/pull/18556#issuecomment-1025075490 I've accepted the PR with some comments. You can decide with your own judgement whether to keep the last two or not. -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

2022-01-29 Thread GitBox
flinkbot commented on pull request #18561: URL: https://github.com/apache/flink/pull/18561#issuecomment-1025075470 ## CI report: * 8fd795009f123e2b799a50735a616231a5bbbc87 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-01-29 Thread GitBox
curcur commented on a change in pull request #18556: URL: https://github.com/apache/flink/pull/18556#discussion_r795130597 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -129,6 +129,16 @@

[GitHub] [flink] flinkbot commented on pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

2022-01-29 Thread GitBox
flinkbot commented on pull request #18561: URL: https://github.com/apache/flink/pull/18561#issuecomment-1025075373 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-25874) PyFlink package dependencies conflict

2022-01-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25874: --- Labels: pull-request-available (was: ) > PyFlink package dependencies conflict >

[GitHub] [flink] martin-liu opened a new pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

2022-01-29 Thread GitBox
martin-liu opened a new pull request #18561: URL: https://github.com/apache/flink/pull/18561 ## What is the purpose of the change [FLINK-25874](https://issues.apache.org/jira/browse/FLINK-25874) reported that PyFlink dependency of `python-dateutil==2.8.0` is [very

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 093354d13fa9fd10047d81e830e58d985586fad3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * baad6b1b8c7c4ba297e0068f5b0bc5ccb18e5e9f Azure:

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 ## CI report: * 093354d13fa9fd10047d81e830e58d985586fad3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * bf542cd367ad218778d1eb093da1ee3e1c68728d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * bf542cd367ad218778d1eb093da1ee3e1c68728d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 691570671b202f17d971b2e694973a9299cd4649 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 691570671b202f17d971b2e694973a9299cd4649 Azure:

[jira] [Commented] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

2022-01-29 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484303#comment-17484303 ] Shammon commented on FLINK-25445: - Sure, thanks [~zuston] to take this issue :) > TaskExecutor always

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

2022-01-29 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-25874. Resolution: Not A Problem This is not about the incompatibility of pyflink dependencies, but that

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * e3a0766cb731672fd5be68b79bf380c8577ea068 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18496: URL: https://github.com/apache/flink/pull/18496#issuecomment-1020867632 ## CI report: * e3a0766cb731672fd5be68b79bf380c8577ea068 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 ## CI report: * 21354e64e46b565c0866975aeaf90fc14f1f2ca5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 ## CI report: * 21354e64e46b565c0866975aeaf90fc14f1f2ca5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * baad6b1b8c7c4ba297e0068f5b0bc5ccb18e5e9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * baad6b1b8c7c4ba297e0068f5b0bc5ccb18e5e9f Azure:

[GitHub] [flink] RocMarshal commented on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
RocMarshal commented on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1025049954 @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] flinkbot edited a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * Unknown: [CANCELED](TBD) * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d 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-29 Thread GitBox
flinkbot edited a comment on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1024043680 ## CI report: * Unknown: [CANCELED](TBD) * 8813b2eec4b0004ac1a180c92ce6fbc5604d898d UNKNOWN Bot commands The @flinkbot bot supports the

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

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

[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-29 Thread GitBox
TanYuxin-tyx commented on pull request #18551: URL: https://github.com/apache/flink/pull/18551#issuecomment-1025046217 @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 removed a comment on pull request #18551: [FLINK-25653][network] Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

2022-01-29 Thread GitBox
TanYuxin-tyx removed a comment 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

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2022-01-29 Thread Joan Goyeau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484283#comment-17484283 ] Joan Goyeau commented on FLINK-13414: - I agree with [~NickBurkard] we should just have a separate

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

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

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

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

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

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

[GitHub] [flink] nirtsruya closed pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-29 Thread GitBox
nirtsruya closed pull request #18449: URL: https://github.com/apache/flink/pull/18449 -- 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] nirtsruya commented on pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-29 Thread GitBox
nirtsruya commented on pull request #18449: URL: https://github.com/apache/flink/pull/18449#issuecomment-1024995710 Thank you guys for the comments. It seems it requires a bit more thinking and planning, and I think given timelines and that I want to focus in the dynamodb pull request,

[jira] [Closed] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

2022-01-29 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Galen Warren closed FLINK-25873. Resolution: Not A Problem > Using RocksDB state backend causes java.lang.ClassNotFoundException:

[jira] [Commented] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

2022-01-29 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484241#comment-17484241 ] Galen Warren commented on FLINK-25873: -- Yes, this was a problem on my end. I hadn't removed the

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

2022-01-29 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 #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

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

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2022-01-29 Thread Pedro Silva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484231#comment-17484231 ] Pedro Silva commented on FLINK-21564: - I would like to have a look at this one. Could you assign it

[jira] [Commented] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

2022-01-29 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484200#comment-17484200 ] Galen Warren commented on FLINK-25873: -- Actually, this may be a caching issue on my side. I'll

[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-29 Thread GitBox
flinkbot edited a comment on pull request #18555: URL: https://github.com/apache/flink/pull/18555#issuecomment-1024279714 ## CI report: * 4a05b15e68bcece7aba07377a627ead54e2fc3b8 Azure:

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

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

[jira] [Updated] (FLINK-25877) Update the copyright year in NOTICE files

2022-01-29 Thread nyingping (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-25877: -- Description: * The current copyright year is 2014-2021 in NOTICE files. We should change it to

[GitHub] [flink] flinkbot edited a comment on pull request #18447: FLINK-25762 - [Deployment/kubernetes] Move JVM system properties args after log_settings

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18447: URL: https://github.com/apache/flink/pull/18447#issuecomment-1019286035 ## CI report: * 212495e262845da131ed356d742bc7cc8139d0ab Azure:

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18560: URL: https://github.com/apache/flink/pull/18560#issuecomment-1024935636 ## CI report: * 7b97038cf3597e34a315b5845b8bc5ff12c22a23 Azure:

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18559: URL: https://github.com/apache/flink/pull/18559#issuecomment-1024935073 ## CI report: * 6716c498c1d749f3c48acc7db8688eb17b9f925f Azure:

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18560: URL: https://github.com/apache/flink/pull/18560#issuecomment-1024935636 ## CI report: * 7b97038cf3597e34a315b5845b8bc5ff12c22a23 Azure:

[GitHub] [flink] flinkbot commented on pull request #18560: [BP-1.13][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
flinkbot commented on pull request #18560: URL: https://github.com/apache/flink/pull/18560#issuecomment-1024935804 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

[GitHub] [flink-web] tillrohrmann commented on pull request #501: Release announcement for Statefun 3.2.0

2022-01-29 Thread GitBox
tillrohrmann commented on pull request #501: URL: https://github.com/apache/flink-web/pull/501#issuecomment-1024935651 Thanks for the review @igalshilman. I've addressed your comments and pushed a fix up commit. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on pull request #18560: [BP-1.13][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
flinkbot commented on pull request #18560: URL: https://github.com/apache/flink/pull/18560#issuecomment-1024935636 ## CI report: * 7b97038cf3597e34a315b5845b8bc5ff12c22a23 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18559: URL: https://github.com/apache/flink/pull/18559#issuecomment-1024935073 ## CI report: * 6716c498c1d749f3c48acc7db8688eb17b9f925f Azure:

[GitHub] [flink-web] tillrohrmann commented on a change in pull request #501: Release announcement for Statefun 3.2.0

2022-01-29 Thread GitBox
tillrohrmann commented on a change in pull request #501: URL: https://github.com/apache/flink-web/pull/501#discussion_r795067638 ## File path: _posts/2022-01-27-release-statefun-3.2.0.md ## @@ -0,0 +1,111 @@ +--- +layout: post +title: "Stateful Functions 3.2.0 Release

[GitHub] [flink] flinkbot commented on pull request #18559: [BP-1.14][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
flinkbot commented on pull request #18559: URL: https://github.com/apache/flink/pull/18559#issuecomment-1024935301 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

[GitHub] [flink-web] tillrohrmann commented on a change in pull request #501: Release announcement for Statefun 3.2.0

2022-01-29 Thread GitBox
tillrohrmann commented on a change in pull request #501: URL: https://github.com/apache/flink-web/pull/501#discussion_r795067621 ## File path: _posts/2022-01-27-release-statefun-3.2.0.md ## @@ -0,0 +1,111 @@ +--- +layout: post +title: "Stateful Functions 3.2.0 Release

[GitHub] [flink] flinkbot commented on pull request #18559: [BP-1.14][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
flinkbot commented on pull request #18559: URL: https://github.com/apache/flink/pull/18559#issuecomment-1024935073 ## CI report: * 6716c498c1d749f3c48acc7db8688eb17b9f925f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

2022-01-29 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25486. - Resolution: Fixed Fixed via 1.15.0: 8ba13f37afb9164f3bb17de78c4b0d85b1633638 1.14.4: (will be

[GitHub] [flink] tillrohrmann opened a new pull request #18560: [BP-1.13][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
tillrohrmann opened a new pull request #18560: URL: https://github.com/apache/flink/pull/18560 Backport of #18296 onto `release-1.13`. -- 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] tillrohrmann opened a new pull request #18559: [BP-1.14][FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
tillrohrmann opened a new pull request #18559: URL: https://github.com/apache/flink/pull/18559 Backport of #18296 onto `release-1.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

[GitHub] [flink] tillrohrmann closed pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

2022-01-29 Thread GitBox
tillrohrmann closed pull request #18296: URL: https://github.com/apache/flink/pull/18296 -- 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 #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1008024012 ## CI report: * 4572ab9d8d9c034f4a8883886d8d11c220589ea8 UNKNOWN * 1b5592a07cec5d06cb3d61f8ee6a3dceb26dc322 Azure:

[GitHub] [flink] deadwind4 commented on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-29 Thread GitBox
deadwind4 commented on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1024918844 @HuangXingBo Thanks, I will put a documentation section into another PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #18447: FLINK-25762 - [Deployment/kubernetes] Move JVM system properties args after log_settings

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18447: URL: https://github.com/apache/flink/pull/18447#issuecomment-1019286035 ## CI report: * f2809ca6c301880f3ce0ef741277b86a60afe32e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18447: FLINK-25762 - [Deployment/kubernetes] Move JVM system properties args after log_settings

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18447: URL: https://github.com/apache/flink/pull/18447#issuecomment-1019286035 ## CI report: * f2809ca6c301880f3ce0ef741277b86a60afe32e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * baad6b1b8c7c4ba297e0068f5b0bc5ccb18e5e9f 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-29 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 #18555: [FLINK-25492][state/changelog] Place metadata at the beginning of the in-memory state changelog

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

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

2022-01-29 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484138#comment-17484138 ] Roman Khachatryan commented on FLINK-25825: ---

[GitHub] [flink] flinkbot edited a comment on pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1008024012 ## CI report: * 4572ab9d8d9c034f4a8883886d8d11c220589ea8 UNKNOWN * 39696308dab7396e76c053092f7a7eed880e8483 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1008024012 ## CI report: * 4572ab9d8d9c034f4a8883886d8d11c220589ea8 UNKNOWN * 39696308dab7396e76c053092f7a7eed880e8483 Azure:

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

2022-01-29 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 #18556: [FLINK-23559][tests] Randomize periodic materialisation interval in tests

2022-01-29 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 #18558: [FLINK-25877][legal] Update the copyright year to 2022 in NOTICE files

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18558: URL: https://github.com/apache/flink/pull/18558#issuecomment-1024880730 ## CI report: * 258f9aaafa934ae9b25f2907e66e8c347cccf73e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18557: https://issues.apache.org/jira/browse/FLINK-25875

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18557: URL: https://github.com/apache/flink/pull/18557#issuecomment-1024879345 ## CI report: * ac7ab57413f8db610ae0c2bd6e7047f7c560b63c Azure:

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2022-01-29 Thread Aris Koliopoulos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484131#comment-17484131 ] Aris Koliopoulos commented on FLINK-13414: -- In my latest Flink project we went for wrapping the

[GitHub] [flink] RocMarshal commented on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

2022-01-29 Thread GitBox
RocMarshal commented on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1024894312 Hi, @MartijnVisser Would you mind helping me to check it ? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * e9db2dbef49490c8f65278c19951dd7435e2714c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * e9db2dbef49490c8f65278c19951dd7435e2714c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18558: [FLINK-25877][legal] Update the copyright year to 2022 in NOTICE files

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18558: URL: https://github.com/apache/flink/pull/18558#issuecomment-1024880730 ## CI report: * 258f9aaafa934ae9b25f2907e66e8c347cccf73e Azure:

[GitHub] [flink] flinkbot commented on pull request #18558: [FLINK-25877][legal] Update the copyright year to 2022 in NOTICE files

2022-01-29 Thread GitBox
flinkbot commented on pull request #18558: URL: https://github.com/apache/flink/pull/18558#issuecomment-1024880693 -- 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

[jira] [Updated] (FLINK-25877) Update the copyright year in NOTICE files

2022-01-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25877: --- Labels: pull-request-available (was: ) > Update the copyright year in NOTICE files >

[GitHub] [flink] nyingping opened a new pull request #18558: [FLINK-25877][legal] Update the copyright year in NOTICE files

2022-01-29 Thread GitBox
nyingping opened a new pull request #18558: URL: https://github.com/apache/flink/pull/18558 ## What is the purpose of the change Update the copyright year in NOTICE files ## Brief change log Update the copyright year to 2022 in NOTICE files ##

[jira] [Created] (FLINK-25877) Update the copyright year in NOTICE files

2022-01-29 Thread nyingping (Jira)
nyingping created FLINK-25877: - Summary: Update the copyright year in NOTICE files Key: FLINK-25877 URL: https://issues.apache.org/jira/browse/FLINK-25877 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #18557: https://issues.apache.org/jira/browse/FLINK-25875

2022-01-29 Thread GitBox
flinkbot commented on pull request #18557: URL: https://github.com/apache/flink/pull/18557#issuecomment-1024879811 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

[GitHub] [flink] flinkbot edited a comment on pull request #18557: https://issues.apache.org/jira/browse/FLINK-25875

2022-01-29 Thread GitBox
flinkbot edited a comment on pull request #18557: URL: https://github.com/apache/flink/pull/18557#issuecomment-1024879345 ## CI report: * ac7ab57413f8db610ae0c2bd6e7047f7c560b63c Azure:

[GitHub] [flink] flinkbot commented on pull request #18557: https://issues.apache.org/jira/browse/FLINK-25875

2022-01-29 Thread GitBox
flinkbot commented on pull request #18557: URL: https://github.com/apache/flink/pull/18557#issuecomment-1024879345 ## CI report: * ac7ab57413f8db610ae0c2bd6e7047f7c560b63c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-01-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25875: --- Labels: pull-request-available (was: ) > "StatsDReporter. FilterCharacters" for special

[GitHub] [flink] zhaofuw opened a new pull request #18557: https://issues.apache.org/jira/browse/FLINK-25875

2022-01-29 Thread GitBox
zhaofuw opened a new pull request #18557: URL: https://github.com/apache/flink/pull/18557 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] nyingping closed pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-29 Thread GitBox
nyingping closed pull request #18312: URL: https://github.com/apache/flink/pull/18312 -- 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] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-01-29 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r795030756 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java ## @@

  1   2   >