[jira] [Closed] (FLINK-16123) Add routable Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-16123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16123. --- Resolution: Fixed Merged to master via 1fe23c0ffd915cfe7090502505dee2e4379365b1. >

[jira] [Closed] (FLINK-16395) Mention OkHttp in NOTICE file of statefun-flink-distribution

[ https://issues.apache.org/jira/browse/FLINK-16395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16395. --- Fix Version/s: statefun-1.1 Resolution: Fixed Fixed in master via

[GitHub] [flink-statefun] tzulitai closed pull request #44: [FLINK-16395] [legal] Add OkHttp to NOTICE of statefun-flink-distribution

tzulitai closed pull request #44: [FLINK-16395] [legal] Add OkHttp to NOTICE of statefun-flink-distribution URL: https://github.com/apache/flink-statefun/pull/44 This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] tzulitai closed pull request #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress

tzulitai closed pull request #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress URL: https://github.com/apache/flink-statefun/pull/45 This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] tzulitai closed pull request #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress

tzulitai closed pull request #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress URL: https://github.com/apache/flink-statefun/pull/37 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * 0e2dfb26a887207fa675217145417ccdd8482fa3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

flinkbot edited a comment on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293#issuecomment-593783489 ## CI report: * 9d9ff769ccec11c066ca2a45daaa168f149d030b Travis:

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

[GitHub] [flink] flinkbot edited a comment on issue #11273: [FLINK-12814][sql-client] Support tableau result format

flinkbot edited a comment on issue #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#issuecomment-593096244 ## CI report: * 18e6e2e24fc6a42b501a0e65c90a03dba7c0c5bb Travis:

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

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386828354 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceBuilder.java

[GitHub] [flink] flinkbot edited a comment on issue #11273: [FLINK-12814][sql-client] Support tableau result format

flinkbot edited a comment on issue #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#issuecomment-593096244 ## CI report: * 18e6e2e24fc6a42b501a0e65c90a03dba7c0c5bb Travis:

[GitHub] [flink-statefun] tzulitai commented on issue #44: [FLINK-16395] [legal] Add OkHttp to NOTICE of statefun-flink-distribution

tzulitai commented on issue #44: [FLINK-16395] [legal] Add OkHttp to NOTICE of statefun-flink-distribution URL: https://github.com/apache/flink-statefun/pull/44#issuecomment-593795913 Thanks! Merging ... This is an automated

[GitHub] [flink-statefun] tzulitai commented on issue #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress

tzulitai commented on issue #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress URL: https://github.com/apache/flink-statefun/pull/45#issuecomment-593795999 Thanks! Merging ... This is an automated

[GitHub] [flink-statefun] tzulitai edited a comment on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress

tzulitai edited a comment on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress URL: https://github.com/apache/flink-statefun/pull/37#issuecomment-593795750 Thanks! Merging ... This is an automated

[GitHub] [flink-statefun] tzulitai commented on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress

tzulitai commented on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress URL: https://github.com/apache/flink-statefun/pull/37#issuecomment-593795750 Thanks, merging ... This is an automated message

[GitHub] [flink] TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w…

TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w… URL: https://github.com/apache/flink/pull/11248#discussion_r386823957 ## File path:

[GitHub] [flink] TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w…

TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w… URL: https://github.com/apache/flink/pull/11248#discussion_r386823957 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * 88b68ef1c9eeb715da5bf216ad0e55e1a89afb7d Travis:

[GitHub] [flink] zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

zhengcanbin commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593792257 > > @TisonKun Do you think we need to reorganize the commit message or squash them when merging? Currently, i think

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN *

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386818991 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceBuilder.java

[GitHub] [flink] flinkbot edited a comment on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

flinkbot edited a comment on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293#issuecomment-593783489 ## CI report: * 9d9ff769ccec11c066ca2a45daaa168f149d030b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * 88b68ef1c9eeb715da5bf216ad0e55e1a89afb7d Travis:

[GitHub] [flink] flinkbot commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

flinkbot commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293#issuecomment-593783489 ## CI report: * 9d9ff769ccec11c066ca2a45daaa168f149d030b UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. URL: https://github.com/apache/flink/pull/10768#issuecomment-570915760 ## CI report: *

[jira] [Updated] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14172: -- Parent: (was: FLINK-14460) Issue Type: Task (was: Sub-task) > Implement KubeClient with

[jira] [Updated] (FLINK-15643) Support to start multiple Flink masters to achieve faster recovery

[ https://issues.apache.org/jira/browse/FLINK-15643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15643: -- Parent: (was: FLINK-14460) Issue Type: New Feature (was: Sub-task) > Support to start

[jira] [Updated] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14172: -- Priority: Minor (was: Major) > Implement KubeClient with official Java client library for kubernetes

[jira] [Updated] (FLINK-15643) Support to start multiple Flink masters to achieve faster recovery

[ https://issues.apache.org/jira/browse/FLINK-15643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15643: -- Description: The replicas of Flink master deployment could be set more than 1 to achieve faster

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386811424 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@ +#!/usr/bin/env

[jira] [Updated] (FLINK-12884) Implement HighAvailabilityService based on native k8s APIs

[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-12884: -- Parent: (was: FLINK-14460) Issue Type: New Feature (was: Sub-task) > Implement

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386810708 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceBuilder.java

[GitHub] [flink] leonardBang commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

leonardBang commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293#issuecomment-593777125 Hi @JingsongLi , @libenchao Could you help review this PR for release-1.10? many thanks.

[GitHub] [flink] flinkbot commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

flinkbot commented on issue #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293#issuecomment-593777129 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] leonardBang opened a new pull request #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter

leonardBang opened a new pull request #11293: [FLINK-16281][jdbc] Parameter 'maxRetryTimes' can not work in AppendOnlyWriter URL: https://github.com/apache/flink/pull/11293 Parameter 'maxRetryTimes' can not work in AppendOnlyWriter ## What is the purpose of the change

[GitHub] [flink-statefun] igalshilman commented on issue #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress

igalshilman commented on issue #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress URL: https://github.com/apache/flink-statefun/pull/45#issuecomment-593776469 The protobuf message looks good to me. +1

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386807612 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@

[jira] [Updated] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla updated FLINK-16397: -- Affects Version/s: 1.9.2 1.10.0 > [metric] flink metric graphite will format

[GitHub] [flink] TisonKun commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

TisonKun commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593774185 ``` 2020-03-03T04:18:38.2171847Z [ERROR] Failed to execute goal

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

TisonKun edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593774185 ``` 2020-03-03T04:18:38.2171847Z [ERROR] Failed to execute goal

[GitHub] [flink-statefun] igalshilman commented on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress

igalshilman commented on issue #37: [FLINK-16123] Add E2E for auto-routable Protobuf Kafka ingress URL: https://github.com/apache/flink-statefun/pull/37#issuecomment-593773473 Let’s merge it, so it won’t diverge too much.

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386804627 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386802522 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386801166 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386802135 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386803247 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386801819 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is request

JingsongLi commented on a change in pull request #11236: [FLINK-16269][FLINK-16108][table-planner-blink] Fix schema of query and sink do not match when generic or POJO type is requested URL: https://github.com/apache/flink/pull/11236#discussion_r386803945 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN *

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386803470 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@

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

TisonKun edited a comment on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593771974 > @TisonKun Do you think we need to reorganize the commit message or squash them when merging? Currently, i think

[GitHub] [flink] TisonKun commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design

TisonKun commented on issue #11233: [FLINK-16194][k8s] Refactor the Kubernetes decorator design URL: https://github.com/apache/flink/pull/11233#issuecomment-593771974 > @TisonKun Do you think we need to reorganize the commit message or squash them when merging? Currently, i think there

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386801810 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@ +#!/usr/bin/env

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

KarmaGYZ commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386800915 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@ +#!/usr/bin/env

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

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 5fbfcd932cb089b0993d6ce3707bea9ef738e2b6 Travis:

[GitHub] [flink] JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format

JingsongLi commented on a change in pull request #11273: [FLINK-12814][sql-client] Support tableau result format URL: https://github.com/apache/flink/pull/11273#discussion_r386799570 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386799098 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798885 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w…

xintongsong commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w… URL: https://github.com/apache/flink/pull/11248#discussion_r386798964 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798958 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798744 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798744 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798696 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798439 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386798377 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386797874 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386797841 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386797617 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386797635 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386797662 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 5fbfcd932cb089b0993d6ce3707bea9ef738e2b6 Travis:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386796864 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386796818 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r386796843 ## File path:

[jira] [Created] (FLINK-16398) Rename Protobuf Kafka Ingress / Routable Kafka Ingress type identifier strings

Tzu-Li (Gordon) Tai created FLINK-16398: --- Summary: Rename Protobuf Kafka Ingress / Routable Kafka Ingress type identifier strings Key: FLINK-16398 URL: https://issues.apache.org/jira/browse/FLINK-16398

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * 88b68ef1c9eeb715da5bf216ad0e55e1a89afb7d Travis:

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

[GitHub] [flink] flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. URL: https://github.com/apache/flink/pull/10768#issuecomment-570915760 ## CI report: *

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049888#comment-17049888 ] BlaBlabla commented on FLINK-16142: --- I met this issue , when I upgraded flink from 1.9.2 to 1.10.0.

[GitHub] [flink] flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin

flinkbot edited a comment on issue #11291: [FLINK-16392] [API / DataStream] oneside sorted cache in intervaljoin URL: https://github.com/apache/flink/pull/11291#issuecomment-593677297 ## CI report: * 88b68ef1c9eeb715da5bf216ad0e55e1a89afb7d Travis:

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

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: * 6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e Travis:

[GitHub] [flink] TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w…

TaoYang526 commented on a change in pull request #11248: [FLINK-16299] Release containers recovered from previous attempt in w… URL: https://github.com/apache/flink/pull/11248#discussion_r386791133 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. URL: https://github.com/apache/flink/pull/10768#issuecomment-570915760 ## CI report: *

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386790513 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049884#comment-17049884 ] Caizhi Weng commented on FLINK-14807: - Hi dear Flink community, After some implementation and

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386790141 ## File path: flink-end-to-end-tests/test-scripts/test_nat.sh ## @@ -0,0 +1,71 @@

[jira] [Updated] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla updated FLINK-16397: -- Description: I'm using flink GraphiteReporter to monitor metrics. But I found that the

[jira] [Updated] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla updated FLINK-16397: -- Description: I'm using flink GraphiteReporter to monitor metrics. But I found that the

[jira] [Updated] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla updated FLINK-16397: -- Description: I'm using flink GraphiteReporter to monitor metrics. But I found that the

[jira] [Updated] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

[ https://issues.apache.org/jira/browse/FLINK-16397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BlaBlabla updated FLINK-16397: -- Description: I'm using flink GraphiteReporter to monitor metrics. But I found that the

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r386789347 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceBuilder.java

[jira] [Created] (FLINK-16397) [metric] flink metric graphite will format double metrics to "%2.2f"

BlaBlabla created FLINK-16397: - Summary: [metric] flink metric graphite will format double metrics to "%2.2f" Key: FLINK-16397 URL: https://issues.apache.org/jira/browse/FLINK-16397 Project: Flink

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

[GitHub] [flink] flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner

flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050 ## CI report: * ec7775530fe0294d9cc2a32333d7227fb7f80461 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11292: [FLINK-16393][kinesis] Skip record emitter thread creation w/o source sync

flinkbot edited a comment on issue #11292: [FLINK-16393][kinesis] Skip record emitter thread creation w/o source sync URL: https://github.com/apache/flink/pull/11292#issuecomment-593705062 ## CI report: * 3f5decfd0bfd4737b2ada30c1489bef9fd3c243a Travis:

[jira] [Updated] (FLINK-16396) Support binding Kafka egresses with YAML-ized modules

[ https://issues.apache.org/jira/browse/FLINK-16396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16396: --- Labels: pull-request-available (was: ) > Support binding Kafka egresses with YAML-ized

[GitHub] [flink-statefun] tzulitai opened a new pull request #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress

tzulitai opened a new pull request #45: [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress URL: https://github.com/apache/flink-statefun/pull/45 This adds a Protobuf message to be used by the YAML-ized Kafka egress (WIP). I'm eagerly opening this PR already because

  1   2   3   4   5   6   >