[GitHub] [flink] zuston commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
zuston commented on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-1019438762 Updated. @gaoyunhaii Thanks for your review. Could you help check again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * b03d760783ff5f1c554a49aaa08729165eaf7142 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r790244517 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/MetadataOutputStreamWrapper.java ## @@ -0,0 +1,78 @@ +/* + * Licensed

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r790244561 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +161,18 @@ public F

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * b03d760783ff5f1c554a49aaa08729165eaf7142 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type

2022-01-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480572#comment-17480572 ] Aitozi commented on FLINK-20830: Hi [~chesnay], [~wangyang0918], Sorry for bring up disc

[GitHub] [flink] leonardBang closed pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

2022-01-23 Thread GitBox
leonardBang closed pull request #18437: URL: https://github.com/apache/flink/pull/18437 -- 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-uns

[GitHub] [flink] leonardBang closed pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

2022-01-23 Thread GitBox
leonardBang closed pull request #18137: URL: https://github.com/apache/flink/pull/18137 -- 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-uns

[GitHub] [flink] Myasuka commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

2022-01-23 Thread GitBox
Myasuka commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r790249924 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -368

[jira] [Resolved] (FLINK-25287) Refactor connector testing framework interfaces

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25287. Assignee: Qingsheng Ren Resolution: Fixed master: d864ce37da557e0709469803539c1ee16abf67b0

[jira] [Resolved] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25712. Release Note: The flink-connector-testing module has been removed and should use flink-connector-t

[jira] [Updated] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-25712: --- Parent: FLINK-25286 Issue Type: Sub-task (was: Bug) > Merge flink-connector-testing into fl

[jira] [Commented] (FLINK-25377) kubernetes's request/limit resource can been seperated?

2022-01-23 Thread jeff-zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480581#comment-17480581 ] jeff-zou commented on FLINK-25377: -- i have tried it,event if u set limit in jm/tm pod t

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

2022-01-23 Thread GitBox
nirtsruya opened a new pull request #18449: URL: https://github.com/apache/flink/pull/18449 Add FatalExceptionHandler to allow the users of the sink to configure fatal exception handling. ## What is the purpose of the change This pull request allows users of a sink bas

[jira] [Updated] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

2022-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25661: --- Labels: pull-request-available (was: ) > Add Custom Fatal Exception handler in AsyncSinkWri

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-01-23 Thread Nir Tsruya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480586#comment-17480586 ] Nir Tsruya commented on FLINK-24229: Hey [~CrynetLogistics] , I created a pull reque

[GitHub] [flink] flinkbot commented on pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-23 Thread GitBox
flinkbot commented on pull request #18449: URL: https://github.com/apache/flink/pull/18449#issuecomment-1019456067 ## CI report: * 6cb754d7f53dd95f508ebcf60b3e7d65503e2996 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

2022-01-23 Thread GitBox
flinkbot commented on pull request #18449: URL: https://github.com/apache/flink/pull/18449#issuecomment-1019456185 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] flinkbot edited a comment on pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-23 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * bdbbf550bb2fa01fdfad3d1e64ee08cff4a2fb0e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23732) StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException

2022-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480595#comment-17480595 ] Matthias Pohl commented on FLINK-23732: --- I'm adding a build failure here without r

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

2022-01-23 Thread GitBox
wanglijie95 opened a new pull request #18450: URL: https://github.com/apache/flink/pull/18450 ## What is the purpose of the change Document how to use the usrlib to load code in the user code class loader ## Brief change log 272b759c65511b88aab0cc322b38033e89f9f945 Document how

[jira] [Updated] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

2022-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25053: --- Labels: pull-request-available (was: ) > Document how to use the usrlib to load code in the

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

2022-01-23 Thread GitBox
flinkbot commented on pull request #18450: URL: https://github.com/apache/flink/pull/18450#issuecomment-1019472545 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] flinkbot commented on pull request #18450: [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader

2022-01-23 Thread GitBox
flinkbot commented on pull request #18450: URL: https://github.com/apache/flink/pull/18450#issuecomment-1019472598 ## CI report: * 272b759c65511b88aab0cc322b38033e89f9f945 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

[jira] [Comment Edited] (FLINK-25377) kubernetes's request/limit resource can been seperated?

2022-01-23 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480616#comment-17480616 ] Tamir Sagi edited comment on FLINK-25377 at 1/23/22, 12:22 PM: ---

[jira] [Commented] (FLINK-25377) kubernetes's request/limit resource can been seperated?

2022-01-23 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480616#comment-17480616 ] Tamir Sagi commented on FLINK-25377: Yes I see that in flink# org.apache.flink.kuber

[GitHub] [flink] flinkbot edited a comment on pull request #18449: [FLINK-25661] [flink-connector-base]- fatal exception handler

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

[GitHub] [flink] mans2singh commented on pull request #18448: [FLINK-25763][match-recognize][docs] Updated docs to use code tag consistent with other tables

2022-01-23 Thread GitBox
mans2singh commented on pull request #18448: URL: https://github.com/apache/flink/pull/18448#issuecomment-1019487320 Thanks @SteNicholas for your review. -- 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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-23 Thread GitBox
zhuzhurk commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790281527 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private stati

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

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-23 Thread GitBox
zhuzhurk commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790282508 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private stati

[GitHub] [flink] zhuzhurk commented on a change in pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-23 Thread GitBox
zhuzhurk commented on a change in pull request #18376: URL: https://github.com/apache/flink/pull/18376#discussion_r790282508 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java ## @@ -148,6 +161,78 @@ private stati

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18126: [FLINK-25036][runtime] Introduce vertex wise scheduling strategy

2022-01-23 Thread GitBox
zhuzhurk commented on a change in pull request #18126: URL: https://github.com/apache/flink/pull/18126#discussion_r790285074 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/VertexwiseSchedulingStrategy.java ## @@ -0,0 +1,187 @@ +/* + * Lic

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18407: [FLINK-25669][runtime] Support register operator coordinators for newly initialized ExecutionJobVertex

2022-01-23 Thread GitBox
zhuzhurk commented on a change in pull request #18407: URL: https://github.com/apache/flink/pull/18407#discussion_r790286777 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultOperatorCoordinatorHandler.java ## @@ -151,4 +161,28 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[jira] [Created] (FLINK-25764) Docker sets JobManager's rpc address to same host by default

2022-01-23 Thread Niklas Semmler (Jira)
Niklas Semmler created FLINK-25764: -- Summary: Docker sets JobManager's rpc address to same host by default Key: FLINK-25764 URL: https://issues.apache.org/jira/browse/FLINK-25764 Project: Flink

[jira] [Updated] (FLINK-25764) Docker sets JobManager's rpc address to same host by default

2022-01-23 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niklas Semmler updated FLINK-25764: --- Description: In the [docker entrypoint|https://github.com/apache/flink-docker/blob/master/1

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[jira] [Comment Edited] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

2022-01-23 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479931#comment-17479931 ] Jane Chan edited comment on FLINK-25746 at 1/23/22, 3:34 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] Myasuka commented on a change in pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-23 Thread GitBox
Myasuka commented on a change in pull request #18382: URL: https://github.com/apache/flink/pull/18382#discussion_r790293553 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -441

[GitHub] [flink] Zarathustra2 opened a new pull request #18451: [FLINK-24623] [EventTimeWindowing]: Prevent usage of EventTimeWindows when EventTime is disabled

2022-01-23 Thread GitBox
Zarathustra2 opened a new pull request #18451: URL: https://github.com/apache/flink/pull/18451 ## What is the purpose of the change Prevent usage of EventTimeWindows when EventTime is disabled. For instance: ```java source.assignTimestampsAndWatermarks(WatermarkStrategy.noWaterm

[jira] [Updated] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled

2022-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24623: --- Labels: pull-request-available (was: ) > Prevent usage of EventTimeWindows when EventTime i

[GitHub] [flink] flinkbot commented on pull request #18451: [FLINK-24623] [EventTimeWindowing]: Prevent usage of EventTimeWindows when EventTime is disabled

2022-01-23 Thread GitBox
flinkbot commented on pull request #18451: URL: https://github.com/apache/flink/pull/18451#issuecomment-1019516830 ## CI report: * 276b3d2642da698b19a42843467ccd27b0c1d41a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled

2022-01-23 Thread Dario Heinisch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480666#comment-17480666 ] Dario Heinisch commented on FLINK-24623: Hey,  I opened a draft pull request fo

[GitHub] [flink] flinkbot commented on pull request #18451: [FLINK-24623] [EventTimeWindowing]: Prevent usage of EventTimeWindows when EventTime is disabled

2022-01-23 Thread GitBox
flinkbot commented on pull request #18451: URL: https://github.com/apache/flink/pull/18451#issuecomment-1019517165 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] flinkbot edited a comment on pull request #18451: [FLINK-24623] [EventTimeWindowing]: Prevent usage of EventTimeWindows when EventTime is disabled

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] galenwarren opened a new pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-23 Thread GitBox
galenwarren opened a new pull request #18452: URL: https://github.com/apache/flink/pull/18452 ## What is the purpose of the change Fix licensing issues in Java 11 build. ## Brief change log Exclude javax.annotation.* in flink-gs-fs-hadoop via filter in pom.xml. ##

[jira] [Updated] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

2022-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25758: --- Labels: pull-request-available (was: ) > GCS Filesystem implementation fails on Java 11 tes

[GitHub] [flink] galenwarren commented on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-23 Thread GitBox
galenwarren commented on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019527513 @MartijnVisser I'm not sure how to run these license checks locally, so this is a bit of a guess. Previously, javax.annotation was excluded via a dependency exclusion, whic

[GitHub] [flink] flinkbot commented on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-23 Thread GitBox
flinkbot commented on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019527627 ## CI report: * 6cf148aeb02d6fdbaf0bd78fa1d6a1aca76dbeff UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

2022-01-23 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480685#comment-17480685 ] Galen Warren commented on FLINK-25758: -- [~MartijnVisser] PR created: https://github

[GitHub] [flink] flinkbot commented on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-23 Thread GitBox
flinkbot commented on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019527950 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] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

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

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

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

[jira] [Created] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

2022-01-23 Thread Niklas Semmler (Jira)
Niklas Semmler created FLINK-25765: -- Summary: Kubernetes: flink's configmap and flink's actual config are out of sync Key: FLINK-25765 URL: https://issues.apache.org/jira/browse/FLINK-25765 Project:

[jira] [Commented] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

2022-01-23 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480695#comment-17480695 ] Niklas Semmler commented on FLINK-25765: I think we have to either manage user's

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[jira] [Updated] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

2022-01-23 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niklas Semmler updated FLINK-25765: --- Description: For kubernetes setups, Flink's configmap does not reflect the actual config. C

[GitHub] [flink] flinkbot edited a comment on pull request #18451: [FLINK-24623] [EventTimeWindowing]: Prevent usage of EventTimeWindows when EventTime is disabled

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

[GitHub] [flink] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

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

[GitHub] [flink] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

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

[GitHub] [flink] galenwarren edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-23 Thread GitBox
galenwarren edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1018971976 @xintongsong I've realized something as I'm working through the docs and checking things. The existing GCS [documentation](https://nightlies.apache.org/flink/

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

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

[GitHub] [flink] galenwarren commented on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-23 Thread GitBox
galenwarren commented on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1019557974 @MartijnVisser @xintongsong I think these docs are ready to go, but please let me know if you have any feedback. Note that you can't actually follow along with the in

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

2022-01-23 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480728#comment-17480728 ] Galen Warren commented on FLINK-25758: -- PR created: [https://github.com/apache/flin

[jira] [Commented] (FLINK-25577) Update GCS documentation

2022-01-23 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480732#comment-17480732 ] Galen Warren commented on FLINK-25577: -- [~MartijnVisser] I'm trying to add the rele

[GitHub] [flink] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

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

[GitHub] [flink] galenwarren commented on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-23 Thread GitBox
galenwarren commented on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019568918 @MartijnVisser The issues with the Java 11 build were with respect to `package.html` files; perhaps excluding `javax.annotation` as a dependency doesn't prevent such

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

  1   2   3   >