[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * b2d8f3d7657f62c44cfaeab31ccf7c5166ea184b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * 4ee2dc3ec2f22731b83709c2b82343849a36ab2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * 4ee2dc3ec2f22731b83709c2b82343849a36ab2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * 4ee2dc3ec2f22731b83709c2b82343849a36ab2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19313: [WIP][FLINK-26966][heap/state] Implement incremental checkpoints

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19313: URL: https://github.com/apache/flink/pull/19313#issuecomment-1084823301 ## CI report: * f824a8263eef497fb6993f7d909a31675df786f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19312: [FLINK-26965][state] Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19312: URL: https://github.com/apache/flink/pull/19312#issuecomment-1084814274 ## CI report: * ae81d9cd3365947f0e1d129599296d716d46a77e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19311: [FLINK-26968][state/heap] Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19311: URL: https://github.com/apache/flink/pull/19311#issuecomment-1084802860 ## CI report: * 49e0e87592da9da114634b8fd7a519af186d8292 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * c88402046367076a32075719ed69ebc75634a142 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19303: [FLINK-26961][connectors][filesystems][formats] Update multiple Jacks…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19303: URL: https://github.com/apache/flink/pull/19303#issuecomment-1084622464 ## CI report: * c88402046367076a32075719ed69ebc75634a142 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19310: [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19310: URL: https://github.com/apache/flink/pull/19310#issuecomment-1084802557 ## CI report: * d966cba96df250f85b237192e6b60ff5a18b77ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19308: [FLINK-26963][state/heap] Allow backend creation customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19308: URL: https://github.com/apache/flink/pull/19308#issuecomment-1084786542 ## CI report: * 9adda4c741d5694f6bdc25dc4c8780c609322c9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19309: URL: https://github.com/apache/flink/pull/19309#issuecomment-1084794264 ## CI report: * 588fbdaa49ab59feb67a1ff3106b27cf92ba8989 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19307: [FLINK-21784][state/heap] Allow Restore Operation customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19307: URL: https://github.com/apache/flink/pull/19307#issuecomment-1084778059 ## CI report: * 1fda6db974897cf99f3355056aba10df2a0c90eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * 0e6ba688dc8c46ad83139d5e6d9c5756763186e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19306: [FLINK-21783][state/heap] Allow snapshotting customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19306: URL: https://github.com/apache/flink/pull/19306#issuecomment-1084777915 ## CI report: * 92d3eabc679d7974e35254158561d48a8ad615ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19305: [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19305: URL: https://github.com/apache/flink/pull/19305#issuecomment-1084771084 ## CI report: * f0e9c27bf807966a742bd22bf02dc600950f28ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 260828cb024e0a9d71dd61296fd4e4200545d6fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19177: [FLINK-23399][state] Add a benchmark for rescaling

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19177: URL: https://github.com/apache/flink/pull/19177#issuecomment-1073539671 ## CI report: * 1012ead6db20e77f4fa95ebcc92fd3f23e59cc11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19304: [FLINK-26957][runtime] Removes flush in FileSystemJobResultStore.createDirtyResultInternal

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19304: URL: https://github.com/apache/flink/pull/19304#issuecomment-1084756618 ## CI report: * 5d65fa86a1259cd82b90a7213359dea92b42c555 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19263: [FLINK-21585][metrics] Add options for in-/excluding metrics

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19263: URL: https://github.com/apache/flink/pull/19263#issuecomment-1081065491 ## CI report: * 8eda65b9d6af64aafa22c855e8177f2eacbaf1d0 Azure:

[GitHub] [flink] matriv commented on a change in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-03-31 Thread GitBox
matriv commented on a change in pull request #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r839874307 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/CallContext.java ## @@ -93,6 +93,17 @@ default

[GitHub] [flink-connector-elasticsearch] JingGe edited a comment on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo

2022-03-31 Thread GitBox
JingGe edited a comment on pull request #2: URL: https://github.com/apache/flink-connector-elasticsearch/pull/2#issuecomment-1084815636 > @JingGe I was testing a bit with a build pipeline and ran a convergence check. That actually fails. I ran `mvn clean install

[GitHub] [flink] matriv commented on a change in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-03-31 Thread GitBox
matriv commented on a change in pull request #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r839868945 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ToTimestampLtzTypeStrategy.java ## @@ -0,0

[GitHub] [flink] matriv commented on a change in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-03-31 Thread GitBox
matriv commented on a change in pull request #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r839867430 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java ## @@ -1222,76 +1231,103 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18447: FLINK-25762 - [Deployment/kubernetes] Move JVM system properties args after log_settings

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #18447: URL: https://github.com/apache/flink/pull/18447#issuecomment-1019286035 ## CI report: * a168598144a27e60275af35a5ab75b0cffa32066 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19302: [FLINK-26810][connectors/elasticsearch] Use local timezone for TIMESTAMP_WITH_LOCAL_TIMEZONE fields in dynamic index

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19302: URL: https://github.com/apache/flink/pull/19302#issuecomment-1084520142 ## CI report: * 8b0b0152e957da57276f6e79f0fa7f50fcf8794e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19301: [FLINK-17231][kubernetes]When using LB Service, the optimization of returning RestEndpoint

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19301: URL: https://github.com/apache/flink/pull/19301#issuecomment-1084505731 ## CI report: * 40a69ea6f5a03415dbfdb027391ce97f85a8df60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19300: [hotfix] [connectors/hbase] Fix equal method of HBaseWriteOptions

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19300: URL: https://github.com/apache/flink/pull/19300#issuecomment-1084485960 ## CI report: * 6499e3aa3e17cbb7b7da00b501c8ab0818053ab4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19263: [FLINK-21585][metrics] Add options for in-/excluding metrics

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19263: URL: https://github.com/apache/flink/pull/19263#issuecomment-1081065491 ## CI report: * 8eda65b9d6af64aafa22c855e8177f2eacbaf1d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19313: [WIP][FLINK-26966][heap/state] Implement incremental checkpoints

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19313: URL: https://github.com/apache/flink/pull/19313#issuecomment-1084823301 ## CI report: * f824a8263eef497fb6993f7d909a31675df786f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 30b31e5172e45bb499f403fdd73e85004b2b3c59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19263: [FLINK-21585][metrics] Add options for in-/excluding metrics

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19263: URL: https://github.com/apache/flink/pull/19263#issuecomment-1081065491 ## CI report: * 8eda65b9d6af64aafa22c855e8177f2eacbaf1d0 Azure:

[GitHub] [flink] flinkbot commented on pull request #19313: [WIP][FLINK-26966][heap/state] Implement incremental checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #19312: [FLINK-26965][state] Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19312: URL: https://github.com/apache/flink/pull/19312#issuecomment-1084814274 ## CI report: * ae81d9cd3365947f0e1d129599296d716d46a77e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19286: URL: https://github.com/apache/flink/pull/19286#issuecomment-1083653731 ## CI report: * 6ec4b0b242c099430437047c449a1ee3402ba0dc Azure:

[GitHub] [flink] zentol commented on pull request #19263: [FLINK-21585][metrics] Add options for in-/excluding metrics

2022-03-31 Thread GitBox
zentol commented on pull request #19263: URL: https://github.com/apache/flink/pull/19263#issuecomment-1084822152 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-26963) Allow HeapBackend creation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26963: -- Summary: Allow HeapBackend creation customization (was: Allow HeapState backend

[jira] [Updated] (FLINK-26963) Allow HeapState backend creation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26963: -- Summary: Allow HeapState backend creation customization (was: Allow heap state

[jira] [Updated] (FLINK-26966) Implement incremental checkpoints

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26966: --- Labels: pull-request-available (was: ) > Implement incremental checkpoints >

[GitHub] [flink] rkhachatryan opened a new pull request #19313: [WIP][FLINK-26966][heap/state] Implement incremental checkpoints

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19313: URL: https://github.com/apache/flink/pull/19313 This PR includes all the commits from other tickets. -- 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-connector-elasticsearch] JingGe commented on pull request #2: [Flink-26884][draft] move elasticsearch connectors to the external repo

2022-03-31 Thread GitBox
JingGe commented on pull request #2: URL: https://github.com/apache/flink-connector-elasticsearch/pull/2#issuecomment-1084815636 > @JingGe I was testing a bit with a build pipeline and ran a convergence check. That actually fails. I ran `mvn clean install

[jira] [Assigned] (FLINK-21784) Allow HeapBackend RestoreOperation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21784: - Assignee: Roman Khachatryan > Allow HeapBackend RestoreOperation customization

[jira] [Assigned] (FLINK-21783) Allow HeapBackend snapshotting customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21783: - Assignee: Roman Khachatryan > Allow HeapBackend snapshotting customization >

[jira] [Assigned] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26964: - Assignee: Roman Khachatryan > Notify CheckpointStrategy about checkpoint

[GitHub] [flink] flinkbot commented on pull request #19312: [FLINK-26965][state] Allow reuse of PeriodicMaterializationManager

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

[jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21784: -- Fix Version/s: 1.16.0 > Allow HeapBackend RestoreOperation customization >

[jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21783: -- Fix Version/s: 1.16.0 > Allow HeapBackend snapshotting customization >

[GitHub] [flink] flinkbot edited a comment on pull request #19311: [FLINK-26968][state/heap] Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19311: URL: https://github.com/apache/flink/pull/19311#issuecomment-1084802860 ## CI report: * 49e0e87592da9da114634b8fd7a519af186d8292 Azure:

[jira] [Assigned] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26968: - Assignee: Roman Khachatryan > Bump CopyOnWriteStateMap entry version before

[jira] [Assigned] (FLINK-26965) Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26965: - Assignee: Roman Khachatryan > Allow reuse of PeriodicMaterializationManager >

[jira] [Assigned] (FLINK-26967) Fix race condition in CopyOnWriteStateMap

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26967: - Assignee: Roman Khachatryan > Fix race condition in CopyOnWriteStateMap >

[jira] [Updated] (FLINK-26963) Allow heap state backend creation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26963: -- Description: Incremental Heap State Backend needs to customize SnapshotStrategy and

[GitHub] [flink] flinkbot edited a comment on pull request #19310: [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19310: URL: https://github.com/apache/flink/pull/19310#issuecomment-1084802557 ## CI report: * d966cba96df250f85b237192e6b60ff5a18b77ba Azure:

[jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21649: -- Summary: Allow extension of CopyOnWrite state classes (was: Refactor CopyOnWrite

[jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21783: -- Description: Allow customization of snapshotting of HeapKeyedStateBackend so that it

[jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21783: -- Summary: Allow HeapBackend snapshotting customization (was: Allow extension of

[jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21784: -- Description: Allow customization of HeapRestoreOperation to be able to restore from

[jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21784: -- Summary: Allow HeapBackend RestoreOperation customization (was: Allow extension of

[GitHub] [flink] flinkbot commented on pull request #19311: [FLINK-26968][state/heap] Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread GitBox
flinkbot commented on pull request #19311: URL: https://github.com/apache/flink/pull/19311#issuecomment-1084802860 ## CI report: * 49e0e87592da9da114634b8fd7a519af186d8292 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #19310: [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap

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

[GitHub] [flink] flinkbot edited a comment on pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19309: URL: https://github.com/apache/flink/pull/19309#issuecomment-1084794264 ## CI report: * 588fbdaa49ab59feb67a1ff3106b27cf92ba8989 Azure:

[jira] [Updated] (FLINK-26965) Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26965: -- Description: The same approach that is used with Changelog can be used with other

[jira] [Updated] (FLINK-26965) Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26965: --- Labels: pull-request-available (was: ) > Allow reuse of PeriodicMaterializationManager >

[GitHub] [flink] rkhachatryan opened a new pull request #19312: [FLINK-26965][state] Allow reuse of PeriodicMaterializationManager

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19312: URL: https://github.com/apache/flink/pull/19312 ## What is the purpose of the change The same approach that is used with Changelog can be used with other state backends too, in particular IncrementalHeapStateBackend (FLIP-151).

[jira] [Commented] (FLINK-26953) Introduce Operator Specific Metrics

2022-03-31 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515421#comment-17515421 ] Matyas Orhidi commented on FLINK-26953: --- I haven't started working on this feature yet, but I'd

[jira] [Updated] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26968: --- Labels: pull-request-available (was: ) > Bump CopyOnWriteStateMap entry version before

[GitHub] [flink] rkhachatryan opened a new pull request #19311: [FLINK-26968][state/heap] Bump CopyOnWriteStateMap entry version before write

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19311: URL: https://github.com/apache/flink/pull/19311 ## What is the purpose of the change ``` CopyOnWriteStateMap copies the entry before returning it to the client for update. This also updates its state and entry versions.

[GitHub] [flink] flinkbot commented on pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread GitBox
flinkbot commented on pull request #19309: URL: https://github.com/apache/flink/pull/19309#issuecomment-1084794264 ## CI report: * 588fbdaa49ab59feb67a1ff3106b27cf92ba8989 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19308: [FLINK-26963][state/heap] Allow backend creation customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19308: URL: https://github.com/apache/flink/pull/19308#issuecomment-1084786542 ## CI report: * 9adda4c741d5694f6bdc25dc4c8780c609322c9f Azure:

[jira] [Updated] (FLINK-26967) Fix race condition in CopyOnWriteStateMap

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26967: --- Labels: pull-request-available (was: ) > Fix race condition in CopyOnWriteStateMap >

[GitHub] [flink] rkhachatryan opened a new pull request #19310: [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19310: URL: https://github.com/apache/flink/pull/19310 ## What is the purpose of the change ``` Currently, handling chained entry on copy-on-write uses object identity to find the wanted entry in the chain. However, if the same method

[jira] [Updated] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26964: -- Description: Notifications could be used by incremental snapshot strategy to replace

[jira] [Updated] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26964: --- Labels: pull-request-available (was: ) > Notify CheckpointStrategy about checkpoint

[GitHub] [flink] rkhachatryan opened a new pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19309: URL: https://github.com/apache/flink/pull/19309 ## What is the purpose of the change Notifications could be used by incremental snapshot strategy to replace state handles with placeholders. Please see

[GitHub] [flink] flinkbot commented on pull request #19308: [FLINK-26963][state/heap] Allow backend creation customization

2022-03-31 Thread GitBox
flinkbot commented on pull request #19308: URL: https://github.com/apache/flink/pull/19308#issuecomment-1084786542 ## CI report: * 9adda4c741d5694f6bdc25dc4c8780c609322c9f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19306: [FLINK-21783][state/heap] Allow snapshotting customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19306: URL: https://github.com/apache/flink/pull/19306#issuecomment-1084777915 ## CI report: * 92d3eabc679d7974e35254158561d48a8ad615ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19307: [FLINK-21784][state/heap] Allow Restore Operation customization

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19307: URL: https://github.com/apache/flink/pull/19307#issuecomment-1084778059 ## CI report: * 1fda6db974897cf99f3355056aba10df2a0c90eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * f7a5a653dbb0ea3196878c51b272b1aa5631b635 Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #19308: [FLINK-26963][state/heap] Allow backend creation customization

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19308: URL: https://github.com/apache/flink/pull/19308 This PR depends on #19306 and #19307 - so it should not be merged before them. Please ignore the first 3 commits. ## What is the purpose of the change Allow customization of Heap

[jira] [Updated] (FLINK-26963) Allow heap state backend creation customization

2022-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26963: --- Labels: pull-request-available (was: ) > Allow heap state backend creation customization >

[GitHub] [flink] flinkbot commented on pull request #19307: [FLINK-21784][state/heap] Allow Restore Operation customization

2022-03-31 Thread GitBox
flinkbot commented on pull request #19307: URL: https://github.com/apache/flink/pull/19307#issuecomment-1084778059 ## CI report: * 1fda6db974897cf99f3355056aba10df2a0c90eb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #19306: [FLINK-21783][state/heap] Allow snapshotting customization

2022-03-31 Thread GitBox
flinkbot commented on pull request #19306: URL: https://github.com/apache/flink/pull/19306#issuecomment-1084777915 ## CI report: * 92d3eabc679d7974e35254158561d48a8ad615ed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19305: [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19305: URL: https://github.com/apache/flink/pull/19305#issuecomment-1084771084 ## CI report: * f0e9c27bf807966a742bd22bf02dc600950f28ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 30b31e5172e45bb499f403fdd73e85004b2b3c59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * f7a5a653dbb0ea3196878c51b272b1aa5631b635 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4f6c6a12e9e1e7287bbbd03cb36eb3f2e171d577 Azure:

[GitHub] [flink] rkhachatryan commented on pull request #15209: [FLINK-21784] Allow extension of HeapBackend RestoreOperation

2022-03-31 Thread GitBox
rkhachatryan commented on pull request #15209: URL: https://github.com/apache/flink/pull/15209#issuecomment-1084773392 Obsoleted by #19307. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] rkhachatryan opened a new pull request #19307: [FLINK-21784][state/heap] Allow Restore Operation customization

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19307: URL: https://github.com/apache/flink/pull/19307 ## What is the purpose of the change Allow customization of HeapRestoreOperation to be able to restore from incremental checkpoints. Please see

[GitHub] [flink] rkhachatryan closed pull request #15209: [FLINK-21784] Allow extension of HeapBackend RestoreOperation

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

[GitHub] [flink] flinkbot commented on pull request #19305: [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes

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

[GitHub] [flink] rkhachatryan commented on pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

2022-03-31 Thread GitBox
rkhachatryan commented on pull request #15204: URL: https://github.com/apache/flink/pull/15204#issuecomment-1084770424 Obsoleted by #19306. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] rkhachatryan closed pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 30b31e5172e45bb499f403fdd73e85004b2b3c59 Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #19306: [FLINK-21783][state/heap] Allow snapshotting customization

2022-03-31 Thread GitBox
rkhachatryan opened a new pull request #19306: URL: https://github.com/apache/flink/pull/19306 ## What is the purpose of the change Allow customization of snapshotting of HeapKeyedStateBackend so that it can be snapshotted incrementally. Please see

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-31 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4f6c6a12e9e1e7287bbbd03cb36eb3f2e171d577 Azure:

[jira] [Updated] (FLINK-21649) Refactor CopyOnWrite state classes

2022-03-31 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-21649: -- Fix Version/s: 1.16.0 > Refactor CopyOnWrite state classes >

[GitHub] [flink] imaffe commented on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-31 Thread GitBox
imaffe commented on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1084765797 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] rkhachatryan commented on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2022-03-31 Thread GitBox
rkhachatryan commented on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-1084765157 Obsoleted by #19305. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] rkhachatryan closed pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

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

[GitHub] [flink] rkhachatryan removed a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2022-03-31 Thread GitBox
rkhachatryan removed a comment on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-1084764698 Obsoleted by #19305. -- 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

<    1   2   3   4   5   6   >