[
https://issues.apache.org/jira/browse/FLINK-16965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-16965:
Assignee: Yangze Guo
> Convert Graphite reporter to plugin
>
[
https://issues.apache.org/jira/browse/FLINK-17206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17206:
---
Labels: pull-request-available (was: )
> Refactor FunctionCatalog to support delayed UDF in
dianfu commented on issue #11767: [FLINK-17119][python] Add Cython support for
composite types
URL: https://github.com/apache/flink/pull/11767#issuecomment-615077677
@pnowojski Sorry about this. The CiBot has not been triggered for about 10
hours after pushing a new commit. So just merge t
WeiZhong94 opened a new pull request #11785: [FLINK-17206][table] refactor
function catalog to support delayed UDF initialization.
URL: https://github.com/apache/flink/pull/11785
## What is the purpose of the change
*This pull request refactors the `FunctionCatalog` to support delaye
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r410026090
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/f
KarmaGYZ commented on issue #11615: [FLINK-16605] Add max limitation to the
total number of slots
URL: https://github.com/apache/flink/pull/11615#issuecomment-615076187
Rebased to the latest master.
This is an automated messa
sunjincheng121 commented on issue #11767: [FLINK-17119][python] Add Cython
support for composite types
URL: https://github.com/apache/flink/pull/11767#issuecomment-615076310
Thanks @pnowojski
This is an automated message fro
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r410025301
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/f
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r410024849
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/f
KurtYoung commented on issue #11765: [FLINK-8864][sql-client] Add cli command
history in sql client and make it available after restarts
URL: https://github.com/apache/flink/pull/11765#issuecomment-615074990
Good point, I will try to write some.
---
[
https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085479#comment-17085479
]
Dian Fu commented on FLINK-17205:
-
Sorry about this. Will look into it ASAP.
> test_ci
[
https://issues.apache.org/jira/browse/FLINK-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085480#comment-17085480
]
Jingsong Lee commented on FLINK-17178:
--
Although it doesn't look very elegant, I th
[
https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-17208:
Assignee: Yingjie Cao
> Reduce redundant data available notification of PipelinedSubpartition
> -
[
https://issues.apache.org/jira/browse/FLINK-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17207:
---
Priority: Critical (was: Blocker)
> Lots of test_ci Python tests failing with OSError: [Err
[
https://issues.apache.org/jira/browse/FLINK-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-17207.
---
Resolution: Duplicate
[~pnowojski] This issue duplicates with FLINK-17068. I'm closing it.
> Lots of test_c
flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement
PipelinedRegionSchedulingStrategy
URL: https://github.com/apache/flink/pull/11770#issuecomment-614523163
## CI report:
* 2577ed1f1fe568552fcec2a89366ae8dc59911c9 Travis:
[SUCCESS](https://travis-ci.com/g
[
https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17068:
---
Priority: Critical (was: Major)
> ERROR at teardown of TableConfigTests.test_get_set_decima
JingsongLi commented on issue #11759: FLINK-17142: Bump ORC dependency version
to 1.5.6
URL: https://github.com/apache/flink/pull/11759#issuecomment-615073310
I found `mvn clean install -Phive-2.2.0` in flink-connector-hive can not
work.
@zenfenan can you create a `hive.orc.version=1.4.
flinkbot edited a comment on issue #11782: [FLINK-15801] fix Timestamp
extractor created from properties does no…
URL: https://github.com/apache/flink/pull/11782#issuecomment-614731103
## CI report:
* de8e893e40c189d6aaa3de4330df4c3065b8ae62 Travis:
[FAILURE](https://travis-ci.c
flinkbot edited a comment on issue #11764: [FLINK-17023][scripts] Fix format
checking of extractExecutionParams in config.sh
URL: https://github.com/apache/flink/pull/11764#issuecomment-614393395
## CI report:
* 59e7e206fbc4bc1074df99204cd52689c0038e7d Travis:
[SUCCESS](https://
GJL commented on issue #11783: [FLINK-17181][runtime] Drop generic Types in
SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#issuecomment-615072674
> I tried rebasing #11770 onto this PR and #11770 can still work with some
small adjustments.
> If you do not s
Yingjie Cao created FLINK-17208:
---
Summary: Reduce redundant data available notification of
PipelinedSubpartition
Key: FLINK-17208
URL: https://issues.apache.org/jira/browse/FLINK-17208
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085475#comment-17085475
]
Piotr Nowojski edited comment on FLINK-17205 at 4/17/20, 6:38 AM:
[
https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-17205.
--
Resolution: Fixed
Resolved by reverting 5eaf2b50a6 FLINK-17119 (as c201e1dc91 on master)
> te
[
https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085474#comment-17085474
]
Piotr Nowojski commented on FLINK-17205:
another instances:
https://dev.azure.co
[
https://issues.apache.org/jira/browse/FLINK-17205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085473#comment-17085473
]
Robert Metzger commented on FLINK-17205:
Do we need to add "gcc" to the underlyi
pnowojski edited a comment on issue #11767: [FLINK-17119][python] Add Cython
support for composite types
URL: https://github.com/apache/flink/pull/11767#issuecomment-615070234
Guys, can you please pay attention to test failures? This failed in this PR:
https://dev.azure.com/rmetzger/Fli
pnowojski commented on issue #11767: [FLINK-17119][python] Add Cython support
for composite types
URL: https://github.com/apache/flink/pull/11767#issuecomment-615070234
Guys, can you please pay attention to travis failures? This failed in this
PR:
https://dev.azure.com/rmetzger/Flink/_
Wei Zhong created FLINK-17206:
-
Summary: Refactor FunctionCatalog to support delayed UDF
initialization.
Key: FLINK-17206
URL: https://issues.apache.org/jira/browse/FLINK-17206
Project: Flink
Is
Piotr Nowojski created FLINK-17207:
--
Summary: Lots of test_ci Python tests failing with OSError: [Errno
9] Bad file descriptor
Key: FLINK-17207
URL: https://issues.apache.org/jira/browse/FLINK-17207
Piotr Nowojski created FLINK-17205:
--
Summary: test_ci Python fails with unable to execute 'gcc': No
such file or directory
Key: FLINK-17205
URL: https://issues.apache.org/jira/browse/FLINK-17205
Proj
[
https://issues.apache.org/jira/browse/FLINK-12894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-12894:
Fix Version/s: (was: 1.9.3)
1.9.4
> add Chinese documentation of how to configure a
[
https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-13086:
Fix Version/s: (was: 1.9.3)
1.9.4
> add Chinese documentation for catalogs
> --
[
https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-13278:
Fix Version/s: (was: 1.9.3)
1.9.4
> add Chinese documentation for Hive source/sink
[
https://issues.apache.org/jira/browse/FLINK-14614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14614:
Fix Version/s: (was: 1.9.3)
1.9.4
> add annotation location javastyle rule
> --
[
https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-16581.
-
Resolution: Fixed
Resolved in master (1.11.0): 3f6080f4e9bdeb564c32a1bbbd5f577b0fbfe873
> Support state
wuchong merged pull request #11482: [FLINK-16581][table] Minibatch
deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16581:
---
Labels: pull-request-available (was: )
> Minibatch deduplication lack state TTL
> -
[
https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16581:
Summary: Support state ttl for Mini-Batch deduplication using
StateTtlConfig (was: Minibatch deduplicatio
[
https://issues.apache.org/jira/browse/FLINK-16549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085468#comment-17085468
]
Jark Wu commented on FLINK-16549:
-
Another instance:
https://dev.azure.com/rmetzger/Fli
[
https://issues.apache.org/jira/browse/FLINK-16437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-16437.
---
Resolution: Fixed
Fixed via
7286c5cf22bd50bac081ef05771f15b0067f0a37
5b735c07ae5f62f84d7f09
tillrohrmann closed pull request #11320: [FLINK-16437][runtime] Make
SlotManager allocate resource from ResourceManager at the worker granularity.
URL: https://github.com/apache/flink/pull/11320
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14258:
-
Component/s: (was: Connectors / Hive)
Connectors / FileSystem
> Integrate f
[
https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-14258:
Assignee: Jingsong Lee
> Integrate file system connector to streaming sink
>
[
https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14258:
-
Fix Version/s: 1.11.0
> Integrate file system connector to streaming sink
>
[
https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14255:
-
Summary: Integrate streaming file sink for hive connector (was: Introduce
StreamingSink for Fil
[
https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14258:
-
Summary: Integrate file system connector to streaming sink (was: Integrate
hive to streaming si
[
https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee resolved FLINK-17128.
--
Resolution: Fixed
master: c1bc0d45c10130c36a426d268cc0e185acca7b72
> Add isBounded to TableSi
ChaojianZhang created FLINK-17204:
-
Summary: The RMQSource and RMQSink of the RabbitMQ connector have
inconsistent default value of durable when declaring the queue.
Key: FLINK-17204
URL: https://issues.apache.o
JingsongLi commented on issue #11726: [FLINK-17128][table] Add isBounded to
TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726#issuecomment-615063190
Merging...
This is an automated message from the Apac
JingsongLi merged pull request #11726: [FLINK-17128][table] Add isBounded to
TableSinkFactory#Context
URL: https://github.com/apache/flink/pull/11726
This is an automated message from the Apache Git Service.
To respond to th
GJL commented on a change in pull request #11783: [FLINK-17181][runtime] Drop
generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r410010226
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failov
GJL commented on a change in pull request #11783: [FLINK-17181][runtime] Drop
generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r410010051
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/topology/BaseTopology
[
https://issues.apache.org/jira/browse/FLINK-17172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-17172.
Resolution: Fixed
master: 2669f5bbfac7e973379ce37bdb7a8837cb7405ae
> Re-enable debug level logging in Jep
xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and
use BashJavaUtils to start JM JVM process and pass JVM memory args
URL: https://github.com/apache/flink/pull/11545#issuecomment-615058632
Rebased onto #11577.
A few changes during the rebasing:
- Pass dynam
[
https://issues.apache.org/jira/browse/FLINK-17199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li resolved FLINK-17199.
Resolution: Duplicate
> Use NeverReturnExpired strategy for states in blink streaming join.
>
[
https://issues.apache.org/jira/browse/FLINK-17199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085456#comment-17085456
]
Benchao Li commented on FLINK-17199:
Yes. Thanks for the reminder.
> Use NeverRetur
[
https://issues.apache.org/jira/browse/FLINK-17200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jinhai updated FLINK-17200:
---
Description:
Clickhouse is a powerful OLAP query engine and supports real-time data mini
batch writing.
We
xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r410006159
##
File path:
flink-kubernetes/src/mai
[
https://issues.apache.org/jira/browse/FLINK-17201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085454#comment-17085454
]
liufangliang commented on FLINK-17201:
--
Amazing
> Implement Streaming ClickHouseSi
jinhai created FLINK-17203:
--
Summary: Add metrics for ClickHouse sink
Key: FLINK-17203
URL: https://issues.apache.org/jira/browse/FLINK-17203
Project: Flink
Issue Type: New Feature
Repor
jinhai created FLINK-17202:
--
Summary: Add SQL for ClickHouse connector
Key: FLINK-17202
URL: https://issues.apache.org/jira/browse/FLINK-17202
Project: Flink
Issue Type: New Feature
Repo
zhengcanbin commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r410001005
##
File path:
flink-kubernetes/src/mai
jinhai created FLINK-17201:
--
Summary: Implement Streaming ClickHouseSink
Key: FLINK-17201
URL: https://issues.apache.org/jira/browse/FLINK-17201
Project: Flink
Issue Type: New Feature
Re
zhengcanbin commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r409991098
##
File path:
flink-kubernetes/src/mai
jinhai created FLINK-17200:
--
Summary: Add connectors to ClickHouse
Key: FLINK-17200
URL: https://issues.apache.org/jira/browse/FLINK-17200
Project: Flink
Issue Type: New Feature
Reporter
zhengcanbin commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r410001005
##
File path:
flink-kubernetes/src/mai
[
https://issues.apache.org/jira/browse/FLINK-17199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085446#comment-17085446
]
Jark Wu commented on FLINK-17199:
-
I think we will change this behavior in FLINK-16581?
flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set
the configuration option "pipeline.jars" in PyFlink.
URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552
## CI report:
* a3aa6b6cab6c0a7e0e26c0cf3ef0e38f265e8799 Travis:
[SUCCESS](htt
[
https://issues.apache.org/jira/browse/FLINK-16104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16104:
---
Assignee: ChaojianZhang
> Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese
[
https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085442#comment-17085442
]
Canbin Zheng edited comment on FLINK-17177 at 4/17/20, 5:22 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085442#comment-17085442
]
Canbin Zheng commented on FLINK-17177:
--
{quote}I post the {{WatchEvent}} in K8s her
xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r409997707
##
File path:
flink-kubernetes/src/mai
zhengcanbin commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r409991098
##
File path:
flink-kubernetes/src/mai
flinkbot edited a comment on issue #11749: [FLINK-16669][python][table] Support
Python UDF in SQL function DDL.
URL: https://github.com/apache/flink/pull/11749#issuecomment-613901508
## CI report:
* 7cbe2380ac7246cf703397d9a78d002c0491a959 Travis:
[FAILURE](https://travis-ci.com
flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to
the total number of slots
URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339
## CI report:
* 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN
* 0b0111ba893c9ecc7632394fc59e455f8d
flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set
the configuration option "pipeline.jars" in PyFlink.
URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552
## CI report:
* a3aa6b6cab6c0a7e0e26c0cf3ef0e38f265e8799 Travis:
[SUCCESS](htt
flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error
in KubernetesResourceManager when the pods watcher is closed with exception
URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412
## CI report:
* 1130280dfe557a0268fed248089fb32d15f83
Benchao Li created FLINK-17199:
--
Summary: Use NeverReturnExpired strategy for states in blink
streaming join.
Key: FLINK-17199
URL: https://issues.apache.org/jira/browse/FLINK-17199
Project: Flink
zhijiangW commented on a change in pull request #11687:
[FLINK-16536][network][checkpointing] Implement InputChannel state recovery for
unaligned checkpoint
URL: https://github.com/apache/flink/pull/11687#discussion_r409995125
##
File path:
flink-runtime/src/main/java/org/apache/f
dianfu commented on a change in pull request #11784: [FLINK-17120][python] Add
Cython support for operations
URL: https://github.com/apache/flink/pull/11784#discussion_r409994413
##
File path: flink-python/pyflink/fn_execution/fast_operations.pxd
##
@@ -0,0 +1,48 @@
+#
+#
dianfu commented on a change in pull request #11784: [FLINK-17120][python] Add
Cython support for operations
URL: https://github.com/apache/flink/pull/11784#discussion_r409991523
##
File path: flink-python/pyflink/fn_execution/coders.py
##
@@ -177,6 +187,9 @@ def __init__(
dianfu commented on a change in pull request #11784: [FLINK-17120][python] Add
Cython support for operations
URL: https://github.com/apache/flink/pull/11784#discussion_r409992838
##
File path: flink-python/pyflink/fn_execution/fast_operations.pyx
##
@@ -0,0 +1,242 @@
+#
+#
dianfu commented on a change in pull request #11784: [FLINK-17120][python] Add
Cython support for operations
URL: https://github.com/apache/flink/pull/11784#discussion_r409994309
##
File path: flink-python/pyflink/fn_execution/fast_operations.pxd
##
@@ -0,0 +1,48 @@
+#
+#
flinkbot edited a comment on issue #11781: [FLINK-16770][checkpointing] Revert
commits of FLINK-16945 and FLINK-14971
URL: https://github.com/apache/flink/pull/11781#issuecomment-614694494
## CI report:
* c6ea0d7e853fb1b8f244f5ce756fe07348580cf6 Travis:
[SUCCESS](https://travis-
WeiZhong94 commented on issue #11768: [FLINK-16943][python] Support set the
configuration option "pipeline.jars" in PyFlink.
URL: https://github.com/apache/flink/pull/11768#issuecomment-615041372
@kl0u Hi Kostas, the change of `LocalExecutor` has been included in this PR.
It seems all test
flinkbot edited a comment on issue #11782: [FLINK-15801] fix Timestamp
extractor created from properties does no…
URL: https://github.com/apache/flink/pull/11782#issuecomment-614731103
## CI report:
* de8e893e40c189d6aaa3de4330df4c3065b8ae62 Travis:
[FAILURE](https://travis-ci.c
flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make
KubernetesResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888
## CI report:
* edd2f98c2a607655aef8823024753fcceb
flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error
in KubernetesResourceManager when the pods watcher is closed with exception
URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412
## CI report:
* 1130280dfe557a0268fed248089fb32d15f83
wangyang0918 commented on issue #11010: [FLINK-15836][k8s] Throw fatal error in
KubernetesResourceManager when the pods watcher is closed with exception
URL: https://github.com/apache/flink/pull/11010#issuecomment-615040585
@tillrohrmann Could you help to review this PR?
--
WeiZhong94 commented on issue #11768: [FLINK-16943][python] Support set the
configuration option "pipeline.jars" in PyFlink.
URL: https://github.com/apache/flink/pull/11768#issuecomment-615039935
@dianfu Thanks for your review! I have addressed your comments in the latest
commit.
zhengcanbin commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r409991098
##
File path:
flink-kubernetes/src/mai
wangyang0918 commented on a change in pull request #11323: [FLINK-16439][k8s]
Make KubernetesResourceManager starts workers using WorkerResourceSpec
requested by SlotManager
URL: https://github.com/apache/flink/pull/11323#discussion_r409989580
##
File path:
flink-kubernetes/src/ma
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r409988049
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/topology/BaseTop
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r409988394
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/f
zhuzhurk commented on a change in pull request #11783: [FLINK-17181][runtime]
Drop generic Types in SchedulingTopology Interface
URL: https://github.com/apache/flink/pull/11783#discussion_r409988449
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/f
dianfu commented on a change in pull request #11749:
[FLINK-16669][python][table] Support Python UDF in SQL function DDL.
URL: https://github.com/apache/flink/pull/11749#discussion_r409266063
##
File path:
flink-python/src/main/java/org/apache/flink/client/python/PythonFunctionFact
dianfu commented on a change in pull request #11749:
[FLINK-16669][python][table] Support Python UDF in SQL function DDL.
URL: https://github.com/apache/flink/pull/11749#discussion_r409261220
##
File path:
flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.jav
dianfu commented on a change in pull request #11749:
[FLINK-16669][python][table] Support Python UDF in SQL function DDL.
URL: https://github.com/apache/flink/pull/11749#discussion_r409958033
##
File path: flink-python/pyflink/table/tests/test_table_environment_api.py
##
@
dianfu commented on a change in pull request #11749:
[FLINK-16669][python][table] Support Python UDF in SQL function DDL.
URL: https://github.com/apache/flink/pull/11749#discussion_r409959968
##
File path:
flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.jav
1 - 100 of 690 matches
Mail list logo
