[jira] [Updated] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14370: Fix Version/s: (was: 1.8.2) 1.8.3 > KafkaProducerAtLeastOnceITCase>KafkaPro

[jira] [Closed] (FLINK-14988) Table dependency shading fails

[ https://issues.apache.org/jira/browse/FLINK-14988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-14988. Resolution: Duplicate > Table dependency shading fails > -- >

[jira] [Updated] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14235: Fix Version/s: 1.8.3 > Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomO

[jira] [Commented] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984795#comment-16984795 ] Hequn Cheng commented on FLINK-14235: - Resolved in 1.8.3 via e0387a8007707ab29795e3a

[GitHub] [flink] flinkbot commented on issue #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction

flinkbot commented on issue #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction URL: https://github.com/apache/flink/pull/10356#issuecomment-559693220 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

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

[GitHub] [flink] wangxlong opened a new pull request #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction

wangxlong opened a new pull request #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction URL: https://github.com/apache/flink/pull/10356 ## What is the purpose of the change JDBCTableSource supports AsyncLookupFunction for temporal table join ## Br

[GitHub] [flink] kl0u commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

kl0u commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559691884 I addressed the comments. Let me know if now it is good to merge @TisonKun and @aljoscha

[GitHub] [flink] kl0u commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

kl0u commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#discussion_r352009886 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/executors/RemoteExecutor

[jira] [Commented] (FLINK-14813) Expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric

[ https://issues.apache.org/jira/browse/FLINK-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984783#comment-16984783 ] lining commented on FLINK-14813: FLINK-14815 is blocked by this JIRA, the previous link

[GitHub] [flink] flinkbot edited a comment on issue #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

flinkbot edited a comment on issue #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#issuecomment-92815 ## CI report: * cb019fdc2ef071edc76f9d93ced50551605a4cae : SUCCESS [Build](https://tr

[jira] [Closed] (FLINK-14956) MemoryMappedBoundedData Compressed Buffer Slicer

[ https://issues.apache.org/jira/browse/FLINK-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-14956. Resolution: Duplicate > MemoryMappedBoundedData Compressed Buffer Slicer > ---

[jira] [Commented] (FLINK-14956) MemoryMappedBoundedData Compressed Buffer Slicer

[ https://issues.apache.org/jira/browse/FLINK-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984777#comment-16984777 ] zhijiang commented on FLINK-14956: -- I would close this duplicated issue to focus on FLI

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in new web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984769#comment-16984769 ] David Moravek commented on FLINK-13550: --- Hi [~xintongsong], we already use this in

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[jira] [Commented] (FLINK-14989) Improve efficiency by bitwise operation.

[ https://issues.apache.org/jira/browse/FLINK-14989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984744#comment-16984744 ] Zhenghua Gao commented on FLINK-14989: -- I'm afraid we should not do that. Modern co

[jira] [Commented] (FLINK-13595) KafkaITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984741#comment-16984741 ] Dian Fu commented on FLINK-13595: - Another instance: [https://api.travis-ci.org/v3/job/6

[GitHub] [flink] flinkbot edited a comment on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation.

flinkbot edited a comment on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation. URL: https://github.com/apache/flink/pull/10355#issuecomment-559652719 ## CI report: * 5e8e90e2e98172438ded5aa1cd88d5a47b650339 : SUCCESS [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] flinkbot edited a comment on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation.

flinkbot edited a comment on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation. URL: https://github.com/apache/flink/pull/10355#issuecomment-559652719 ## CI report: * 5e8e90e2e98172438ded5aa1cd88d5a47b650339 : PENDING [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] flinkbot edited a comment on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot edited a comment on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10354#issuecomment-559648653 ## CI report: * 39f094776ea236e08b18c471c36fc784d8e85bbc : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation.

flinkbot commented on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation. URL: https://github.com/apache/flink/pull/10355#issuecomment-559652719 ## CI report: * 5e8e90e2e98172438ded5aa1cd88d5a47b650339 : UNKNOWN Bot commands The @flinkbot b

[GitHub] [flink] flinkbot commented on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation.

flinkbot commented on issue #10355: [FLINK-14989][table] Improve efficiency by bitwise operation. URL: https://github.com/apache/flink/pull/10355#issuecomment-559651151 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] zhangzqit opened a new pull request #10355: [FLINK-14989][table] Improve efficiency by bitwise operation.

zhangzqit opened a new pull request #10355: [FLINK-14989][table] Improve efficiency by bitwise operation. URL: https://github.com/apache/flink/pull/10355 ## What is the purpose of the change *Improve efficiency by bitwise operation.* ## Brief change log -

[jira] [Updated] (FLINK-14989) Improve efficiency by bitwise operation.

[ https://issues.apache.org/jira/browse/FLINK-14989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14989: --- Labels: pull-request-available (was: ) > Improve efficiency by bitwise operation. > ---

[jira] [Created] (FLINK-14990) Add bit functions to Blink planner

hailong wang created FLINK-14990: Summary: Add bit functions to Blink planner Key: FLINK-14990 URL: https://issues.apache.org/jira/browse/FLINK-14990 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot commented on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10354#issuecomment-559648653 ## CI report: * 39f094776ea236e08b18c471c36fc784d8e85bbc : UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader

guoweiM commented on a change in pull request #10256: [FLINK-14467][runtime] Let MesosJobClusterEntrypoint use user code class loader URL: https://github.com/apache/flink/pull/10256#discussion_r351968587 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterfram

[GitHub] [flink] flinkbot commented on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot commented on issue #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10354#issuecomment-559645834 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[jira] [Commented] (FLINK-14729) Multi-topics consuming from KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984720#comment-16984720 ] Fang Peng Cheng commented on FLINK-14729: - new PR,  https://github.com/apache/fl

[GitHub] [flink] fangpengcheng95 opened a new pull request #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

fangpengcheng95 opened a new pull request #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10354 ## What is the purpose of the change propose a new functionality of KafkaTableSource which can consume mult

[jira] [Commented] (FLINK-14989) Improve efficiency by bitwise operation.

[ https://issues.apache.org/jira/browse/FLINK-14989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984718#comment-16984718 ] Caizhi Weng commented on FLINK-14989: - Hi Ziqiang, Thanks for the JIRA. Which part

[jira] [Comment Edited] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984717#comment-16984717 ] lincoln lee edited comment on FLINK-14946 at 11/29/19 3:03 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #10353: [docs] remove surplus semicolon in Utils

flinkbot edited a comment on issue #10353: [docs] remove surplus semicolon in Utils URL: https://github.com/apache/flink/pull/10353#issuecomment-559639650 ## CI report: * cf2b40b6d31449d3ec41b2b94a4685d64adf9777 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/13865

[jira] [Commented] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984717#comment-16984717 ] lincoln lee commented on FLINK-14946: - [~jinyu.zj]  I think your two solutions can b

[jira] [Created] (FLINK-14989) Improve efficiency by bitwise operation.

Zhang Ziqiang created FLINK-14989: - Summary: Improve efficiency by bitwise operation. Key: FLINK-14989 URL: https://issues.apache.org/jira/browse/FLINK-14989 Project: Flink Issue Type: Improv

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] TisonKun commented on issue #10311: [FLINK-14762][client] Enrich JobClient API

TisonKun commented on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-559643033 tison 10:48 AM I narrow the change set to only unwrap accumulator inside client codes. Here is the diff 6d8f1afa7026a6bbab7a3d024fc67b8588

[GitHub] [flink] jinglining edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

jinglining edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-559642356 Could we create a new metric called BackPressMetrics for it? --

[GitHub] [flink] jinglining edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

jinglining edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-559642356 Could we create a new metrics called BackPressMetrics for it? -

[GitHub] [flink] jinglining commented on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

jinglining commented on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-559642356 could we create a new metrics called BackPressMetrics for it?

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351963262 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351963949 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351963262 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351962703 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[jira] [Commented] (FLINK-14987) JDBCTableSource can't support DataTypes.DECIMAL

[ https://issues.apache.org/jira/browse/FLINK-14987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984714#comment-16984714 ] Zhenghua Gao commented on FLINK-14987: -- Yes. The JDBCTableSource can't support Data

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351963149 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351962827 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351962926 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351962827 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351960228 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351962703 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] flinkbot commented on issue #10353: [docs] remove surplus semicolon in Utils

flinkbot commented on issue #10353: [docs] remove surplus semicolon in Utils URL: https://github.com/apache/flink/pull/10353#issuecomment-559639650 ## CI report: * cf2b40b6d31449d3ec41b2b94a4685d64adf9777 : UNKNOWN Bot commands The @flinkbot bot supports the follow

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351960228 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.compon

[GitHub] [flink] flinkbot commented on issue #10353: [docs] remove surplus semicolon in Utils

flinkbot commented on issue #10353: [docs] remove surplus semicolon in Utils URL: https://github.com/apache/flink/pull/10353#issuecomment-559636956 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

[GitHub] [flink] fangpengcheng95 opened a new pull request #10353: [docs] remove surplus semicolon in Utils

fangpengcheng95 opened a new pull request #10353: [docs] remove surplus semicolon in Utils URL: https://github.com/apache/flink/pull/10353 ## What is the purpose of the change remove surplus semicolon in Utils ## Brief change log *(for example:)* - *The TaskInfo is

[GitHub] [flink] vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

vthinkxie commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r351959019 ## File path: flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts ##

[GitHub] [flink] Rishi55 commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

Rishi55 commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-559636145 > @Rishi55 Any updates on this? @aljoscha I need some help in how to call ping().

[GitHub] [flink] TisonKun commented on issue #10311: [FLINK-14762][client] Enrich JobClient API

TisonKun commented on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-559635706 cherry-pick from slack channel. feel free to react wherever you like. >Sorry but when rebasing I cannot convince myself about why we in

[GitHub] [flink] fangpengcheng95 closed pull request #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

fangpengcheng95 closed pull request #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10343 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10343#issuecomment-559320006 ## CI report: * 42fbaee718ac9509938b448b80f1b78ba3d7cd52 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource URL: https://github.com/apache/flink/pull/10343#issuecomment-559320006 ## CI report: * 42fbaee718ac9509938b448b80f1b78ba3d7cd52 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE [Build](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE [Build](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] GJL commented on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

GJL commented on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-559608641 @flinkbot run travis This is an automated message from the Apache Git Servic

[GitHub] [flink] flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE [Build](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[jira] [Updated] (FLINK-14988) Table dependency shading fails

[ https://issues.apache.org/jira/browse/FLINK-14988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14988: - Affects Version/s: (was: 1.10.0) 1.9.1 > Table dependency sha

[jira] [Created] (FLINK-14988) Table dependency shading fails

Chesnay Schepler created FLINK-14988: Summary: Table dependency shading fails Key: FLINK-14988 URL: https://issues.apache.org/jira/browse/FLINK-14988 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14988) Table dependency shading fails

[ https://issues.apache.org/jira/browse/FLINK-14988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14988: - Priority: Blocker (was: Major) > Table dependency shading fails > -

[GitHub] [flink] GJL closed pull request #10352: [WIP][FLINK-14651]

GJL closed pull request #10352: [WIP][FLINK-14651] URL: https://github.com/apache/flink/pull/10352 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[jira] [Comment Edited] (FLINK-14859) Avoid leaking unassigned Slot in DefaultScheduler when Deployment is outdated

[ https://issues.apache.org/jira/browse/FLINK-14859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16978581#comment-16978581 ] Gary Yao edited comment on FLINK-14859 at 11/28/19 8:46 PM:

[jira] [Closed] (FLINK-14859) Avoid leaking unassigned Slot in DefaultScheduler when Deployment is outdated

[ https://issues.apache.org/jira/browse/FLINK-14859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14859. Resolution: Fixed > Avoid leaking unassigned Slot in DefaultScheduler when Deployment is outdated > --

[GitHub] [flink] GJL closed pull request #10351: [FLINK-14859][runtime] Remove wrong checkState

GJL closed pull request #10351: [FLINK-14859][runtime] Remove wrong checkState URL: https://github.com/apache/flink/pull/10351 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE [Build](https://t

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351909177 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/

[GitHub] [flink] flinkbot edited a comment on issue #10351: [FLINK-14859][runtime] Remove wrong checkState

flinkbot edited a comment on issue #10351: [FLINK-14859][runtime] Remove wrong checkState URL: https://github.com/apache/flink/pull/10351#issuecomment-559560938 ## CI report: * 5d7ba9db7d9923e8ecca91b46c600ac7630f0327 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #10352: [WIP][FLINK-14651]

flinkbot edited a comment on issue #10352: [WIP][FLINK-14651] URL: https://github.com/apache/flink/pull/10352#issuecomment-559568529 ## CI report: * cf7f3a6cf7db44ef19e351ebe6654500a96017cc : CANCELED [Build](https://travis-ci.com/flink-ci/flink/builds/138609890) * 07ab4e89c7c

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #10352: [WIP][FLINK-14651]

flinkbot edited a comment on issue #10352: [WIP][FLINK-14651] URL: https://github.com/apache/flink/pull/10352#issuecomment-559568529 ## CI report: * cf7f3a6cf7db44ef19e351ebe6654500a96017cc : CANCELED [Build](https://travis-ci.com/flink-ci/flink/builds/138609890) * 07ab4e89c7c

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/138

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351914910 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTa

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351909719 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/Executio

[GitHub] [flink] flinkbot edited a comment on issue #10350: [FLINK-14957] Remove deprecated -yst option

flinkbot edited a comment on issue #10350: [FLINK-14957] Remove deprecated -yst option URL: https://github.com/apache/flink/pull/10350#issuecomment-559552706 ## CI report: * 91798df536b1f681f2c81a228545d9ba09d58e8b : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/13

[GitHub] [flink] flinkbot edited a comment on issue #10352: [WIP][FLINK-14651]

flinkbot edited a comment on issue #10352: [WIP][FLINK-14651] URL: https://github.com/apache/flink/pull/10352#issuecomment-559568529 ## CI report: * cf7f3a6cf7db44ef19e351ebe6654500a96017cc : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/138609890) * 07ab4e89c7c2

[GitHub] [flink] flinkbot edited a comment on issue #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy

flinkbot edited a comment on issue #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy URL: https://github.com/apache/flink/pull/10349#issuecomment-559552672 ## CI report: * fdb6aea8d100865946dbee7840647e1314cb8241 : SU

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351909719 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/Executio

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351909177 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/

[GitHub] [flink] flinkbot edited a comment on issue #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly

flinkbot edited a comment on issue #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly URL: https://github.com/apache/flink/pull/10341#issuecomment-559181765 ## CI report: * a4045089cf8d671a4160c09e60cb3fece7fbd881 : SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#issuecomment-559115891 ## CI report: * 65f4f8552770a2e1fd05c604a5cc074f32487c74 : CANCELED [Build](https://travis-ci

[jira] [Commented] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984586#comment-16984586 ] Dawid Wysakowicz commented on FLINK-14910: -- I think an easy fix would be to pe

[jira] [Closed] (FLINK-14669) All hadoop-2.4.1 related nightly end-to-end tests failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14669. Resolution: Duplicate FLINK-13745 was always just a band-aid; there's currently nothing we

[jira] [Commented] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16984580#comment-16984580 ] Chesnay Schepler commented on FLINK-14835: -- Starting from 1.10 you can use {{Co

  1   2   3   4   5   >