[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * b46eccc0ae7849f52f3fc735121703f78db926eb Azure:

[jira] [Comment Edited] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285695#comment-17285695 ] Tzu-Li (Gordon) Tai edited comment on FLINK-21359 at 2/17/21, 7:58 AM:

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285695#comment-17285695 ] Tzu-Li (Gordon) Tai commented on FLINK-21359: - [~sivaj2ee] Since the stack trace you

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-02-16 Thread GitBox
LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577390289 ## File path:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-02-16 Thread GitBox
LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577390089 ## File path:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-02-16 Thread GitBox
LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577390019 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org.apache.flink.glue.schema.registry.test/GSRKinesisPubsubClient.java

[jira] [Updated] (FLINK-21076) Document how to use the declarative scheduler and its limitations

2021-02-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21076: --- Component/s: Runtime / Coordination > Document how to use the declarative scheduler and its

[GitHub] [flink] rmetzger commented on pull request #14923: [DRAFT] Remove State#onEnter

2021-02-16 Thread GitBox
rmetzger commented on pull request #14923: URL: https://github.com/apache/flink/pull/14923#issuecomment-780361413  for this change! This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] LadyForest commented on a change in pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

2021-02-16 Thread GitBox
LadyForest commented on a change in pull request #14944: URL: https://github.com/apache/flink/pull/14944#discussion_r577355765 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java ## @@ -205,6 +211,10 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 843c8955cf8479749da5ea5dfb8bcf76fd4de378 Azure:

[GitHub] [flink] LadyForest commented on a change in pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

2021-02-16 Thread GitBox
LadyForest commented on a change in pull request #14944: URL: https://github.com/apache/flink/pull/14944#discussion_r577347696 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java ## @@ -864,6

[GitHub] [flink] curcur commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-02-16 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r577316437 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration shortcut

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 8a49107b300f0c8d0b03542276db382742ae7aed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * f3deeedc248d1f36ce6ae12bdd1e1e034674e97e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[jira] [Created] (FLINK-21386) FromElements ignores returns()

2021-02-16 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21386: Summary: FromElements ignores returns() Key: FLINK-21386 URL: https://issues.apache.org/jira/browse/FLINK-21386 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 1a0271b16f2d2869beef7cefc0e27ab6d2793e47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-16 Thread Siva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285529#comment-17285529 ] Siva commented on FLINK-21359: -- BytesDeserializerSchema cannot be cast to

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] sjwiesman closed pull request #14949: [FLINK-21384][docs] Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread GitBox
sjwiesman closed pull request #14949: URL: https://github.com/apache/flink/pull/14949 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

[GitHub] [flink] flinkbot edited a comment on pull request #14936: [FLINK-20580][core] Don't support nullable value for SerializedValue

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14936: URL: https://github.com/apache/flink/pull/14936#issuecomment-778569873 ## CI report: * 4895ac2d275f1b4425d72fae7673bceca14e343d UNKNOWN * ddb9314a013b3eab9fccd3eabeef1b41c17568e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 1a0271b16f2d2869beef7cefc0e27ab6d2793e47 Azure:

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r577158379 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java ## @@ -605,6 +624,289 @@ public void

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r577157152 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -908,38 +909,57 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN *

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r577152942 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java ## @@ -605,6 +625,414 @@ public void

[GitHub] [flink] XComp commented on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-780130394 I followed @tillrohrmann proposal and introduced `StopWithSavepointOperations`. Its implementation `StopWithSavepointsContext` implements the stop-with-savepoint using states

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r577148145 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java ## @@ -605,6 +624,289 @@ public void

[GitHub] [flink] XComp commented on a change in pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
XComp commented on a change in pull request #14847: URL: https://github.com/apache/flink/pull/14847#discussion_r577147425 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -908,38 +909,57 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14847: [FLINK-21030][runtime] Add global failover in case of a stop-with-savepoint failure

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14847: URL: https://github.com/apache/flink/pull/14847#issuecomment-772387941 ## CI report: * 9a2ea20ce0803e48edfc3ab7bcc02078b7410fbf UNKNOWN * 1a0271b16f2d2869beef7cefc0e27ab6d2793e47 Azure:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-02-16 Thread GitBox
LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577139233 ## File path:

[jira] [Closed] (FLINK-21377) Adjust queryable-state JobMaster tests

2021-02-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21377. Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS tests pass with declarative scheduler

2021-02-16 Thread GitBox
zentol merged pull request #14942: URL: https://github.com/apache/flink/pull/14942 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 #14949: [FLINK-21384][docs] Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14949: URL: https://github.com/apache/flink/pull/14949#issuecomment-780093495 ## CI report: * 3ab70c7f0969506b71a5854edd9e0633d0f6b90b Azure:

[jira] [Created] (FLINK-21385) AvroDeserializationSchema corrupted after getting invalid data

2021-02-16 Thread Leonid Ilyevsky (Jira)
Leonid Ilyevsky created FLINK-21385: --- Summary: AvroDeserializationSchema corrupted after getting invalid data Key: FLINK-21385 URL: https://issues.apache.org/jira/browse/FLINK-21385 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #14949: [FLINK-21384][docs] Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread GitBox
flinkbot commented on pull request #14949: URL: https://github.com/apache/flink/pull/14949#issuecomment-780093495 ## CI report: * 3ab70c7f0969506b71a5854edd9e0633d0f6b90b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * b46eccc0ae7849f52f3fc735121703f78db926eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * c638fb8340fb07c493e236ee7ddecb1e89789c8d Azure:

[GitHub] [flink] flinkbot commented on pull request #14949: [FLINK-21384][docs] Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread GitBox
flinkbot commented on pull request #14949: URL: https://github.com/apache/flink/pull/14949#issuecomment-780082194 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-21384) Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21384: --- Labels: pull-request-available (was: ) > Automatically copy maven dependencies to

[GitHub] [flink] sjwiesman opened a new pull request #14949: [FLINK-21384][docs] Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread GitBox
sjwiesman opened a new pull request #14949: URL: https://github.com/apache/flink/pull/14949 Flink has a number of optional dependencies users may need to copy into their pom files to use, such as connectors and formats. The docs should automatically copy the maven dependency to the users'

[jira] [Created] (FLINK-21384) Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-21384: Summary: Automatically copy maven dependencies to clipboard on click Key: FLINK-21384 URL: https://issues.apache.org/jira/browse/FLINK-21384 Project: Flink

[jira] [Updated] (FLINK-21384) Automatically copy maven dependencies to clipboard on click

2021-02-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-21384: - Component/s: Documentation > Automatically copy maven dependencies to clipboard on click >

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * c638fb8340fb07c493e236ee7ddecb1e89789c8d Azure:

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285441#comment-17285441 ] Chesnay Schepler commented on FLINK-21359: -- Could you try upgrading to 1.7 first, and then to

[GitHub] [flink] flinkbot edited a comment on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS tests pass with declarative scheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * ad6ced4ac0ad3c64d1e135039b85a79928e9f6f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS tests pass with declarative scheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * ad6ced4ac0ad3c64d1e135039b85a79928e9f6f2 Azure:

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

2021-02-16 Thread Siva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285426#comment-17285426 ] Siva commented on FLINK-21359: -- is there any ETA to get the fix resolution ? > CompatibilityResult issues

[GitHub] [flink-web] rkhachatryan opened a new pull request #418: Add Apache Flink 1.12.2 release

2021-02-16 Thread GitBox
rkhachatryan opened a new pull request #418: URL: https://github.com/apache/flink-web/pull/418 The PR adds 1.12.2 release by restoring a commit erroneously added the `asf-site` branch. The site has not been rebuilt (changes from `bash docker-build.sh` are not included in the

[GitHub] [flink] zentol commented on a change in pull request #14923: [DRAFT] Remove State#onEnter

2021-02-16 Thread GitBox
zentol commented on a change in pull request #14923: URL: https://github.com/apache/flink/pull/14923#discussion_r577043778 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/DeclarativeScheduler.java ## @@ -887,19 +897,22 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * f241498bb0ae86535a37f552fcd4deeafd0dbfb0 Azure:

[GitHub] [flink] tillrohrmann closed pull request #14265: FLINK-15649 and FLINK-20359. Adding Volume and Configuration Mount decorators and Owner reference

2021-02-16 Thread GitBox
tillrohrmann closed pull request #14265: URL: https://github.com/apache/flink/pull/14265 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

[GitHub] [flink] tillrohrmann closed pull request #14284: [FLINK-20324] Added Configuration mount support

2021-02-16 Thread GitBox
tillrohrmann closed pull request #14284: URL: https://github.com/apache/flink/pull/14284 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

[GitHub] [flink] tillrohrmann commented on a change in pull request #14923: [DRAFT] Remove State#onEnter

2021-02-16 Thread GitBox
tillrohrmann commented on a change in pull request #14923: URL: https://github.com/apache/flink/pull/14923#discussion_r577023374 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/DeclarativeScheduler.java ## @@ -887,19 +897,22 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #14936: [FLINK-20580][core] Don't support nullable value for SerializedValue

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14936: URL: https://github.com/apache/flink/pull/14936#issuecomment-778569873 ## CI report: * 4895ac2d275f1b4425d72fae7673bceca14e343d UNKNOWN * f0b807f8a4e53e173afc26fe4b44cbc301b04b6c Azure:

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen edited comment on FLINK-21133 at 2/16/21, 5:37 PM: The

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen edited comment on FLINK-21133 at 2/16/21, 5:35 PM: The

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen edited comment on FLINK-21133 at 2/16/21, 5:35 PM: The

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen edited comment on FLINK-21133 at 2/16/21, 5:32 PM: The

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen commented on FLINK-21133: -- The complexity of adding a new {{EndOfData}} event, versus

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285367#comment-17285367 ] Stephan Ewen edited comment on FLINK-21133 at 2/16/21, 5:31 PM: The

[GitHub] [flink] flinkbot edited a comment on pull request #14936: [FLINK-20580][core] Don't support nullable value for SerializedValue

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14936: URL: https://github.com/apache/flink/pull/14936#issuecomment-778569873 ## CI report: * 4895ac2d275f1b4425d72fae7673bceca14e343d UNKNOWN * f0b807f8a4e53e173afc26fe4b44cbc301b04b6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14942: [FLINK-21377][coordination][tests] Make JobMaster QS tests pass with declarative scheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14942: URL: https://github.com/apache/flink/pull/14942#issuecomment-779287504 ## CI report: * ad6ced4ac0ad3c64d1e135039b85a79928e9f6f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * f208c333b987a6c05bc5dc291019452387d3d1a6 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-02-16 Thread GitBox
dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r576978089 ## File path: flink-end-to-end-tests/test-scripts/test_glue_schema_registry.sh ## @@ -0,0 +1,72 @@ +#!/usr/bin/env bash Review comment: Have

[GitHub] [flink] flinkbot edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 603f66e3ad01d8c857678ff852087f48db66b1a8 Azure:

[jira] [Commented] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

2021-02-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285323#comment-17285323 ] Till Rohrmann commented on FLINK-21383: --- cc [~chesnay], [~fly_in_gis]. > Docker image does not

[jira] [Created] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

2021-02-16 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-21383: - Summary: Docker image does not play well together with ConfigMap based flink-conf.yamls Key: FLINK-21383 URL: https://issues.apache.org/jira/browse/FLINK-21383

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285319#comment-17285319 ] Kezhu Wang edited comment on FLINK-21133 at 2/16/21, 4:21 PM: -- {quote}But

[GitHub] [flink] flinkbot commented on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-02-16 Thread GitBox
flinkbot commented on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 603f66e3ad01d8c857678ff852087f48db66b1a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14946: [FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14946: URL: https://github.com/apache/flink/pull/14946#issuecomment-779866080 ## CI report: * 3acf861c7e288f9ce7c3b0fec5bc513c75ea8f18 Azure:

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285319#comment-17285319 ] Kezhu Wang commented on FLINK-21133: {quote}But this assumption doesn't hold with the legacy

[jira] [Created] (FLINK-21382) Standalone K8s documentation does not explain usage of standby JobManagers

2021-02-16 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-21382: - Summary: Standalone K8s documentation does not explain usage of standby JobManagers Key: FLINK-21382 URL: https://issues.apache.org/jira/browse/FLINK-21382

[GitHub] [flink] wuchong commented on a change in pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

2021-02-16 Thread GitBox
wuchong commented on a change in pull request #14944: URL: https://github.com/apache/flink/pull/14944#discussion_r576913197 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java ## @@ -864,6

[jira] [Updated] (FLINK-21333) Introduce stopping with savepoint state

2021-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21333: --- Labels: pull-request-available (was: ) > Introduce stopping with savepoint state >

[GitHub] [flink] flinkbot commented on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-02-16 Thread GitBox
flinkbot commented on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779933454 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #14947: [BP-1.12][FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14947: URL: https://github.com/apache/flink/pull/14947#issuecomment-779866301 ## CI report: * 16aff33df0ad3527e2115438037417ba3d25d47c Azure:

[GitHub] [flink] rmetzger commented on pull request #14948: Flink 21333 stop with savepoint state

2021-02-16 Thread GitBox
rmetzger commented on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779932280 @tillrohrmann if you happen to have some time, it would be nice if you could take a quick look at the `StopWithSavepoint` state from the last commit:

[GitHub] [flink] rmetzger opened a new pull request #14948: Flink 21333 stop with savepoint state

2021-02-16 Thread GitBox
rmetzger opened a new pull request #14948: URL: https://github.com/apache/flink/pull/14948 ## What is the purpose of the change Introduce StopWithSavepoint state to declarative scheduler. This PR is based on https://github.com/apache/flink/pull/14921. ##

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 979f6647eea9c314a21e55585f2c891ec6145d96 Azure:

[jira] [Updated] (FLINK-21366) Kafka connector documentation should mentions Maxwell as CDC mechanism

2021-02-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-21366: - Fix Version/s: 1.13.0 > Kafka connector documentation should mentions Maxwell as CDC mechanism

[jira] [Commented] (FLINK-21366) Kafka connector documentation should mentions Maxwell as CDC mechanism

2021-02-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285269#comment-17285269 ] Seth Wiesman commented on FLINK-21366: -- merged in master: 8dda6eeeda281e52e90b6ab9730f41e60dbdac49

[jira] [Closed] (FLINK-21366) Kafka connector documentation should mentions Maxwell as CDC mechanism

2021-02-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-21366. Resolution: Fixed > Kafka connector documentation should mentions Maxwell as CDC mechanism >

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * 979f6647eea9c314a21e55585f2c891ec6145d96 Azure:

[GitHub] [flink] sjwiesman closed pull request #14743: [FLINK-21366][doc] mentions Maxwell as CDC tool in Kafka connector documentation

2021-02-16 Thread GitBox
sjwiesman closed pull request #14743: URL: https://github.com/apache/flink/pull/14743 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

[GitHub] [flink] sjwiesman commented on pull request #14743: [FLINK-21366][doc] mentions Maxwell as CDC tool in Kafka connector documentation

2021-02-16 Thread GitBox
sjwiesman commented on pull request #14743: URL: https://github.com/apache/flink/pull/14743#issuecomment-779896145 Thanks, I'm glad you like it. I'm aware of the formatting. I had issues getting the XML to render properly. I have it as a follow-up to fix before the next release but

[GitHub] [flink] flinkbot edited a comment on pull request #14946: [FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14946: URL: https://github.com/apache/flink/pull/14946#issuecomment-779866080 ## CI report: * 3acf861c7e288f9ce7c3b0fec5bc513c75ea8f18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14947: [BP-1.12][FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14947: URL: https://github.com/apache/flink/pull/14947#issuecomment-779866301 ## CI report: * 16aff33df0ad3527e2115438037417ba3d25d47c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

2021-02-16 Thread GitBox
flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * f2b7f3e571d20843e34bf0ae95bda811601aee73 Azure:

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-02-16 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285250#comment-17285250 ] Kezhu Wang commented on FLINK-21317: [~pnowojski] Yeh, I could prepare a fix if my proposed

[jira] [Comment Edited] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

2021-02-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285219#comment-17285219 ] Piotr Nowojski edited comment on FLINK-21133 at 2/16/21, 2:47 PM: --

[GitHub] [flink] blublinsky commented on pull request #14265: FLINK-15649 and FLINK-20359. Adding Volume and Configuration Mount decorators and Owner reference

2021-02-16 Thread GitBox
blublinsky commented on pull request #14265: URL: https://github.com/apache/flink/pull/14265#issuecomment-779867479 Yes, lets close, thank you This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] blublinsky commented on pull request #14284: [FLINK-20324] Added Configuration mount support

2021-02-16 Thread GitBox
blublinsky commented on pull request #14284: URL: https://github.com/apache/flink/pull/14284#issuecomment-779866878 Yes, thank you This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #14947: [BP-1.12][FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot commented on pull request #14947: URL: https://github.com/apache/flink/pull/14947#issuecomment-779866301 ## CI report: * 16aff33df0ad3527e2115438037417ba3d25d47c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14946: [FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

2021-02-16 Thread GitBox
flinkbot commented on pull request #14946: URL: https://github.com/apache/flink/pull/14946#issuecomment-779866080 ## CI report: * 3acf861c7e288f9ce7c3b0fec5bc513c75ea8f18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-02-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285195#comment-17285195 ] Piotr Nowojski edited comment on FLINK-21132 at 2/16/21, 2:12 PM: --

[jira] [Comment Edited] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-02-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285195#comment-17285195 ] Piotr Nowojski edited comment on FLINK-21132 at 2/16/21, 2:12 PM: --

  1   2   >