[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 399f06e14079a512d35814508b6f7598d7d175ba Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] YuvalItzchakov commented on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

YuvalItzchakov commented on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766310391 @wuchong Thank you for the comments. Made the modifications. This is an automated message from the Apache

[GitHub] [flink] fsk119 commented on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

fsk119 commented on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766311558 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] leonardBang commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

leonardBang commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r561827373 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StateConfigUtil.java ## @@ -20,9 +20,13 @@ i

[GitHub] [flink] flinkbot edited a comment on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766094970 ## CI report: * 95137f07f2172150b444e9d3e4ce0b5cece22e2d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

flinkbot edited a comment on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766300412 ## CI report: * ee016150b9a4dce6af1f3e060c4c0708fcfb0940 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * bd617892bfec1db1654606355041a6e4b9050304 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766094970 ## CI report: * 95137f07f2172150b444e9d3e4ce0b5cece22e2d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

flinkbot edited a comment on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766300412 ## CI report: * ee016150b9a4dce6af1f3e060c4c0708fcfb0940 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766094970 ## CI report: * 597d0277ea0046e818971d5e846e76807342b452 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] CuiYanxiang opened a new pull request #14739: Gio release 1.11

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

[GitHub] [flink] gaoyunhaii opened a new pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii opened a new pull request #14740: URL: https://github.com/apache/flink/pull/14740 ## What is the purpose of the change Modifies the logic of computation of checkpoint brief to support the case that have finished tasks. **Basic Algorithm** The algorithm would

[jira] [Updated] (FLINK-21067) Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks

[ https://issues.apache.org/jira/browse/FLINK-21067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21067: --- Labels: pull-request-available (was: ) > Modify the logic of computing tasks to trigger/wai

[GitHub] [flink] HuangXingBo opened a new pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

HuangXingBo opened a new pull request #14741: URL: https://github.com/apache/flink/pull/14741 ## What is the purpose of the change *This pull request will Bump Beam to 2.27.0* ## Brief change log - *Bump Beam to 2.27.0* ## Verifying this change Th

[jira] [Updated] (FLINK-21021) Bump Beam to 2.27.0

[ https://issues.apache.org/jira/browse/FLINK-21021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21021: --- Labels: pull-request-available (was: ) > Bump Beam to 2.27.0 > --- > >

[GitHub] [flink] flinkbot commented on pull request #14739: Gio release 1.11

flinkbot commented on pull request #14739: URL: https://github.com/apache/flink/pull/14739#issuecomment-766338424 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot commented on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766338662 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 pro

[GitHub] [flink] flinkbot commented on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot commented on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766338671 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14739: Gio release 1.11

flinkbot edited a comment on pull request #14739: URL: https://github.com/apache/flink/pull/14739#issuecomment-766338424 ## CI report: * 21f9bc0a3b1089a607354bcec501fbf71f9f2ee1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot commented on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * fc9eebe10a60640303df43899888d783af9293a0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot commented on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 1877658dcfbda8d61985811468878b026a011f3d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] SteNicholas opened a new pull request #14742: [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

SteNicholas opened a new pull request #14742: URL: https://github.com/apache/flink/pull/14742 ## What is the purpose of the change *The configuration `parallelism.default` for table environment doesn't take effect for `TableEnvironment#explain`. Because `PlannerBase#translateToRel`

[jira] [Updated] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

[ https://issues.apache.org/jira/browse/FLINK-21069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21069: --- Labels: pull-request-available starter (was: starter) > Configuration "parallelism.default"

[GitHub] [flink] flinkbot commented on pull request #14742: [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

flinkbot commented on pull request #14742: URL: https://github.com/apache/flink/pull/14742#issuecomment-766341700 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * fc9eebe10a60640303df43899888d783af9293a0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot edited a comment on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 1877658dcfbda8d61985811468878b026a011f3d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14742: [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

flinkbot commented on pull request #14742: URL: https://github.com/apache/flink/pull/14742#issuecomment-766343148 ## CI report: * d541df916f27528c8be8e9fc2daa36d535e78061 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14739: Gio release 1.11

flinkbot edited a comment on pull request #14739: URL: https://github.com/apache/flink/pull/14739#issuecomment-766338424 ## CI report: * 21f9bc0a3b1089a607354bcec501fbf71f9f2ee1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot edited a comment on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 1877658dcfbda8d61985811468878b026a011f3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14742: [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

flinkbot edited a comment on pull request #14742: URL: https://github.com/apache/flink/pull/14742#issuecomment-766343148 ## CI report: * d541df916f27528c8be8e9fc2daa36d535e78061 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270736#comment-17270736 ] Matthias edited comment on FLINK-21106 at 1/24/21, 2:05 PM:

[GitHub] [flink] wuchong commented on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

wuchong commented on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766353650 Oops, `MatchRecognizeITCase.testWindowedGroupingAppliedToMatchRecognize` is still failed, because `org.apache.flink.cep.time.TimeContext#timestamp` returns primitive type `long`

[GitHub] [flink] wuchong edited a comment on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

wuchong edited a comment on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766353650 Oops, `MatchRecognizeITCase.testWindowedGroupingAppliedToMatchRecognize` is still failed, because `org.apache.flink.cep.time.TimeContext#timestamp()` returns primitive ty

[GitHub] [flink] wuchong edited a comment on pull request #14735: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

wuchong edited a comment on pull request #14735: URL: https://github.com/apache/flink/pull/14735#issuecomment-766353650 Oops, `MatchRecognizeITCase.testWindowedGroupingAppliedToMatchRecognize` is still failed, because `org.apache.flink.cep.time.TimeContext#timestamp()` returns primitive ty

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563298480 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/LazyMemorySegmentPool.java ## @@ -37,37 +34,26 @@

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563298480 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/LazyMemorySegmentPool.java ## @@ -37,37 +34,26 @@

[jira] [Comment Edited] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270736#comment-17270736 ] Matthias edited comment on FLINK-21106 at 1/24/21, 2:20 PM:

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: (was: google-java-format-1.7.0.5-patched.zip) > google-java-format Intellij Plugin 1.7.0

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: google-java-format-1.7.0.5-patched.zip > google-java-format Intellij Plugin 1.7.0.5 causes

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: google-java-format-1.7.0.5-patched.zip > google-java-format Intellij Plugin 1.7.0.5 causes

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: (was: google-java-format-1.7.0.5-patched.zip) > google-java-format Intellij Plugin 1.7.0

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: (was: google-java-format.zip) > google-java-format Intellij Plugin 1.7.0.5 causes > Uns

[jira] [Comment Edited] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270736#comment-17270736 ] Matthias edited comment on FLINK-21106 at 1/24/21, 2:29 PM:

[jira] [Updated] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21106: - Attachment: google-java-format-1.7-patched.zip > google-java-format Intellij Plugin 1.7.0.5 causes > Un

[jira] [Comment Edited] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270736#comment-17270736 ] Matthias edited comment on FLINK-21106 at 1/24/21, 2:30 PM:

[jira] [Comment Edited] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270736#comment-17270736 ] Matthias edited comment on FLINK-21106 at 1/24/21, 2:30 PM:

[jira] [Commented] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270904#comment-17270904 ] Matthias commented on FLINK-21106: -- I created issue [#560|https://github.com/google/goo

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563305734 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceSharedAssigner.java ## @@

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563306124 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java ## @@ -0,0

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563306860 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SliceAssigners.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot edited a comment on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 1877658dcfbda8d61985811468878b026a011f3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong commented on a change in pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on a change in pull request #14708: URL: https://github.com/apache/flink/pull/14708#discussion_r563307764 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java ## @

[GitHub] [flink] wuchong commented on pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

wuchong commented on pull request #14708: URL: https://github.com/apache/flink/pull/14708#issuecomment-766367200 Thanks for the reviewing @leonardBang . Hope I have addressed all your concerns. This is an automated message

[GitHub] [flink] wuchong commented on pull request #14742: [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

wuchong commented on pull request #14742: URL: https://github.com/apache/flink/pull/14742#issuecomment-766368245 Compile is failed. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

flinkbot edited a comment on pull request #14708: URL: https://github.com/apache/flink/pull/14708#issuecomment-763516524 ## CI report: * e00fb2507a257ad657632047b3d2ec2e5b38a737 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot edited a comment on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 1877658dcfbda8d61985811468878b026a011f3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

Xiaoguang Sun created FLINK-21108: - Summary: Flink runtime rest server and history server webmonitor do not require authentication. Key: FLINK-21108 URL: https://issues.apache.org/jira/browse/FLINK-21108

[GitHub] [flink] flinkbot edited a comment on pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

flinkbot edited a comment on pull request #14708: URL: https://github.com/apache/flink/pull/14708#issuecomment-763516524 ## CI report: * e00fb2507a257ad657632047b3d2ec2e5b38a737 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270911#comment-17270911 ] Xiaoguang Sun commented on FLINK-21108: --- Changes: [https://github.com/sunxiaoguan

[GitHub] [flink] Myasuka commented on a change in pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

Myasuka commented on a change in pull request #14662: URL: https://github.com/apache/flink/pull/14662#discussion_r563315357 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -237,19 +241,29 @@ private v

[GitHub] [flink] Myasuka commented on a change in pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

Myasuka commented on a change in pull request #14662: URL: https://github.com/apache/flink/pull/14662#discussion_r561753898 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -237,19 +241,29 @@ private v

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

flinkbot edited a comment on pull request #14741: URL: https://github.com/apache/flink/pull/14741#issuecomment-766340784 ## CI report: * 0f1f61148639276031e0d7b07b69c2e1e56b8c29 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 354d120aed8501e9a7df5db9c381e5e174b3c68f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 354d120aed8501e9a7df5db9c381e5e174b3c68f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 44390d70d9c15b70473e1249e042aed2ae99a7b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sv3ndk opened a new pull request #14743: [doc][hotfix] mentions Maxwell as CDC tool in Kafka connector documentation

sv3ndk opened a new pull request #14743: URL: https://github.com/apache/flink/pull/14743 ## What is the purpose of the change The current [Kafka connector changelog section of the documentation](https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors

[GitHub] [flink] flinkbot commented on pull request #14743: [doc][hotfix] mentions Maxwell as CDC tool in Kafka connector documentation

flinkbot commented on pull request #14743: URL: https://github.com/apache/flink/pull/14743#issuecomment-766411085 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 pro

[jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270954#comment-17270954 ] Mikhail Pryakhin commented on FLINK-6949: - Hey [~Tang Yan] cc [~trohrmann] I co

[GitHub] [flink] flinkbot commented on pull request #14743: [doc][hotfix] mentions Maxwell as CDC tool in Kafka connector documentation

flinkbot commented on pull request #14743: URL: https://github.com/apache/flink/pull/14743#issuecomment-766412125 ## CI report: * d1095358d7e5c1982fb362e9b6641cc84a70647c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14743: [doc][hotfix] mentions Maxwell as CDC tool in Kafka connector documentation

flinkbot edited a comment on pull request #14743: URL: https://github.com/apache/flink/pull/14743#issuecomment-766412125 ## CI report: * d1095358d7e5c1982fb362e9b6641cc84a70647c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14708: [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

flinkbot edited a comment on pull request #14708: URL: https://github.com/apache/flink/pull/14708#issuecomment-763516524 ## CI report: * c49626cfa8cd631c731f7db6395465af1711bd20 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21036) Consider removing automatic configuration fo number of slots from docker

[ https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270987#comment-17270987 ] Chesnay Schepler commented on FLINK-21036: -- gotcha. how about for this ticket w

[GitHub] [flink-shaded] zentol merged pull request #93: [FLINK-21020][jackson] Bump version to 2.12.1

zentol merged pull request #93: URL: https://github.com/apache/flink-shaded/pull/93 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

[jira] [Updated] (FLINK-21020) Bump Jackson to 2.12.1

[ https://issues.apache.org/jira/browse/FLINK-21020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-21020: - Fix Version/s: shaded-13.0 > Bump Jackson to 2.12.1 > -- > >

[jira] [Commented] (FLINK-21020) Bump Jackson to 2.12.1

[ https://issues.apache.org/jira/browse/FLINK-21020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271002#comment-17271002 ] Chesnay Schepler commented on FLINK-21020: -- flink-shaded: master: 473eec90a3379

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * ef724e57e7676c154c8f0d6da93a811e9d411051 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * ef724e57e7676c154c8f0d6da93a811e9d411051 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 5d701796fc88f998c12bc58ada37b0248ea978c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shouweikun commented on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

shouweikun commented on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-766489232 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] flinkbot edited a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * 97b72b4489e955f86aa9886b77e91b597bd957f5 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fsk119 commented on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

fsk119 commented on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766495411 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

flinkbot edited a comment on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766300412 ## CI report: * ee016150b9a4dce6af1f3e060c4c0708fcfb0940 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * 97b72b4489e955f86aa9886b77e91b597bd957f5 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271029#comment-17271029 ] Yun Tang commented on FLINK-21104: -- Another instances: https://myasuka.visualstudio.com

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271031#comment-17271031 ] Guowei Ma commented on FLINK-21104: --- Another case: https://dev.azure.com/apache-flink

[jira] [Comment Edited] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271029#comment-17271029 ] Yun Tang edited comment on FLINK-21104 at 1/25/21, 2:33 AM:

[GitHub] [flink] Myasuka commented on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

Myasuka commented on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-766500546 CI failed due to FLINK-21104 This is an automated message from the Apache Git Service. To respond to the message

[jira] [Commented] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271033#comment-17271033 ] Jiang Xin commented on FLINK-9683: -- I believe this is expected behavior. fs.default-sche

[jira] [Comment Edited] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271033#comment-17271033 ] Jiang Xin edited comment on FLINK-9683 at 1/25/21, 2:36 AM: I

[jira] [Comment Edited] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271031#comment-17271031 ] Guowei Ma edited comment on FLINK-21104 at 1/25/21, 2:36 AM: -

[jira] [Commented] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271037#comment-17271037 ] Guowei Ma commented on FLINK-19445: --- another instance https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14738: [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

flinkbot edited a comment on pull request #14738: URL: https://github.com/apache/flink/pull/14738#issuecomment-766300412 ## CI report: * ee016150b9a4dce6af1f3e060c4c0708fcfb0940 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271044#comment-17271044 ] Guowei Ma commented on FLINK-16947: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-21036) Consider removing automatic configuration fo number of slots from docker

[ https://issues.apache.org/jira/browse/FLINK-21036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271045#comment-17271045 ] Yang Wang commented on FLINK-21036: --- +1 to remove the magic logics of computing slots

[GitHub] [flink] Myasuka opened a new pull request #14744: [FLINK-17511][tests] Rerun RocksDB memory control tests if necessary

Myasuka opened a new pull request #14744: URL: https://github.com/apache/flink/pull/14744 ## What is the purpose of the change Currently, RocksDB memory control end-to-end tests failed with very small probability due to the limitation of RocksDB itself. In general, we think RocksDB

[jira] [Updated] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17511: --- Labels: pull-request-available test-stability (was: test-stability) > "RocksDB Memory Manag

[GitHub] [flink] flinkbot commented on pull request #14744: [FLINK-17511][tests] Rerun RocksDB memory control tests if necessary

flinkbot commented on pull request #14744: URL: https://github.com/apache/flink/pull/14744#issuecomment-766507051 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 pro

[GitHub] [flink] shouweikun removed a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

shouweikun removed a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-766489232 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] shouweikun commented on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

shouweikun commented on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-766509300 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] wangyang0918 commented on pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on pull request #14629: URL: https://github.com/apache/flink/pull/14629#issuecomment-766512509 I believe your suggestions make sense. For labels, annotations, node-selectors, tolerations and other similar features, Flink config option will add additional results to s

  1   2   >