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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382460#comment-17382460 ] Aitozi commented on FLINK-22594: As far as i know , the OOMKilled metrics may be only available from k8s

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure:

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

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 @@ +/* + *

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

flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure:

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

flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure:

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

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

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

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

flinkbot edited a comment on pull request #16519: URL: https://github.com/apache/flink/pull/16519#issuecomment-881769475 ## CI report: * 0757adbd9a1f012b6ddf0b4b69276d6606a519c1 Azure:

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

[ 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`

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

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

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:

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

flinkbot edited a comment on pull request #16519: URL: https://github.com/apache/flink/pull/16519#issuecomment-881769475 ## CI report: * 0757adbd9a1f012b6ddf0b4b69276d6606a519c1 Azure:

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

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

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

flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * cdcfba208b727c8d6b5b0ebc880227cb054de525 Azure:

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

flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * 310f2f91af384c29412e7b9a8b7478866d4f470e Azure:

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

flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * 3825108332e414ec318fc1638b1989b732b0c88d Azure:

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

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

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

[ 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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382375#comment-17382375 ] Mans Singh commented on FLINK-23412: Please assign this issue to me.  Thanks > Improve sourceSink

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

[ 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:

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

[ 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:

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

flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * cdc17400ddab6a13932cd5b5d930f487f2c899b5 Azure:

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

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

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

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)

flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 25c523343780cd96be23cb394830a91cc1fb200b Azure:

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

[ 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 -

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

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:

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

flinkbot edited a comment on pull request #16518: URL: https://github.com/apache/flink/pull/16518#issuecomment-881579487 ## CI report: * 23ab649d4f802ee86f19cd6e690e5d607c708d27 Azure:

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

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

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

flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * ac91363f476031fe77b25495ffe48fae2de45d77 Azure:

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

flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * e3c6775999035e893e0e0360eaa7862e5d967f5d Azure:

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

flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * a3b1f3391fea3be3c40c92c95b0aab51398a91ad Azure:

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

flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure:

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

flinkbot edited a comment on pull request #15180: URL: https://github.com/apache/flink/pull/15180#issuecomment-798246847 ## CI report: * ac91363f476031fe77b25495ffe48fae2de45d77 Azure:

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

flinkbot edited a comment on pull request #15179: URL: https://github.com/apache/flink/pull/15179#issuecomment-798246629 ## CI report: * a3b1f3391fea3be3c40c92c95b0aab51398a91ad Azure:

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

flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * e3c6775999035e893e0e0360eaa7862e5d967f5d Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382298#comment-17382298 ] David Fricker commented on FLINK-21966: --- Is there anything we can do to help progress this ticket?

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

flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure:

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 1e1966be39449111528a8defdd5e2ac6af30aad6 Azure:

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

[ 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

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382277#comment-17382277 ] Chesnay Schepler commented on FLINK-22386: -- master: a8d2068553b928321faa4007dad27b26c45a9ebf

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

flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure:

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

[ 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

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:

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

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

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

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

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

flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 96356cd499ad194aaa30a45bd66333942a66a4c5 Azure:

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

[ 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

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

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

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

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 0fadf7d17e721375e1d554033c050a0f4e1b2ccc Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382238#comment-17382238 ] Stephan Ewen commented on FLINK-23402: -- [~twalthr] If we want to make this independent of

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:40 PM: For the

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

flinkbot edited a comment on pull request #15322: URL: https://github.com/apache/flink/pull/15322#issuecomment-804015738 ## CI report: * eb50427eca80dd62004e23945d5bbd7fadb97319 UNKNOWN * 96356cd499ad194aaa30a45bd66333942a66a4c5 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:37 PM: For the

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:36 PM: For the

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:35 PM: For the

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382147#comment-17382147 ] Stephan Ewen edited comment on FLINK-23402 at 7/16/21, 5:35 PM: For the

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

flinkbot edited a comment on pull request #16518: URL: https://github.com/apache/flink/pull/16518#issuecomment-881579487 ## CI report: * 23ab649d4f802ee86f19cd6e690e5d607c708d27 Azure:

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

flinkbot edited a comment on pull request #16515: URL: https://github.com/apache/flink/pull/16515#issuecomment-881388403 ## CI report: * ecbc5f4c3d73b0f56b2dc684688f046ca4a723ed Azure:

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

flinkbot edited a comment on pull request #16509: URL: https://github.com/apache/flink/pull/16509#issuecomment-880892007 ## CI report: * 13f32a4fe35fcb5707aa90dc98fe9ddce40821d8 Azure:

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

flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * b05d3e0d1cf8c5588f2b5dee70bf6fd99122bd5b Azure:

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

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

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

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

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

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

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

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 @@ +/* + *

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

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

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

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

flinkbot edited a comment on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881565395 ## CI report: * e1d04b1e5c6a1ba3904a1d405de62582841aea89 Azure:

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

flinkbot edited a comment on pull request #16509: URL: https://github.com/apache/flink/pull/16509#issuecomment-880892007 ## CI report: * 13f32a4fe35fcb5707aa90dc98fe9ddce40821d8 Azure:

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

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

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 7bbb5a7c9bf1b15106b2f83d001b98b0b2c14d4c Azure:

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

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

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

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

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

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

[ 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

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

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

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

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 7bbb5a7c9bf1b15106b2f83d001b98b0b2c14d4c Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382175#comment-17382175 ] Srinivasulu Punuru commented on FLINK-18568: [~rmetzger] This ticket is slightly different

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382167#comment-17382167 ] Srinivasulu Punuru commented on FLINK-18562: [~rmetzger] If this is ticket is still

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382164#comment-17382164 ] Timo Walther commented on FLINK-23402: -- Thanks for the second comment. That makes a lot of sense.

[jira] [Commented] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382162#comment-17382162 ] frank wang commented on FLINK-13400: [~lirui] i have submit pr about this issue

[jira] [Comment Edited] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382162#comment-17382162 ] frank wang edited comment on FLINK-13400 at 7/16/21, 3:51 PM: -- [~lirui] i

[jira] [Created] (FLINK-23411) Expose Flink checkpoint details metrics

Jun Qin created FLINK-23411: --- Summary: Expose Flink checkpoint details metrics Key: FLINK-23411 URL: https://issues.apache.org/jira/browse/FLINK-23411 Project: Flink Issue Type: Improvement

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

flinkbot commented on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-881542732 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 #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * d1de6d708b5ff108968142549b0a9074a13834db Azure:

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

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 7bbb5a7c9bf1b15106b2f83d001b98b0b2c14d4c Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382149#comment-17382149 ] Stephan Ewen commented on FLINK-23402: -- > Let's postpone POINTWISE_EDGES_PIPELINED and

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13400: --- Labels: auto-deprioritized-critical pull-request-available stale-major (was:

[GitHub] [flink] yiduwangkai opened a new pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

yiduwangkai opened a new pull request #16517: URL: https://github.com/apache/flink/pull/16517 What is the purpose of the change This pull request will remove all dependencies on Hive/Hadoop and replace catalog-related tests by a testing catalog Brief change log Add new module

[GitHub] [flink] flinkbot edited a comment on pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

flinkbot edited a comment on pull request #15191: URL: https://github.com/apache/flink/pull/15191#issuecomment-798521197 ## CI report: * 4759dbafe9cf13ab47617dba7bac08703418422e Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382148#comment-17382148 ] Timo Walther commented on FLINK-23402: -- Thanks for the feedback [~sewen]. I was also struggling

[jira] [Created] (FLINK-23410) Use a pool of KafkaProducers to commit Kafka Transactions

Jun Qin created FLINK-23410: --- Summary: Use a pool of KafkaProducers to commit Kafka Transactions Key: FLINK-23410 URL: https://issues.apache.org/jira/browse/FLINK-23410 Project: Flink Issue Type:

  1   2   3   >