[
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 fb885052130
[
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.
>
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 r
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 respo
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 t
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:
[PENDING](https://travis-ci.co
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:
[SUCCESS](https://tra
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
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:
[FAILURE](https://travis-ci.com/flink-ci/fli
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
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
#
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:
[FAILURE](https://travis-ci.com/flink-ci/fli
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
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 mess
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 mess
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 fro
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:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.jav
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:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.jav
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:
[FAILURE](https://travis-ci.co
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 ther
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
* 8652a187416cafe
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
#
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:
[PENDING](https://tra
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:
[FAILURE](https://travis-ci.co
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
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:
* 31ba52e04ee5e84ee6c50ebd5c8b972bf32
[
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 o
[
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 mul
[
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
[
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 recov
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 b
[
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 HighAvaila
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
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.
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
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
*Thi
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
--
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 @@
+#!/usr/bin/en
[
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 do
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
org.apache.maven.plugins:maven-surefire-plugin:2.22.1:te
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
org.apache.maven.plugins:maven-surefire-plugin:2.
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.
Thi
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 @@
+#!/usr/bin/en
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:
flink-table
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:
flink-table
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:
flink-table
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:
flink-table
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:
flink-table
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:
flink-table
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
* 8652a187416cafe
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 @@
+#!/usr/bin/en
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 th
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 are
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 b
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 b
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
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:
[CANCELED](https://
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:
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTable
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.ja
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
[CANCELED](https://
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
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
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:
[FAILURE](https://travis-ci.co
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
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:
* 3563e73329fd94305582c244a24d5e8b662
[
https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049888#comment-17049888
]
BlaBlabla commented on FLINK-16142:
---
I met this issue , when I upgraded flink from 1.9
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:
[PENDING](https://travis-ci.co
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
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:
[F
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:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.jav
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:
* 3563e73329fd94305582c244a24d5e8b662
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 @@
+#!/usr/bin/en
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049884#comment-17049884
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community,
After some implemen
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 @@
+#!/usr/bin/en
[
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
GraphiteReport
[
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
GraphiteReport
[
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
GraphiteReport
[
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
GraphiteReport
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
#
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
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
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:
[F
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:
[SUCCESS](https://travis-
[
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 modu
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 the
1 - 100 of 585 matches
Mail list logo
