[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][statsd] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15189: URL: https://github.com/apache/flink/pull/15189#issuecomment-798459150 ## CI report: * f7089222a33530ec555b266b06f0d94b238288a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15188: URL: https://github.com/apache/flink/pull/15188#issuecomment-798424651 ## CI report: * 6b3c0efce0ab7cd55e1023d08ef4e4077c7bfd27 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15183: [FLINK-21764][metrics][dropwizard] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15183: URL: https://github.com/apache/flink/pull/15183#issuecomment-798304217 ## CI report: * b1cdadcdfcd2f3ba4aacbe70187795db2657e4a8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15182: [FLINK-21761][metrics][influxdb] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15182: URL: https://github.com/apache/flink/pull/15182#issuecomment-798247313 ## CI report: * 90e71e1cacac3b0be387b451caf6b02582d10196 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15181: [FLINK-21760][metrics][jmx] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15181: URL: https://github.com/apache/flink/pull/15181#issuecomment-798247104 ## CI report: * 6e7942b9c3bb252df92eda86ec0bbef38dc2a3d2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * 310f2f91af384c29412e7b9a8b7478866d4f470e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e7d75466adcfc4270b4b08a906be16289af93a3b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 18ab78ac104482db9908100792390031b22ab911 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-21759) Add TestMetricGroup

2021-07-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21759. Resolution: Fixed master: 4a09019671188c82c96dea3232b5f35bb68296d1 > Add TestMetricGroup

[GitHub] [flink] zentol merged pull request #15177: [FLINK-21759][metrics][tests] Add TestMetricGroup

2021-07-16 Thread GitBox
zentol merged pull request #15177: URL: https://github.com/apache/flink/pull/15177 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Closed] (FLINK-21757) Extract LogicalScopeProvider interface from FrontMetricGroup

2021-07-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21757. Resolution: Fixed master: 860a13d270dff1b43e041f07db4884656e0d71bb > Extract LogicalScope

[GitHub] [flink] zentol merged pull request #15179: [FLINK-21757][metrics] Add LogicalScopeProvider interface

2021-07-16 Thread GitBox
zentol merged pull request #15179: URL: https://github.com/apache/flink/pull/15179 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-22594) Report oom killed pod in k8s resource manager

2021-07-16 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382460#comment-17382460 ] Aitozi commented on FLINK-22594: As far as i know , the OOMKilled metrics may be only av

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] yittg commented on a change in pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
yittg commented on a change in pull request #15501: URL: https://github.com/apache/flink/pull/15501#discussion_r671606296 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesSharedInformer.java ## @@ -0,0 +1,244 @@ +/* + * Li

[GitHub] [flink] flinkbot edited a comment on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] HuangXingBo commented on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

2021-07-16 Thread GitBox
HuangXingBo commented on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881802414 Thanks @Airblader for the review. @dianfu is familiar with PyFlink and he will help review this PR too. -- This is an automated message from the Apache Git Service. To res

[jira] [Created] (FLINK-23415) Shade kryo library to reduce class conflict

2021-07-16 Thread Aitozi (Jira)
Aitozi created FLINK-23415: -- Summary: Shade kryo library to reduce class conflict Key: FLINK-23415 URL: https://issues.apache.org/jira/browse/FLINK-23415 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16519: URL: https://github.com/apache/flink/pull/16519#issuecomment-881769475 ## CI report: * 0757adbd9a1f012b6ddf0b4b69276d6606a519c1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23246) Refactor the time indicator materialization

2021-07-16 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23246: --- Description: Refactor the time indicator materialization, including 1. Move `time_indicator` materi

[jira] [Created] (FLINK-23414) Split Match_ROWTIME return type converter into a separator class

2021-07-16 Thread JING ZHANG (Jira)
JING ZHANG created FLINK-23414: -- Summary: Split Match_ROWTIME return type converter into a separator class Key: FLINK-23414 URL: https://issues.apache.org/jira/browse/FLINK-23414 Project: Flink

[jira] [Created] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA

2021-07-16 Thread JING ZHANG (Jira)
JING ZHANG created FLINK-23413: -- Summary: Port RelTimeIndicatorConverter from SCALA to JAVA Key: FLINK-23413 URL: https://issues.apache.org/jira/browse/FLINK-23413 Project: Flink Issue Type: Sub

[GitHub] [flink] flinkbot edited a comment on pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16519: URL: https://github.com/apache/flink/pull/16519#issuecomment-881769475 ## CI report: * 0757adbd9a1f012b6ddf0b4b69276d6606a519c1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

2021-07-16 Thread GitBox
flinkbot commented on pull request #16519: URL: https://github.com/apache/flink/pull/16519#issuecomment-881769475 ## CI report: * 0757adbd9a1f012b6ddf0b4b69276d6606a519c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15177: [FLINK-21759][metrics][tests] Add TestMetricGroup

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * cdcfba208b727c8d6b5b0ebc880227cb054de525 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * 310f2f91af384c29412e7b9a8b7478866d4f470e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15179: [FLINK-21757][metrics] Add LogicalScopeProvider interface

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * 3825108332e414ec318fc1638b1989b732b0c88d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

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

[jira] [Updated] (FLINK-23412) Improve sourceSink description

2021-07-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23412: --- Labels: docuentation pull-request-available sink source table (was: docuentation sink sourc

[GitHub] [flink] mans2singh opened a new pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

2021-07-16 Thread GitBox
mans2singh opened a new pull request #16519: URL: https://github.com/apache/flink/pull/16519 ## What is the purpose of the change * Dynamic table sink and full stack example description improvement. ## Brief change log * Improved description of dynamic table sink and

[jira] [Created] (FLINK-23412) Improve sourceSink description

2021-07-16 Thread Mans Singh (Jira)
Mans Singh created FLINK-23412: -- Summary: Improve sourceSink description Key: FLINK-23412 URL: https://issues.apache.org/jira/browse/FLINK-23412 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-23412) Improve sourceSink description

2021-07-16 Thread Mans Singh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382375#comment-17382375 ] Mans Singh commented on FLINK-23412: Please assign this issue to me.  Thanks > Impr

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

2021-07-16 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22949: --- Labels: auto-deprioritized-blocker (was: stale-blocker) Priority: Critical (was: Bloc

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

2021-07-16 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14482: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * cdc17400ddab6a13932cd5b5d930f487f2c899b5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] NicoK edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-16 Thread GitBox
NicoK edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-881735379 Sorry @paul8263 for letting you wait. I think, the code looks good in general also with respect to improving how the different states are shown, solving FLINK-22527 and FLI

[GitHub] [flink] NicoK commented on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

2021-07-16 Thread GitBox
NicoK commented on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-881735379 Sorry @paul8263 for letting you wait. I think, the code looks good in general also with respect to improving how the different states are shown, solving FLINK-23101 along the way

[GitHub] [flink] flinkbot edited a comment on pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 25c523343780cd96be23cb394830a91cc1fb200b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-23311) Improve PojoSerializer test

2021-07-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23311. --- Resolution: Fixed Fixed on master via: - f8e11e1e57af2d638959eefe455751bb7354780a - a238be16c2f3a95f

[GitHub] [flink] NicoK merged pull request #16426: [FLINK-23311][tests] minor improvements around PojoSerializer tests

2021-07-16 Thread GitBox
NicoK merged pull request #16426: URL: https://github.com/apache/flink/pull/16426 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr.

[GitHub] [flink] flinkbot edited a comment on pull request #16518: [FLINK-23373][task] Fully support object reuse in OperatorChain

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16518: URL: https://github.com/apache/flink/pull/16518#issuecomment-881579487 ## CI report: * 23ab649d4f802ee86f19cd6e690e5d607c708d27 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16509: [WIP][FLINK-23403] Change default for heartbeat.timeout and heartbeat.interval

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16509: URL: https://github.com/apache/flink/pull/16509#issuecomment-880892007 ## CI report: * 4c3cd19b6230e13a85fb4ed01c7372b2b769c3bb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * ac91363f476031fe77b25495ffe48fae2de45d77 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15177: [FLINK-21759][metrics][tests] Add TestMetricGroup

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * e3c6775999035e893e0e0360eaa7862e5d967f5d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15179: [FLINK-21757][metrics] Add LogicalScopeProvider interface

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * a3b1f3391fea3be3c40c92c95b0aab51398a91ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * ac91363f476031fe77b25495ffe48fae2de45d77 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15179: [FLINK-21757][metrics] Add LogicalScopeProvider interface

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * a3b1f3391fea3be3c40c92c95b0aab51398a91ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15177: [FLINK-21759][metrics][tests] Add TestMetricGroup

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * e3c6775999035e893e0e0360eaa7862e5d967f5d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-21966) Support Kinesis connector in Python DataStream API.

2021-07-16 Thread David Fricker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382298#comment-17382298 ] David Fricker commented on FLINK-21966: --- Is there anything we can do to help progr

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-21776) Migrate all JobManagerJobMG instantiations to factory method

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

[GitHub] [flink] zentol merged pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

2021-07-16 Thread GitBox
zentol merged pull request #15191: URL: https://github.com/apache/flink/pull/15191 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Commented] (FLINK-22386) Introduce cache for docker images

2021-07-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382277#comment-17382277 ] Chesnay Schepler commented on FLINK-22386: -- master: a8d2068553b928321faa4007dad

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22386) Introduce cache for docker images

2021-07-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22386: - Fix Version/s: 1.14.0 > Introduce cache for docker images >

[GitHub] [flink] zentol merged pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

2021-07-16 Thread GitBox
zentol merged pull request #16332: URL: https://github.com/apache/flink/pull/16332 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] gaoyunhaii commented on pull request #16238: [FLINK-21084][runtime][checkpoint] Allows tasks to report finished snapshot if finished on restore

2021-07-16 Thread GitBox
gaoyunhaii commented on pull request #16238: URL: https://github.com/apache/flink/pull/16238#issuecomment-881637602 Very thanks @dawidwys for the review! :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Commented] (FLINK-13038) CEP WITHIN don’t support interval expression

2021-07-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382260#comment-17382260 ] 陈卓宇 commented on FLINK-13038: - Hello, our company is very interested in cep library. I hope

[GitHub] [flink] flinkbot edited a comment on pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 96356cd499ad194aaa30a45bd66333942a66a4c5 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-23137) State ownership: prevent private state deletion on JM

2021-07-16 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23137: -- Description: Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342

[GitHub] [flink] flinkbot edited a comment on pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881388403 ## CI report: * 2b535d1b7dd554a8777d1bcd5f6938986cac0bd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 0fadf7d17e721375e1d554033c050a0f4e1b2ccc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382238#comment-17382238 ] Stephan Ewen commented on FLINK-23402: -- [~twalthr] If we want to make this independ

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:40 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 96356cd499ad194aaa30a45bd66333942a66a4c5 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:37 PM: --

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:36 PM: --

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:35 PM: --

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:35 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #16518: [FLINK-23373][task] Fully support object reuse in OperatorChain

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16518: URL: https://github.com/apache/flink/pull/16518#issuecomment-881579487 ## CI report: * 23ab649d4f802ee86f19cd6e690e5d607c708d27 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881388403 ## CI report: * ecbc5f4c3d73b0f56b2dc684688f046ca4a723ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16509: [WIP][FLINK-23403] Change default for heartbeat.timeout and heartbeat.interval

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16509: URL: https://github.com/apache/flink/pull/16509#issuecomment-880892007 ## CI report: * 13f32a4fe35fcb5707aa90dc98fe9ddce40821d8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dmvk edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
dmvk edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-881588128 @yittg Great work, this looks really cool! I think we're almost finished, I have two minor comments, which I'd like to address. I'm off for the weekend, so I'll do a final p

[GitHub] [flink] dmvk commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
dmvk commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-881588128 @yittg Great work, this looks really great! I think we're almost finished, I have two minor comments, which I'd like to address. I'm off for the weekend, so I'll do a final pass on

[GitHub] [flink] dmvk commented on a change in pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
dmvk commented on a change in pull request #15501: URL: https://github.com/apache/flink/pull/15501#discussion_r671397630 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionAndRetrievalITCase.java ## @@ -52,17 +60,2

[GitHub] [flink] dmvk commented on a change in pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
dmvk commented on a change in pull request #15501: URL: https://github.com/apache/flink/pull/15501#discussion_r671396430 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesSharedInformer.java ## @@ -0,0 +1,244 @@ +/* + * Lic

[GitHub] [flink] Airblader commented on a change in pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

2021-07-16 Thread GitBox
Airblader commented on a change in pull request #16516: URL: https://github.com/apache/flink/pull/16516#discussion_r671391007 ## File path: flink-python/pyflink/table/catalog.py ## @@ -733,9 +734,22 @@ def get_schema(self) -> TableSchema: Get the schema of the table.

[GitHub] [flink] flinkbot commented on pull request #16518: [FLINK-23373][task] Fully support object reuse in OperatorChain

2021-07-16 Thread GitBox
flinkbot commented on pull request #16518: URL: https://github.com/apache/flink/pull/16518#issuecomment-881579487 ## CI report: * 23ab649d4f802ee86f19cd6e690e5d607c708d27 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16509: [WIP][FLINK-23403] Change default for heartbeat.timeout and heartbeat.interval

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #16509: URL: https://github.com/apache/flink/pull/16509#issuecomment-880892007 ## CI report: * 13f32a4fe35fcb5707aa90dc98fe9ddce40821d8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader commented on pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

2021-07-16 Thread GitBox
Airblader commented on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881577888 @twalthr Thanks for the review! I split it into two commits and also left `PriorityQueueStateType` where it was to prevent breakage here. I don't think we need to undo the cha

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 7bbb5a7c9bf1b15106b2f83d001b98b0b2c14d4c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader commented on a change in pull request #16515: [FLINK-23369][core][docs] Mechanism to document enums used in ConfigOptions

2021-07-16 Thread GitBox
Airblader commented on a change in pull request #16515: URL: https://github.com/apache/flink/pull/16515#discussion_r671387127 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java #

[GitHub] [flink] flinkbot commented on pull request #16518: [FLINK-23373][task] Fully support object reuse in OperatorChain

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

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-881566693 @dmvk I have push the new changes: 1. watch with executor service, share a cached pool in the ha service; 2. run add/update/delete event directly > One thing worth ment

[jira] [Updated] (FLINK-23373) Support object reuse disabled in OperatorChain

2021-07-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23373: --- Labels: pull-request-available (was: ) > Support object reuse disabled in OperatorChain > -

[GitHub] [flink] twalthr opened a new pull request #16518: [FLINK-23373][task] Fully support object reuse in OperatorChain

2021-07-16 Thread GitBox
twalthr opened a new pull request #16518: URL: https://github.com/apache/flink/pull/16518 ## What is the purpose of the change This adds the missing parts to make object reuse work in OperatorChain. ## Brief change log See commit messages. ## Verifying this change

[GitHub] [flink] flinkbot commented on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

2021-07-16 Thread GitBox
flinkbot commented on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

2021-07-16 Thread GitBox
flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 7bbb5a7c9bf1b15106b2f83d001b98b0b2c14d4c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

2021-07-16 Thread Srinivasulu Punuru (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382167#comment-17382167 ] Srinivasulu Punuru edited comment on FLINK-18562 at 7/16/21, 4:11 PM:

[jira] [Commented] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

2021-07-16 Thread Srinivasulu Punuru (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382175#comment-17382175 ] Srinivasulu Punuru commented on FLINK-18568: [~rmetzger] This ticket is slig

[GitHub] [flink-statefun] igalshilman closed pull request #243: [FLINK-23293] [core] Support extendable transports for remote invocations

2021-07-16 Thread GitBox
igalshilman closed pull request #243: URL: https://github.com/apache/flink-statefun/pull/243 -- 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: issue

[jira] [Commented] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

2021-07-16 Thread Srinivasulu Punuru (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382167#comment-17382167 ] Srinivasulu Punuru commented on FLINK-18562: [~rmetzger] If this is ticket i

[jira] [Comment Edited] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382164#comment-17382164 ] Timo Walther edited comment on FLINK-23402 at 7/16/21, 3:56 PM: --

[jira] [Commented] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

2021-07-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382164#comment-17382164 ] Timo Walther commented on FLINK-23402: -- Thanks for the second comment. That makes a

  1   2   3   >