[jira] [Updated] (FLINK-18572) Flink web UI doesn't display tolerable-failed-checkpoints

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18572: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10007) Security vulnerability in website build infrastructure

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10007: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-24624) Add clean up phase when kubernetes session start failed

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24624: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-20128) Data loss for over windows with rows unbounded preceding

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20128: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16224: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-18209) Replace "charged" words in the Flink codebase.

2021-12-28 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18209: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18194: URL: https://github.com/apache/flink/pull/18194#issuecomment-1000443947 ## CI report: * d111c3d078423a6a90e33d91fe2a8cbc1a4d1bbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 485acda72617d08437759e906d2a20d3cd3984c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-998843801 ## CI report: * 5333d13bb184a2f477be0a9b246f1ec06eca1c96 Azure:

[jira] [Comment Edited] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466063#comment-17466063 ] Till Rohrmann edited comment on FLINK-23047 at 12/28/21, 10:32 AM: ---

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466063#comment-17466063 ] Till Rohrmann commented on FLINK-23047: --- Thanks for the PRs [~echauchot]. Could you maybe link the

[GitHub] [flink] tillrohrmann commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
tillrohrmann commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775836504 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -106,5 +112,87 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18194: URL: https://github.com/apache/flink/pull/18194#issuecomment-1000443947 ## CI report: * d111c3d078423a6a90e33d91fe2a8cbc1a4d1bbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 0ece7b12868a4b123dcc69a11fd0efd65b076f6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 1ebbbf86214cd4fefc1432ea6f0f25320df95542 Azure:

[jira] [Commented] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

2021-12-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466060#comment-17466060 ] Yun Tang commented on FLINK-5279: - Current error message has been "{{{}Keyed state can only be used on a

[GitHub] [flink] flinkbot edited a comment on pull request #18216: [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18216: URL: https://github.com/apache/flink/pull/18216#issuecomment-1001908812 ## CI report: * f2a4393f2e4dc3e49f417baaf5723fefd88505a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18217: URL: https://github.com/apache/flink/pull/18217#issuecomment-1001925740 ## CI report: * 7c60f02cecae1e2d06404f39390147803add396b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001318347 ## CI report: * eb875e44857ad74a51da9d19facf5147d0947dd9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 0ece7b12868a4b123dcc69a11fd0efd65b076f6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 3c906b980750bbd34d9fb4c9732acc73e77c40db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18217: URL: https://github.com/apache/flink/pull/18217#issuecomment-1001925740 ## CI report: * 7c60f02cecae1e2d06404f39390147803add396b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18216: [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18216: URL: https://github.com/apache/flink/pull/18216#issuecomment-1001908812 ## CI report: * f2a4393f2e4dc3e49f417baaf5723fefd88505a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001318347 ## CI report: * eb875e44857ad74a51da9d19facf5147d0947dd9 Azure:

[GitHub] [flink] zuston commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
zuston commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775827788 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfoTest.java ## @@ -20,13 +20,27 @@ import

[GitHub] [flink] zuston edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
zuston edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001977953 If you have time, could you help review it? Thanks @tillrohrmann Do i need to add more tests on other mode like application mode? As i know it's

[GitHub] [flink] flinkbot commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
flinkbot commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001980388 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] [Closed] (FLINK-21218) "state.checkpoints.dir" should be required only when "execution.checkpointing.interval" is specified

2021-12-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-21218. Resolution: Information Provided Since Flink already use new API EmbeddedRocksDBStateBackend to replace

[GitHub] [flink] flinkbot commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
flinkbot commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 3c906b980750bbd34d9fb4c9732acc73e77c40db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * d6d02b1257a59f5c555dbec42e00f9152488d624 Azure:

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001977953 If you have time, could you help review it? Thanks @tillrohrmann -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2021-12-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25178: Assignee: Nicholas Jiang > Throw exception when managed table sink needs checkpointing >

[jira] [Commented] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2021-12-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466048#comment-17466048 ] Jingsong Lee commented on FLINK-25178: -- [~nicholasjiang] Thanks! I will take a look~ > Throw

[jira] [Updated] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

2021-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25410: --- Labels: pull-request-available (was: ) > Flink CLI should exit when app is accepted with

[GitHub] [flink] zuston opened a new pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
zuston opened a new pull request #18220: URL: https://github.com/apache/flink/pull/18220 …mode on Yarn ## What is the purpose of the change ### Why In our internal streaming platform, we will use flink-cli tool to submit Flink streaming application on Yarn. However

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466044#comment-17466044 ] Yun Tang commented on FLINK-25426: -- Another instance:

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 31e2390d189b7dd08bf1e1099138b81b4524ce70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * 3181df1d1f9ae281b74efd96f40d7f60ee8bc269 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18135: URL: https://github.com/apache/flink/pull/18135#issuecomment-995929870 ## CI report: * dee9315b9030fa2ed4cd75b67622f0ed68fe632a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-998843801 ## CI report: * 5333d13bb184a2f477be0a9b246f1ec06eca1c96 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
MartijnVisser commented on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001971311 @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] MartijnVisser commented on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
MartijnVisser commented on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001971177 @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 #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * 3181df1d1f9ae281b74efd96f40d7f60ee8bc269 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 1d1f3053070c92cb092ebb3e677c6f4a95d316b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18135: URL: https://github.com/apache/flink/pull/18135#issuecomment-995929870 ## CI report: * dee9315b9030fa2ed4cd75b67622f0ed68fe632a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-998843801 ## CI report: * 5333d13bb184a2f477be0a9b246f1ec06eca1c96 Azure:

[jira] [Commented] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2021-12-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466026#comment-17466026 ] Nicholas Jiang commented on FLINK-25178: [~lzljs3620320], I have pushed a pull request for this

[jira] [Assigned] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-25426: - Assignee: Anton Kalashnikov >

[GitHub] [flink] matriv commented on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
matriv commented on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-1001968639 @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 #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966453 ## CI report: * 8a899ba056ab6b0b34ab2e9dbe98639c7ba97a70 Azure:

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2021-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466025#comment-17466025 ] Martijn Visser commented on FLINK-18356: Couple of findings: The last two provided pipelines

[GitHub] [flink] flinkbot edited a comment on pull request #18212: There is a link redirection problem in the document of ‘overview’

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18212: URL: https://github.com/apache/flink/pull/18212#issuecomment-1001842363 ## CI report: * f303797e4abd7a71e40e193ddbf273f2178f41c6 Azure:

[GitHub] [flink] flinkbot commented on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
flinkbot commented on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966453 ## CI report: * 8a899ba056ab6b0b34ab2e9dbe98639c7ba97a70 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18212: There is a link redirection problem in the document of ‘overview’

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18212: URL: https://github.com/apache/flink/pull/18212#issuecomment-1001842363 ## CI report: * f303797e4abd7a71e40e193ddbf273f2178f41c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18216: [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18216: URL: https://github.com/apache/flink/pull/18216#issuecomment-1001908812 ## CI report: * f2a4393f2e4dc3e49f417baaf5723fefd88505a0 Azure:

[GitHub] [flink] flinkbot commented on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
flinkbot commented on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966256 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 #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 1d1f3053070c92cb092ebb3e677c6f4a95d316b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18164: [FLINK-25404] Let blob.storage.directory default to /blobStorage

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18164: URL: https://github.com/apache/flink/pull/18164#issuecomment-998893805 ## CI report: * b7120f6165444742957a4e9fc9176c64a7d4e418 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 15a426ccd5aca76c566f437e3a9ab5e3fe9fcc11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 1d1f3053070c92cb092ebb3e677c6f4a95d316b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18164: [FLINK-25404] Let blob.storage.directory default to /blobStorage

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18164: URL: https://github.com/apache/flink/pull/18164#issuecomment-998893805 ## CI report: * b7120f6165444742957a4e9fc9176c64a7d4e418 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 15a426ccd5aca76c566f437e3a9ab5e3fe9fcc11 Azure:

[jira] [Updated] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2021-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25178: --- Labels: pull-request-available (was: ) > Throw exception when managed table sink needs

[GitHub] [flink] SteNicholas opened a new pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
SteNicholas opened a new pull request #18219: URL: https://github.com/apache/flink/pull/18219 ## What is the purpose of the change *In the past, many users encountered the problem that the sink did not output because they did not open the checkpoint. For the managed table: The

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 966d66f1a73207b2d2ed1689664ada26b55f9b7a Azure:

[jira] [Closed] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-24772. -- > Update user document for individual window table-valued function >

[jira] [Resolved] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang resolved FLINK-24772. Release Note: Flink now supports evaluating individual window table-valued functions, so there's

[jira] [Commented] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466023#comment-17466023 ] Jing Zhang commented on FLINK-24772: Fixed in master: 07977083736af1e23f00a4ff6c2134886a0e51d9 >

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 966d66f1a73207b2d2ed1689664ada26b55f9b7a Azure:

[GitHub] [flink] beyond1920 merged pull request #17885: [FLINK-24772][docs] Update documentation for individual window table-value function

2021-12-28 Thread GitBox
beyond1920 merged pull request #17885: URL: https://github.com/apache/flink/pull/17885 -- 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] beyond1920 commented on a change in pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
beyond1920 commented on a change in pull request #17684: URL: https://github.com/apache/flink/pull/17684#discussion_r775808275 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala ## @@ -86,6

[GitHub] [flink] beyond1920 commented on a change in pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
beyond1920 commented on a change in pull request #17684: URL: https://github.com/apache/flink/pull/17684#discussion_r775807553 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRules.java

[GitHub] [flink-web] crazyzhou commented on a change in pull request #484: Add Pravega Flink connector 101 blog

2021-12-28 Thread GitBox
crazyzhou commented on a change in pull request #484: URL: https://github.com/apache/flink-web/pull/484#discussion_r775806152 ## File path: _posts/2021-12-27-pravega-connector-101.md ## @@ -0,0 +1,221 @@ +--- +layout: post +title: "Pravega Flink Connector 101" +date:

[GitHub] [flink-web] infoverload commented on a change in pull request #484: Add Pravega Flink connector 101 blog

2021-12-28 Thread GitBox
infoverload commented on a change in pull request #484: URL: https://github.com/apache/flink-web/pull/484#discussion_r775805969 ## File path: _posts/2021-12-27-pravega-connector-101.md ## @@ -0,0 +1,221 @@ +--- +layout: post +title: "Pravega Flink Connector 101" +date:

[GitHub] [flink-web] infoverload commented on a change in pull request #484: Add Pravega Flink connector 101 blog

2021-12-28 Thread GitBox
infoverload commented on a change in pull request #484: URL: https://github.com/apache/flink-web/pull/484#discussion_r775805493 ## File path: _posts/2021-12-27-pravega-connector-101.md ## @@ -0,0 +1,221 @@ +--- +layout: post +title: "Pravega Flink Connector 101" +date:

[jira] [Closed] (FLINK-4511) Schedule periodic savepoints

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-4511. --- Resolution: Invalid > Schedule periodic savepoints > > > Key:

[jira] [Comment Edited] (FLINK-4511) Schedule periodic savepoints

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466020#comment-17466020 ] Yuan Mei edited comment on FLINK-4511 at 12/28/21, 9:13 AM: There is a

[jira] [Comment Edited] (FLINK-4511) Schedule periodic savepoints

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466020#comment-17466020 ] Yuan Mei edited comment on FLINK-4511 at 12/28/21, 9:11 AM: There is a

[jira] [Commented] (FLINK-4511) Schedule periodic savepoints

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466020#comment-17466020 ] Yuan Mei commented on FLINK-4511: - There is a re-architect related to savepoint and checkpoint. Do not

[jira] [Commented] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466019#comment-17466019 ] Yuan Mei commented on FLINK-5241: - [~pnowojski] [~dwysakowicz] [~akalashnikov]  Could you verify whether

[jira] [Updated] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-5241: Component/s: Runtime / Task (was: Runtime / State Backends) > Introduce

[jira] [Updated] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-5241: Priority: Minor (was: Not a Priority) > Introduce AbstractStreamOperator get CloseableRegistry >

[GitHub] [flink] flinkbot edited a comment on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18218: URL: https://github.com/apache/flink/pull/18218#issuecomment-1001947929 ## CI report: * 0caf2b5dad31055215c294d215de3ac7f28b2aa0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18218: URL: https://github.com/apache/flink/pull/18218#issuecomment-1001947929 ## CI report: * 0caf2b5dad31055215c294d215de3ac7f28b2aa0 Azure:

[GitHub] [flink] flinkbot commented on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
flinkbot commented on pull request #18218: URL: https://github.com/apache/flink/pull/18218#issuecomment-1001948175 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 commented on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
flinkbot commented on pull request #18218: URL: https://github.com/apache/flink/pull/18218#issuecomment-1001947929 ## CI report: * 0caf2b5dad31055215c294d215de3ac7f28b2aa0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466017#comment-17466017 ] Till Rohrmann commented on FLINK-25427: --- Disabled this test in 1.15.0 via

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

2021-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18295: --- Labels: pull-request-available (was: ) > Remove the hack logics of result consumers >

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[GitHub] [flink] zhuzhurk opened a new pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
zhuzhurk opened a new pull request #18218: URL: https://github.com/apache/flink/pull/18218 ## What is the purpose of the change This change is to rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer. This can help to get rid of the hack

[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 1ebbbf86214cd4fefc1432ea6f0f25320df95542 Azure:

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466016#comment-17466016 ] Till Rohrmann commented on FLINK-25426: --- Disabled test on 1.15.0 via

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

2021-12-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Description: Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}. That's why the

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

2021-12-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Description: Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}. That's why the

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

<    1   2   3   4   5   >