[GitHub] [flink] flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589653271 ## CI report: * 1f9edd40377c412486126a329eb8ea2c5885326f Travis: [SUCCESS](https://travis-ci.com/flink

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386604078 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Repo

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 3f0a7c1bbd3f4124d82a75c22abcb6723ef6cda9 Travis: [FAILURE](https://travis-ci.com/flink-

[jira] [Updated] (FLINK-16390) Add `view` and `clear` methods to `PersistedTable`

[ https://issues.apache.org/jira/browse/FLINK-16390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16390: --- Labels: pull-request-available (was: ) > Add `view` and `clear` methods to `PersistedTable`

[GitHub] [flink-statefun] sjwiesman opened a new pull request #42: [FLINK-16390][sdk] Add view and clear methods to PersistedTable

sjwiesman opened a new pull request #42: [FLINK-16390][sdk] Add view and clear methods to PersistedTable URL: https://github.com/apache/flink-statefun/pull/42 Adds common collection methods to PersistedTable. These methods are already available on PersistedAppendingBuffer. Note: I

[jira] [Created] (FLINK-16390) Add `view` and `clear` methods to `PersistedTable`

Seth Wiesman created FLINK-16390: Summary: Add `view` and `clear` methods to `PersistedTable` Key: FLINK-16390 URL: https://issues.apache.org/jira/browse/FLINK-16390 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 46b60757e8d5c7b38f6c2fa04cf1b01dd4712a25 UNKNOWN

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049548#comment-17049548 ] Yun Tang commented on FLINK-16267: -- Hi [~czchen], I suspect the memory consumed by iter

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 3f0a7c1bbd3f4124d82a75c22abcb6723ef6cda9 Travis: [PENDING](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl

flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl URL: https://github.com/apache/flink/pull/11280#issuecomment-593373960 ## CI report: * 69161e40e90e997a26f113cb6da10f7815ebbe0f Travis: [FAILURE](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288#issuecomment-593469694 ## CI report: * 297617886bd9ad220b9d007704145dbf7f36a5fd Travis: [FAILURE](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 46b60757e8d5c7b38f6c2fa04cf1b01dd4712a25 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl

flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl URL: https://github.com/apache/flink/pull/11280#issuecomment-593373960 ## CI report: * 69161e40e90e997a26f113cb6da10f7815ebbe0f Travis: [FAILURE](https://travi

[jira] [Issue Comment Deleted] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sivaprasanna Sethuraman updated FLINK-16371: Comment: was deleted (was: Can someone please grant me access to Flink's J

[GitHub] [flink] flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589653271 ## CI report: * c80a4b33ca4fede8ccfb000deb81005bb8d83710 Travis: [FAILURE](https://travis-ci.com/flink

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049461#comment-17049461 ] Zhenqiu Huang commented on FLINK-16005: --- [~trohrmann] Yes you are right. hadoop.hd

[GitHub] [flink] flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-591843120 ## CI report: * 0017b8a8930024d0e9ce3355d050565a5007831d UNKNOWN * 978c6f00810a66a87325af6454e49e2f084e

[GitHub] [flink] flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288#issuecomment-593469694 ## CI report: * 297617886bd9ad220b9d007704145dbf7f36a5fd Travis: [PENDING](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner

flinkbot edited a comment on issue #11174: [FLINK-16199][sql] Support IS JSON predicate for blink planner URL: https://github.com/apache/flink/pull/11174#issuecomment-589653271 ## CI report: * c80a4b33ca4fede8ccfb000deb81005bb8d83710 Travis: [FAILURE](https://travis-ci.com/flink

[jira] [Commented] (FLINK-16373) EmbeddedLeaderService: IllegalStateException: The RPC connection is already closed

[ https://issues.apache.org/jira/browse/FLINK-16373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049426#comment-17049426 ] Robert Metzger commented on FLINK-16373: No tests have failed. But I wonder if t

[jira] [Resolved] (FLINK-16380) AZP: Python test fails on jdk11 nightly test (misc profile)

[ https://issues.apache.org/jira/browse/FLINK-16380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-16380. Resolution: Fixed Resolved in 195b0d03ad994a82baee8864c1fedf1ae68b0144 > AZP: Python test

[GitHub] [flink] flinkbot edited a comment on issue #11285: [FLINK-16189][e2e] Remove test logic from FlinkDistribution

flinkbot edited a comment on issue #11285: [FLINK-16189][e2e] Remove test logic from FlinkDistribution URL: https://github.com/apache/flink/pull/11285#issuecomment-593416064 ## CI report: * 281fa884afd6a76ece952ce5245227fec2d86bce Travis: [SUCCESS](https://travis-ci.com/flink-c

[GitHub] [flink] flinkbot edited a comment on issue #11283: [FLINK-16370][build] Only bundle javax as Java11-exclusive dependency

flinkbot edited a comment on issue #11283: [FLINK-16370][build] Only bundle javax as Java11-exclusive dependency URL: https://github.com/apache/flink/pull/11283#issuecomment-593407843 ## CI report: * eb4c6e3eb34669a43a745bf31dbf53821c061bf7 Travis: [SUCCESS](https://travis-ci.co

[GitHub] [flink] rmetzger merged pull request #11289: [FLINK-16380][AZP] Fix jdk11 switch

rmetzger merged pull request #11289: [FLINK-16380][AZP] Fix jdk11 switch URL: https://github.com/apache/flink/pull/11289 This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Commented] (FLINK-15621) State TTL: Remove deprecated option and method to disable TTL compaction filter

[ https://issues.apache.org/jira/browse/FLINK-15621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049398#comment-17049398 ] Arujit Pradhan commented on FLINK-15621:  Hi [~azagrebin], I have a doubt while

[GitHub] [flink] flinkbot edited a comment on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch

flinkbot edited a comment on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch URL: https://github.com/apache/flink/pull/11289#issuecomment-593487289 ## CI report: * d2a5e5a79767199d85b360a379f9760af2a05f4f Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151397312)

[GitHub] [flink] flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-591843120 ## CI report: * 0017b8a8930024d0e9ce3355d050565a5007831d UNKNOWN * 978c6f00810a66a87325af6454e49e2f084e

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 3f0a7c1bbd3f4124d82a75c22abcb6723ef6cda9 Travis: [PENDING](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 46b60757e8d5c7b38f6c2fa04cf1b01dd4712a25 UNKNOWN

[jira] [Created] (FLINK-16389) Bump Kafka 0.10 to 0.10.2.2

Chesnay Schepler created FLINK-16389: Summary: Bump Kafka 0.10 to 0.10.2.2 Key: FLINK-16389 URL: https://issues.apache.org/jira/browse/FLINK-16389 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16388) Bump orc-core to 1.4.5

Chesnay Schepler created FLINK-16388: Summary: Bump orc-core to 1.4.5 Key: FLINK-16388 URL: https://issues.apache.org/jira/browse/FLINK-16388 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch

flinkbot commented on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch URL: https://github.com/apache/flink/pull/11289#issuecomment-593487289 ## CI report: * d2a5e5a79767199d85b360a379f9760af2a05f4f UNKNOWN Bot commands The @flinkbot bot supports the following com

[GitHub] [flink] flinkbot commented on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot commented on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 3f0a7c1bbd3f4124d82a75c22abcb6723ef6cda9 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935 ## CI report: * aa1386ad6c2ed2774d659263d7684e777eaccd2d Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] flinkbot edited a comment on issue #11283: [FLINK-16370][build] Only bundle javax as Java11-exclusive dependency

flinkbot edited a comment on issue #11283: [FLINK-16370][build] Only bundle javax as Java11-exclusive dependency URL: https://github.com/apache/flink/pull/11283#issuecomment-593407843 ## CI report: * eb4c6e3eb34669a43a745bf31dbf53821c061bf7 Travis: [SUCCESS](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 46b60757e8d5c7b38f6c2fa04cf1b01dd4712a25 UNKNOWN

[jira] [Commented] (FLINK-16356) Some dependencies contain CVEs

[ https://issues.apache.org/jira/browse/FLINK-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049377#comment-17049377 ] Chesnay Schepler commented on FLINK-16356: -- Have you verified that the suggeste

[GitHub] [flink] flinkbot commented on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

flinkbot commented on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593483814 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-16379) Introduce fromValues in TableEnvironment

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

[GitHub] [flink] dawidwys opened a new pull request #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

dawidwys opened a new pull request #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290 ## What is the purpose of the change It introduces a fromValues method to the TableEnvironment similar to the VALUES clause in SQL.

[GitHub] [flink] flinkbot commented on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch

flinkbot commented on issue #11289: [FLINK-16380][AZP] Fix jdk11 switch URL: https://github.com/apache/flink/pull/11289#issuecomment-593478557 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

[GitHub] [flink] flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

flinkbot edited a comment on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288#issuecomment-593469694 ## CI report: * 297617886bd9ad220b9d007704145dbf7f36a5fd Travis: [PENDING](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl

flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl URL: https://github.com/apache/flink/pull/11280#issuecomment-593373960 ## CI report: * f5de98e8347bd4652b3ba5f91cd09281d621a72a Travis: [FAILURE](https://travi

[jira] [Updated] (FLINK-16380) AZP: Python test fails on jdk11 nightly test (misc profile)

[ https://issues.apache.org/jira/browse/FLINK-16380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16380: --- Labels: pull-request-available (was: ) > AZP: Python test fails on jdk11 nightly test (misc

[jira] [Commented] (FLINK-16356) Some dependencies contain CVEs

[ https://issues.apache.org/jira/browse/FLINK-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049356#comment-17049356 ] XuCongying commented on FLINK-16356: I found that the buggy methods of the CVEs are

[jira] [Updated] (FLINK-16356) Some dependencies contain CVEs

[ https://issues.apache.org/jira/browse/FLINK-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] XuCongying updated FLINK-16356: --- Attachment: apache-flink_CVE-report.md > Some dependencies contain CVEs > --

[GitHub] [flink] rmetzger opened a new pull request #11289: [FLINK-16380][AZP] Fix jdk11 switch

rmetzger opened a new pull request #11289: [FLINK-16380][AZP] Fix jdk11 switch URL: https://github.com/apache/flink/pull/11289 ## What is the purpose of the change - Fix the failing python tests in the jdk11 profile ## Brief change log - fix issue in setting the java

[jira] [Commented] (FLINK-16373) EmbeddedLeaderService: IllegalStateException: The RPC connection is already closed

[ https://issues.apache.org/jira/browse/FLINK-16373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049347#comment-17049347 ] Chesnay Schepler commented on FLINK-16373: -- Please list which tests have failed

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386477670 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386474188 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/fli

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386479537 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386472491 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386477745 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386469696 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386472702 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386467901 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/T

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386471891 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386469003 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386465432 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386474722 ## File path: flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/src/t

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386468691 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/T

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386477973 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386478652 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386476291 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoader.

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386479500 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386469740 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/Report

[GitHub] [flink] zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

zentol commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r386474591 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot commented on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

flinkbot commented on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288#issuecomment-593469694 ## CI report: * 297617886bd9ad220b9d007704145dbf7f36a5fd UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl

flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl URL: https://github.com/apache/flink/pull/11280#issuecomment-593373960 ## CI report: * f5de98e8347bd4652b3ba5f91cd09281d621a72a Travis: [FAILURE](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11282: [FLINK-16204][sql] Support JSON_ARRAY for blink planner

flinkbot edited a comment on issue #11282: [FLINK-16204][sql] Support JSON_ARRAY for blink planner URL: https://github.com/apache/flink/pull/11282#issuecomment-593391863 ## CI report: * 404e0dea038898a1f542f7e202a1933500a9e4fe Travis: [SUCCESS](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 94c9a0247c9dcb9b467ba2629a98677a69679a2b Travis: [CANCELED](https://travis-ci.

[GitHub] [flink] flinkbot commented on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

flinkbot commented on issue #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288#issuecomment-593460725 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] flinkbot edited a comment on issue #11281: [FLINK-16203][sql] Support JSON_OBJECT for blink planner

flinkbot edited a comment on issue #11281: [FLINK-16203][sql] Support JSON_OBJECT for blink planner URL: https://github.com/apache/flink/pull/11281#issuecomment-593379717 ## CI report: * ccac1a1c139b1bb38b7d8f13ca065a100f669bc9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl

flinkbot edited a comment on issue #11280: [FLINK-16377][table] Support inline user defined functions in expression dsl URL: https://github.com/apache/flink/pull/11280#issuecomment-593373960 ## CI report: * f5de98e8347bd4652b3ba5f91cd09281d621a72a Travis: [FAILURE](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink.

flinkbot edited a comment on issue #11223: [FLINK-16281][Table SQL / Ecosystem] parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink. URL: https://github.com/apache/flink/pull/11223#issuecomment-591439360 ## CI report: * 46b60757e8d5c7b38f6c2fa04cf1b01dd4712a25 UNKNOWN

[GitHub] [flink] zentol opened a new pull request #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5

zentol opened a new pull request #11288: [FLINK-16350][e2e] Run half of streaming HA tests against ZK 3.5 URL: https://github.com/apache/flink/pull/11288 This is an automated message from the Apache Git Service. To respond t

[jira] [Updated] (FLINK-16350) Add E2E test for running against Zookeeper 3.5

[ https://issues.apache.org/jira/browse/FLINK-16350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16350: --- Labels: pull-request-available (was: ) > Add E2E test for running against Zookeeper 3.5 > -

[GitHub] [flink] zentol commented on issue #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java

zentol commented on issue #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java URL: https://github.com/apache/flink/pull/11286#issuecomment-593458352 Just like last time, we should first evaluated whether the test should be adjusted instead. Plea

[GitHub] [flink] zentol closed pull request #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java

zentol closed pull request #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java URL: https://github.com/apache/flink/pull/11287 This is an automated message from the Apache Git Service

[GitHub] [flink] zentol commented on issue #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java

zentol commented on issue #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java URL: https://github.com/apache/flink/pull/11287#issuecomment-593458323 Just like last time, we should first evaluated whether the test should be adjusted instead. P

[GitHub] [flink] zentol closed pull request #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java

zentol closed pull request #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java URL: https://github.com/apache/flink/pull/11286 This is an automated message from the Apache Git Service. T

[GitHub] [flink] flinkbot commented on issue #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java

flinkbot commented on issue #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java URL: https://github.com/apache/flink/pull/11287#issuecomment-593455514 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[jira] [Updated] (FLINK-16387) Use LinkedHashMap for deterministic order in HeapMapState.java

[ https://issues.apache.org/jira/browse/FLINK-16387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16387: --- Labels: pull-request-available (was: ) > Use LinkedHashMap for deterministic order in HeapM

[GitHub] [flink] cpugputpu opened a new pull request #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java

cpugputpu opened a new pull request #11287: [FLINK-16387][runtime]Use LinkedHashMap for deterministic order in HeapMapState.java URL: https://github.com/apache/flink/pull/11287 ## What is the purpose of the change This PR aims to solve the issue here: https://issues.apache.org/jira/brow

[GitHub] [flink] tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory URL: https://github.com/apache/flink/pull/11189#discussion_r386453071 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/

[jira] [Assigned] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

[ https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-10429: Assignee: (was: Gary Yao) > Redesign Flink Scheduling, introducing dedicated Scheduler compon

[GitHub] [flink] flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935 ## CI report: * aa1386ad6c2ed2774d659263d7684e777eaccd2d Travis: [PENDING](https://travis-ci.com/flink-ci/flink/buil

[GitHub] [flink] flinkbot edited a comment on issue #11282: [FLINK-16204][sql] Support JSON_ARRAY for blink planner

flinkbot edited a comment on issue #11282: [FLINK-16204][sql] Support JSON_ARRAY for blink planner URL: https://github.com/apache/flink/pull/11282#issuecomment-593391863 ## CI report: * 404e0dea038898a1f542f7e202a1933500a9e4fe Travis: [PENDING](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot commented on issue #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java

flinkbot commented on issue #11286: [FLINK-16386][sql]Use LinkedHashMap for deterministic order SqlFunctionUtils.java URL: https://github.com/apache/flink/pull/11286#issuecomment-593451623 ## CI report: * cee5408799c1924058e091489ae4311178d807f8 UNKNOWN Bot commands

[jira] [Updated] (FLINK-16387) Use LinkedHashMap for deterministic order in HeapMapState.java

[ https://issues.apache.org/jira/browse/FLINK-16387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] cpugputpu updated FLINK-16387: -- Description: The tests in  _org.apache.flink.table.runtime.operators.join.RowTimeBoundedStreamJoinTest

[jira] [Created] (FLINK-16387) Use LinkedHashMap for deterministic order in HeapMapState.java

cpugputpu created FLINK-16387: - Summary: Use LinkedHashMap for deterministic order in HeapMapState.java Key: FLINK-16387 URL: https://issues.apache.org/jira/browse/FLINK-16387 Project: Flink Iss

[jira] [Resolved] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14560. --- Resolution: Fixed Fixed via 272fccf44fd92fc9a2c7fa7465b2fcc430842427 > The value of taskman

[GitHub] [flink] flinkbot edited a comment on issue #11281: [FLINK-16203][sql] Support JSON_OBJECT for blink planner

flinkbot edited a comment on issue #11281: [FLINK-16203][sql] Support JSON_OBJECT for blink planner URL: https://github.com/apache/flink/pull/11281#issuecomment-593379717 ## CI report: * ccac1a1c139b1bb38b7d8f13ca065a100f669bc9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot commented on issue #11286: [FLINK-16386]Use LinkedHashMap for deterministic order SqlFunctionUtils.java

flinkbot commented on issue #11286: [FLINK-16386]Use LinkedHashMap for deterministic order SqlFunctionUtils.java URL: https://github.com/apache/flink/pull/11286#issuecomment-593440416 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-16386) Use LinkedHashMap in SqlFunctionUtils.java

[ https://issues.apache.org/jira/browse/FLINK-16386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16386: --- Labels: pull-request-available (was: ) > Use LinkedHashMap in SqlFunctionUtils.java > -

[GitHub] [flink] wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

wuchong commented on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-593438903 I will review and merge it later. This is an au

[GitHub] [flink] cpugputpu opened a new pull request #11286: [FLINK-16386]Use LinkedHashMap for deterministic order SqlFunctionUtils.java

cpugputpu opened a new pull request #11286: [FLINK-16386]Use LinkedHashMap for deterministic order SqlFunctionUtils.java URL: https://github.com/apache/flink/pull/11286 ## What is the purpose of the change This PR aims to solve the issue here: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-16386) Use LinkedHashMap in SqlFunctionUtils.java

cpugputpu created FLINK-16386: - Summary: Use LinkedHashMap in SqlFunctionUtils.java Key: FLINK-16386 URL: https://issues.apache.org/jira/browse/FLINK-16386 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-14127) Better BackPressure Detection in WebUI

[ https://issues.apache.org/jira/browse/FLINK-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-14127: Assignee: Yadong Xie > Better BackPressure Detection in WebUI > -

[GitHub] [flink] flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

flinkbot edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-591843120 ## CI report: * 0017b8a8930024d0e9ce3355d050565a5007831d UNKNOWN * 978c6f00810a66a87325af6454e49e2f084e

<    1   2   3   4   5   6   >