[jira] [Resolved] (FLINK-25431) Implement file-based JobResultStore

2022-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-25431. --- Fix Version/s: 1.15.0 Resolution: Fixed master: [2770acee1bc4a82a2f4223d4a4cd6073181

[jira] [Assigned] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

2022-01-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25885: - Assignee: Till Rohrmann > ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicat

[GitHub] [flink] flinkbot edited a comment on pull request #18564: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18564: URL: https://github.com/apache/flink/pull/18564#issuecomment-1025426056 ## CI report: * 35abc632db9a1244bab14ed9188e0e7a88fe40e9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484562#comment-17484562 ] Etienne Chauchot commented on FLINK-24844: -- [~gaoyunhaii] of course ! > Cassan

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 2e955fd5db3754a069a1ed8c48ce2e581aaef51b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] echauchot commented on pull request #18509: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

2022-01-31 Thread GitBox
echauchot commented on pull request #18509: URL: https://github.com/apache/flink/pull/18509#issuecomment-1025491113 @fapaul can we merge this PR ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 2e955fd5db3754a069a1ed8c48ce2e581aaef51b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul merged pull request #18509: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

2022-01-31 Thread GitBox
fapaul merged pull request #18509: URL: https://github.com/apache/flink/pull/18509 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Commented] (FLINK-25882) Translate updated privacy policy to Chinese

2022-01-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484565#comment-17484565 ] Martijn Visser commented on FLINK-25882: [~liyubin117] I've assigned it to you,

[jira] [Assigned] (FLINK-25882) Translate updated privacy policy to Chinese

2022-01-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25882: -- Assignee: Yubin Li > Translate updated privacy policy to Chinese > --

[jira] [Resolved] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-01-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25771. - Resolution: Fixed > CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP >

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-01-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484566#comment-17484566 ] Fabian Paul commented on FLINK-25771: - Merged in master: 3144fae0dc8f3ef4b2ed6a8da4c

[jira] [Resolved] (FLINK-25864) Implement Matomo on Flink project website

2022-01-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-25864. Fix Version/s: 1.15.0 Resolution: Fixed Fixed via: [FLINK-25864] Remove Google Ana

[jira] (FLINK-25432) Implement cleanup strategy

2022-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25432 ] Matthias Pohl deleted comment on FLINK-25432: --- was (Author: mapohl): The work is split up into multiple PRs: * [Github PR|https://github.com/apache/flink/pull/18536] about introducing the

[jira] [Created] (FLINK-25886) Hard-coded ZK version in FlinkContainersBuilder#buildZookeeperContainer

2022-01-31 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-25886: Summary: Hard-coded ZK version in FlinkContainersBuilder#buildZookeeperContainer Key: FLINK-25886 URL: https://issues.apache.org/jira/browse/FLINK-25886 Proje

[jira] [Updated] (FLINK-25886) Hard-coded ZK version in FlinkContainersBuilder#buildZookeeperContainer

2022-01-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25886: - Priority: Minor (was: Major) > Hard-coded ZK version in FlinkContainersBuilder#buildZoo

[GitHub] [flink] zentol opened a new pull request #18565: [FLINK-25145][build] Drop ZK 3.4 / Support ZK 3.6

2022-01-31 Thread GitBox
zentol opened a new pull request #18565: URL: https://github.com/apache/flink/pull/18565 - drop zookeeper 3.4 - zookeeper 3.5 is new default - zookeeper 3.6 is new opt-in version - exclude all optional netty dependencies of zookeeper as we don't need them - HBase pinned to 3.4 be

[jira] [Comment Edited] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484562#comment-17484562 ] Etienne Chauchot edited comment on FLINK-24844 at 1/31/22, 8:39 AM: --

[GitHub] [flink] flinkbot commented on pull request #18565: [FLINK-25145][build] Drop ZK 3.4 / Support ZK 3.6

2022-01-31 Thread GitBox
flinkbot commented on pull request #18565: URL: https://github.com/apache/flink/pull/18565#issuecomment-1025498628 ## CI report: * 4a53bc843f607a866c795cd983d71e811e513ef2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

2022-01-31 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-25887: Summary: FLIP-193: Snapshots ownership follow ups Key: FLINK-25887 URL: https://issues.apache.org/jira/browse/FLINK-25887 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25201) Implement duplicating for gcs

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25201: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for gcs >

[jira] [Updated] (FLINK-25200) Implement duplicating for s3 filesystem

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25200: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for s3 filesystem

[GitHub] [flink] flinkbot commented on pull request #18565: [FLINK-25145][build] Drop ZK 3.4 / Support ZK 3.6

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

[jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25322: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Support no-claim mode in changelog state

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

2022-01-31 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484569#comment-17484569 ] Gabor Somogyi commented on FLINK-25670: --- I personally don't see which endpoint thr

[jira] [Updated] (FLINK-25202) Implement duplicating for azure

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25202: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for azure > --

[jira] [Updated] (FLINK-25203) Implement duplicating for aliyun

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25203: - Parent Issue: FLINK-25887 (was: FLINK-25154) > Implement duplicating for aliyun > -

[GitHub] [flink] flinkbot edited a comment on pull request #18565: [FLINK-25145][build] Drop ZK 3.4 / Support ZK 3.6

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18565: URL: https://github.com/apache/flink/pull/18565#issuecomment-1025498628 ## CI report: * 4a53bc843f607a866c795cd983d71e811e513ef2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25201) Implement duplicating for gcs

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25201: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for g

[jira] [Updated] (FLINK-25203) Implement duplicating for aliyun

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25203: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for a

[jira] [Updated] (FLINK-25200) Implement duplicating for s3 filesystem

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25200: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for s

[jira] [Updated] (FLINK-25202) Implement duplicating for azure

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25202: - Fix Version/s: 1.16.0 (was: 1.15.0) > Implement duplicating for a

[jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend

2022-01-31 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-25322: - Fix Version/s: 1.16.0 (was: 1.15.0) > Support no-claim mode in ch

[GitHub] [flink] flinkbot edited a comment on pull request #18518: [FLINK-24229][connectors/dynamodb] Added DynamoDB connector

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

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795447587 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java ## @@ -0,0 +1,90 @@ +/* +

[jira] [Commented] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

2022-01-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484571#comment-17484571 ] Till Rohrmann commented on FLINK-25885: --- I think the problem is that the {{Resour

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484570#comment-17484570 ] Etienne Chauchot commented on FLINK-24844: -- The fix was merged a bit more than

[jira] [Comment Edited] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484570#comment-17484570 ] Etienne Chauchot edited comment on FLINK-24844 at 1/31/22, 8:50 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #18518: [FLINK-24229][connectors/dynamodb] Added DynamoDB connector

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

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795451478 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodeMetadataUtil.java ## @@ -0,0 +1,262 @@ +/* +

[jira] [Assigned] (FLINK-25827) Potential memory leaks in SourceOperator

2022-01-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25827: -- Assignee: Piotr Nowojski > Potential memory leaks in SourceOperator > ---

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484575#comment-17484575 ] Yun Gao commented on FLINK-24844: - Hi [~echauchot] the failure happens on 1.13: https:/

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

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

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

2022-01-31 Thread GitBox
Airblader merged pull request #18333: URL: https://github.com/apache/flink/pull/18333 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsub

[GitHub] [flink-benchmarks] pnowojski merged pull request #46: [hotfix] Corrected java11 build name

2022-01-31 Thread GitBox
pnowojski merged pull request #46: URL: https://github.com/apache/flink-benchmarks/pull/46 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-

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

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

[jira] [Comment Edited] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

2022-01-31 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484575#comment-17484575 ] Yun Gao edited comment on FLINK-24844 at 1/31/22, 9:04 AM: --- Hi

[jira] [Commented] (FLINK-25220) Develop the ArchUnit Infra for test code and write an architectural rule for all IT cases w.r.t. MiniCluster

2022-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484579#comment-17484579 ] Ingo Bürk commented on FLINK-25220: --- Fixed on master commit c132595205130622352821bb9

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

2022-01-31 Thread GitBox
fapaul commented on a change in pull request #18428: URL: https://github.com/apache/flink/pull/18428#discussion_r795465944 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CheckpointCommittableManagerImpl.java ## @

[jira] [Created] (FLINK-25888) Capture time that the job spends on deploying tasks

2022-01-31 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-25888: Summary: Capture time that the job spends on deploying tasks Key: FLINK-25888 URL: https://issues.apache.org/jira/browse/FLINK-25888 Project: Flink I

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

2022-01-31 Thread GitBox
dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r795462214 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkWriter.j

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

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
slinkydeveloper commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795474727 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/MultipleExecNodeMetadata.java ## @@ -0

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * 528758ad9508f9fec5630b747fe9f454fbc30171 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

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

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 6c5e8781c20bcee5fb18d0f8524dd970c5ff2d9d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * 528758ad9508f9fec5630b747fe9f454fbc30171 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795484145 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeMetadata.java ## @@ -0,0 +1,133 @@ +/*

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795484618 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeMetadata.java ## @@ -0,0 +1,133 @@ +/*

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

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

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

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 6c5e8781c20bcee5fb18d0f8524dd970c5ff2d9d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795485514 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java ## @

[GitHub] [flink] zentol opened a new pull request #18566: [FLINK-25888] Capture time that the job spends on deploying tasks

2022-01-31 Thread GitBox
zentol opened a new pull request #18566: URL: https://github.com/apache/flink/pull/18566 FLINK-23976 added standardized metrics for capturing how much time we spend in each JobStatus. However, certain states in practice consist of several stages; for example the RUNNING state also includes

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795486022 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java ## @@ -0,0 +1,90 @@ +/* +

[jira] [Updated] (FLINK-25888) Capture time that the job spends on deploying tasks

2022-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25888: --- Labels: pull-request-available (was: ) > Capture time that the job spends on deploying task

[GitHub] [flink] zentol commented on a change in pull request #18542: [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job

2022-01-31 Thread GitBox
zentol commented on a change in pull request #18542: URL: https://github.com/apache/flink/pull/18542#discussion_r795487730 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java ## @@ -1816,6 +1819,60 @@ public void testJobMasterOnlyTe

[GitHub] [flink] flinkbot commented on pull request #18566: [FLINK-25888] Capture time that the job spends on deploying tasks

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

[GitHub] [flink] zentol commented on pull request #18542: [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job

2022-01-31 Thread GitBox
zentol commented on pull request #18542: URL: https://github.com/apache/flink/pull/18542#issuecomment-1025547972 > [the slot provider allocates] from the set of available slots before it requests a new slot Yes, then we shouldn't need it. -- This is an automated message from the A

[GitHub] [flink] flinkbot commented on pull request #18566: [FLINK-25888] Capture time that the job spends on deploying tasks

2022-01-31 Thread GitBox
flinkbot commented on pull request #18566: URL: https://github.com/apache/flink/pull/18566#issuecomment-1025548729 ## CI report: * 05c8b566defa4127f8d704c3e1343dcff9898056 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-25889) Implement scroll tracking on Flink project website

2022-01-31 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-25889: -- Summary: Implement scroll tracking on Flink project website Key: FLINK-25889 URL: https://issues.apache.org/jira/browse/FLINK-25889 Project: Flink Issue

[jira] [Created] (FLINK-25890) Implement scroll tracking on Flink documentation

2022-01-31 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-25890: -- Summary: Implement scroll tracking on Flink documentation Key: FLINK-25890 URL: https://issues.apache.org/jira/browse/FLINK-25890 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #18566: [FLINK-25888] Capture time that the job spends on deploying tasks

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18566: URL: https://github.com/apache/flink/pull/18566#issuecomment-1025548729 ## CI report: * 05c8b566defa4127f8d704c3e1343dcff9898056 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] dawidwys commented on pull request #18482: [FLINK-25744] Support native savepoints

2022-01-31 Thread GitBox
dawidwys commented on pull request #18482: URL: https://github.com/apache/flink/pull/18482#issuecomment-1025562743 Hey, @akalash I added a single commit for documentation of the savepoint format. Could you take a look at #cdc389d as well? -- This is an automated message from the Apache G

[GitHub] [flink] flinkbot edited a comment on pull request #18482: [FLINK-25744] Support native savepoints

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18482: URL: https://github.com/apache/flink/pull/18482#issuecomment-1020278176 ## CI report: * 91675405ae82d0e945f46caaa685d65763b296c3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18482: [FLINK-25744] Support native savepoints

2022-01-31 Thread GitBox
flinkbot edited a comment on pull request #18482: URL: https://github.com/apache/flink/pull/18482#issuecomment-1020278176 ## CI report: * 91675405ae82d0e945f46caaa685d65763b296c3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] matriv commented on a change in pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-31 Thread GitBox
matriv commented on a change in pull request #18479: URL: https://github.com/apache/flink/pull/18479#discussion_r795518199 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeMetadata.java ## @@ -0,0 +1,131 @@ +/*

[jira] [Created] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25891: - Summary: NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark Key: FLINK-25891 URL: https://issues.apache.org/jira/browse/FLINK-25891 Project: Flink

[jira] [Updated] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-25891: -- Description: After FLINK-25016(upgrading Netty) StreamNetworkThroughputBenchmark bench

[jira] [Updated] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-25891: -- Description: After FLINK-25016(upgrading Netty) StreamNetworkThroughputBenchmark bench

[jira] [Updated] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-25891: -- Priority: Blocker (was: Major) > NoClassDefFoundError AsyncSSLPrivateKeyMethod in ben

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid co

2022-01-31 Thread GitBox
CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r795522964 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsException

[jira] [Created] (FLINK-25892) Develop ArchUnit test for connectors

2022-01-31 Thread Jing Ge (Jira)
Jing Ge created FLINK-25892: --- Summary: Develop ArchUnit test for connectors Key: FLINK-25892 URL: https://issues.apache.org/jira/browse/FLINK-25892 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

2022-01-31 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-25893: - Summary: ResourceManagerServiceImpl's lifecycle can lead to exceptions Key: FLINK-25893 URL: https://issues.apache.org/jira/browse/FLINK-25893 Project: Flink

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

2022-01-31 Thread GitBox
pnowojski commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1025585234 Your efforts didn't go for nothing. We deeply appreciate that you have reported and analysed this bug. A half year ago another user reported similar symptoms, but neither he

[jira] [Commented] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

2022-01-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484597#comment-17484597 ] Till Rohrmann commented on FLINK-25893: --- [~xtsong] could you take a look at this p

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid co

2022-01-31 Thread GitBox
CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r795529758 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsException

[jira] [Commented] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

2022-01-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484598#comment-17484598 ] Till Rohrmann commented on FLINK-25885: --- I think there are some deeper problems wi

[GitHub] [flink] tillrohrmann opened a new pull request #18567: [FLINK-25893] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

2022-01-31 Thread GitBox
tillrohrmann opened a new pull request #18567: URL: https://github.com/apache/flink/pull/18567 This commit suppresses the error reporting for ResourceManagerServiceImpl.deregisterApplication in order to harden the ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes

[jira] [Updated] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

2022-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25893: --- Labels: pull-request-available (was: ) > ResourceManagerServiceImpl's lifecycle can lead to

[jira] [Commented] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484601#comment-17484601 ] Anton Kalashnikov commented on FLINK-25891: --- [~chesnay], Maybe do you have an

[GitHub] [flink] vahmed-hamdy commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

2022-01-31 Thread GitBox
vahmed-hamdy commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r795534589 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkWriter.j

[GitHub] [flink] flinkbot commented on pull request #18567: [FLINK-25893] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

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

[GitHub] [flink] flinkbot commented on pull request #18567: [FLINK-25893] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

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

[jira] [Commented] (FLINK-25847) KubernetesHighAvailabilityRecoverFromSavepointITCase. testRecoverFromSavepoint failed on azure

2022-01-31 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484603#comment-17484603 ] Till Rohrmann commented on FLINK-25847: --- Another instance: https://dev.azure.com/

[GitHub] [flink] flinkbot edited a comment on pull request #18567: [FLINK-25893] Suppress error reporting for ResourceManagerServiceImpl.deregisterApplication

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

[jira] [Assigned] (FLINK-25891) NoClassDefFoundError AsyncSSLPrivateKeyMethod in benchmark

2022-01-31 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-25891: - Assignee: Anton Kalashnikov > NoClassDefFoundError AsyncSSLPrivateKeyMethod in

[jira] [Updated] (FLINK-21232) Kerberos delegation token framework

2022-01-31 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Summary: Kerberos delegation token framework (was: Introduce pluggable Hadoop delegation toke

[jira] [Updated] (FLINK-21232) Kerberos delegation token framework

2022-01-31 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Description: Proper delegation token handling is completely missing from Flink. This jira is

[GitHub] [flink-benchmarks] akalash opened a new pull request #47: [FLINK-25891] Upgraded version of flink.shaded.version and netty.tcna…

2022-01-31 Thread GitBox
akalash opened a new pull request #47: URL: https://github.com/apache/flink-benchmarks/pull/47 …tive.version -- 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

  1   2   3   4   >