[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 1550e7e6200bfcac3cf20f3e930d77da1a5874e4 Azure:

[jira] [Comment Edited] (FLINK-21565) Support more integer types in TIMESTAMPADD

[ https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441496#comment-17441496 ] Shen Zhu edited comment on FLINK-21565 at 11/10/21, 6:17 PM: - Hi

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[jira] [Closed] (FLINK-24834) Add typed builders to DefaultRollingPolicy

[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24834. Resolution: Fixed > Add typed builders to DefaultRollingPolicy >

[jira] [Commented] (FLINK-24834) Add typed builders to DefaultRollingPolicy

[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441880#comment-17441880 ] Seth Wiesman commented on FLINK-24834: -- fixed in 059c00f4f6bbf0b868d4d8e0971e29d0168894f9 > Add

[GitHub] [flink] sjwiesman closed pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

sjwiesman closed pull request #17731: URL: https://github.com/apache/flink/pull/17731 -- 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 #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17737: [FLINK-24690][runtime] Changed the calculation of reaching buffer deb…

flinkbot edited a comment on pull request #17737: URL: https://github.com/apache/flink/pull/17737#issuecomment-964187026 ## CI report: * 52014f830644d86a025d17ab75cdad0b8c149e31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17737: [FLINK-24690][runtime] Changed the calculation of reaching buffer deb…

flinkbot edited a comment on pull request #17737: URL: https://github.com/apache/flink/pull/17737#issuecomment-964187026 ## CI report: * 52014f830644d86a025d17ab75cdad0b8c149e31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 9af1d2909eec24ade6c5278bd5a0e243b26a2c17 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

flinkbot edited a comment on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963552076 ## CI report: * 4bd48df95f9e5c57477ab8ee61f530d604619112 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * 29cfbf799f0382c482c671d1ebed320777e0082b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441866#comment-17441866 ] Anton Kalashnikov commented on FLINK-24800: --- I have fixed the test but the problem is not the

[GitHub] [flink] rkhachatryan commented on a change in pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

rkhachatryan commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r746822965 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -387,6 +390,13 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

rkhachatryan commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r746821004 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/UploadThrottle.java ## @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * a0118aca6247e0b384cd3271da70594156f6f74f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17755: [FLINK-24858][core] Prevent version mismatches in TypeSerializers

flinkbot edited a comment on pull request #17755: URL: https://github.com/apache/flink/pull/17755#issuecomment-965205123 ## CI report: * 08dff354c74129edcdcfe40322f31c1d8adf2831 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[GitHub] [flink] flinkbot commented on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

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

[GitHub] [flink] flinkbot commented on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot commented on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965565952 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 #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

[jira] [Commented] (FLINK-24866) AZP crashed in Post-job: Cache Maven local repo

[ https://issues.apache.org/jira/browse/FLINK-24866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441852#comment-17441852 ] Chesnay Schepler commented on FLINK-24866: -- No, this happened in the e2e profile which doesn't

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[jira] [Updated] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

[ https://issues.apache.org/jira/browse/FLINK-24608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24608: --- Labels: pull-request-available (was: ) > Sinks built with the unified sink framework do

[GitHub] [flink] matriv opened a new pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

matriv opened a new pull request #17759: URL: https://github.com/apache/flink/pull/17759 ## What is the purpose of the change Previously, sinks built using the unified sink framework were missing the `timestamp` from the `StreamRecord` when used with `TableAPI`. Introduce a

[GitHub] [flink] flinkbot edited a comment on pull request #17758: [FLINK-24800][runtime] Changed the assert condition for checking buff…

flinkbot edited a comment on pull request #17758: URL: https://github.com/apache/flink/pull/17758#issuecomment-96715 ## CI report: * cb8faf10ab2a1e4dc5f9e1529cfe1fd19f08ebf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17737: [FLINK-24690][runtime] Changed the calculation of reaching buffer deb…

flinkbot edited a comment on pull request #17737: URL: https://github.com/apache/flink/pull/17737#issuecomment-964187026 ## CI report: * 52014f830644d86a025d17ab75cdad0b8c149e31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot commented on pull request #17758: [FLINK-24800][runtime] Changed the assert condition for checking buff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot commented on pull request #17758: [FLINK-24800][runtime] Changed the assert condition for checking buff…

flinkbot commented on pull request #17758: URL: https://github.com/apache/flink/pull/17758#issuecomment-965553421 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 #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * da3800ed083f10e70c10de50c1f77c2bd41c116a UNKNOWN * 643a25496b3c7ccce9f7c796a095fe5e5be83400 Azure:

[jira] [Updated] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] akalash opened a new pull request #17758: [FLINK-24800][runtime] Changed the assert condition for checking buff…

akalash opened a new pull request #17758: URL: https://github.com/apache/flink/pull/17758 …er timeout disabling test ## What is the purpose of the change *This PR fixes the testDisablingBufferTimeout assert condition* ## Brief change log - *Checked

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

flinkbot edited a comment on pull request #17424: URL: https://github.com/apache/flink/pull/17424#issuecomment-938516882 ## CI report: * 4bec22eb5e57d5b892a24b9253f0531df65bcf07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17752: [FLINK-24860][python] Fix the wrong position mappings in the Python UDTF

flinkbot edited a comment on pull request #17752: URL: https://github.com/apache/flink/pull/17752#issuecomment-965050937 ## CI report: * 1ef33b608f8f93a75a4333cd4ab9882ccfa3d3dd Azure:

[GitHub] [flink] zentol commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

zentol commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r746682643 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/SharedObjectsExtension.java ## @@ -0,0 +1,178

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

flinkbot edited a comment on pull request #17424: URL: https://github.com/apache/flink/pull/17424#issuecomment-938516882 ## CI report: * 4bec22eb5e57d5b892a24b9253f0531df65bcf07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 1550e7e6200bfcac3cf20f3e930d77da1a5874e4 Azure:

[GitHub] [flink] zentol commented on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

zentol commented on pull request #17424: URL: https://github.com/apache/flink/pull/17424#issuecomment-965539548 @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] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[jira] [Closed] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24621. Resolution: Won't Fix > JobManager fails to recover 1.13.1 checkpoint due to >

[GitHub] [flink] zentol commented on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

zentol commented on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-965538760 @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] flinkbot edited a comment on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

flinkbot edited a comment on pull request #17424: URL: https://github.com/apache/flink/pull/17424#issuecomment-938516882 ## CI report: * 4bec22eb5e57d5b892a24b9253f0531df65bcf07 Azure:

[jira] [Created] (FLINK-24868) Use custom serialization for storing checkpoint metadata in CompletedCheckpointStore

Dawid Wysakowicz created FLINK-24868: Summary: Use custom serialization for storing checkpoint metadata in CompletedCheckpointStore Key: FLINK-24868 URL: https://issues.apache.org/jira/browse/FLINK-24868

[GitHub] [flink] flinkbot edited a comment on pull request #17753: [hotfix][table-planner] Move EnrichedRowData to table-runtime

flinkbot edited a comment on pull request #17753: URL: https://github.com/apache/flink/pull/17753#issuecomment-965084875 ## CI report: * 37741459fe44ef88820d3296c65aa10c67a516e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 1550e7e6200bfcac3cf20f3e930d77da1a5874e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 6156cf1b1d8b716781ea118b49ac50ae84a687f1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

flinkbot edited a comment on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * 092e28e32428901c5eab1ff5c82c22ca67378ea4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17753: [hotfix][table-planner] Move EnrichedRowData to table-runtime

flinkbot edited a comment on pull request #17753: URL: https://github.com/apache/flink/pull/17753#issuecomment-965084875 ## CI report: * 37741459fe44ef88820d3296c65aa10c67a516e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 6156cf1b1d8b716781ea118b49ac50ae84a687f1 Azure:

[jira] [Commented] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441838#comment-17441838 ] Dawid Wysakowicz commented on FLINK-24621: -- I am taking the users reply as a confirmation it

[jira] [Comment Edited] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441838#comment-17441838 ] Dawid Wysakowicz edited comment on FLINK-24621 at 11/10/21, 4:43 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[jira] [Commented] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441835#comment-17441835 ] Danny Cranmer commented on FLINK-24639: --- Merged, thanks for the contribution [~jkarp]  > Improve

[jira] [Commented] (FLINK-24866) AZP crashed in Post-job: Cache Maven local repo

[ https://issues.apache.org/jira/browse/FLINK-24866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441834#comment-17441834 ] Till Rohrmann commented on FLINK-24866: --- [~chesnay] could this have something to do with your

[jira] [Updated] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24639: -- Fix Version/s: 1.15.0 > Improve assignment of Kinesis shards to subtasks >

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * 2db1ab776228ba573da1b098ef6692de3b583323 Azure:

[jira] [Assigned] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24639: - Assignee: John Karp > Improve assignment of Kinesis shards to subtasks >

[jira] [Resolved] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24639. --- Resolution: Done > Improve assignment of Kinesis shards to subtasks >

[jira] [Commented] (FLINK-24866) AZP crashed in Post-job: Cache Maven local repo

[ https://issues.apache.org/jira/browse/FLINK-24866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441833#comment-17441833 ] Till Rohrmann commented on FLINK-24866: --- Another instance:

[GitHub] [flink] slinkydeveloper commented on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

slinkydeveloper commented on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-965528168 @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

[GitHub] [flink] slinkydeveloper commented on pull request #17753: [hotfix][table-planner] Move EnrichedRowData to table-runtime

slinkydeveloper commented on pull request #17753: URL: https://github.com/apache/flink/pull/17753#issuecomment-965528102 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 6156cf1b1d8b716781ea118b49ac50ae84a687f1 Azure:

[GitHub] [flink] dannycranmer commented on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

dannycranmer commented on pull request #17583: URL: https://github.com/apache/flink/pull/17583#issuecomment-965527617 Thanks @john-karp, LGTM, merging. -- 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] dannycranmer merged pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

dannycranmer merged pull request #17583: URL: https://github.com/apache/flink/pull/17583 -- 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 #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * 2db1ab776228ba573da1b098ef6692de3b583323 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #17548: [FLINK-24383][streaming] Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

RocMarshal edited a comment on pull request #17548: URL: https://github.com/apache/flink/pull/17548#issuecomment-950549753 Hi, @twalthr @lirui-apache @klion26 Could you help me to check this pr ? Thank you. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] RocMarshal edited a comment on pull request #17463: [Hotfix] Fix typos.

RocMarshal edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-944947844 Hi, @klion26 @dianfu @twalthr , here is a minor typo. Would you like to help me to check it ? Thank you very much. -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17757: [FLINK-23486][state][metrics] Add metrics for the Changelog uploader

flinkbot edited a comment on pull request #17757: URL: https://github.com/apache/flink/pull/17757#issuecomment-965292588 ## CI report: * 2db1ab776228ba573da1b098ef6692de3b583323 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #17387: [FLINK-24864][metrics] Release TaskManagerJobMetricGroup with the last slot rather than task

rkhachatryan commented on a change in pull request #17387: URL: https://github.com/apache/flink/pull/17387#discussion_r746765941 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStorageMetricGroup.java ## @@ -0,0 +1,134 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17742: URL: https://github.com/apache/flink/pull/17742#issuecomment-964839558 ## CI report: * cdd8dceadd7e64914a304f735086bab40a270b2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * eb2f1b26cf8288ac59bfa05c2ce9a5be041a3706 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * c7f2992dc6d3c93f30b38a0be5b065bba300fbfc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17742: URL: https://github.com/apache/flink/pull/17742#issuecomment-964839558 ## CI report: * cdd8dceadd7e64914a304f735086bab40a270b2a Azure:

<    1   2   3   4   5   6   7   8   >