zhuzhurk commented on a change in pull request #9797: [FLINK-14059][core]
Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig
URL: https://github.com/apache/flink/pull/9797#discussion_r341051062
##
File path:
flink-core/src/main/java/org/apache/flink/api/
libenchao opened a new pull request #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060
## What is the purpose of the change
This pr fix flink-json map type resolution bug.
## Brief change log
Add map typ
tillrohrmann commented on issue #10002: [FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10002#issuecomment-548299050
Thanks a lot for the review @GJL. Merging this PR now.
---
flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the
number of bytes from input parameters in HybridMemorySegment
URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242
## CI report:
* 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS
[Buil
flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce
NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.
URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804
## CI report:
* f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14546:
---
Labels: pull-request-available (was: )
> Support map type in flink-json
> -
flinkbot commented on issue #10060: [FLINK-14546] [flink-json] Support map type
in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548300134
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pul
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963838#comment-16963838
]
Dawid Wysakowicz commented on FLINK-13702:
--
I agree the solution suggested by [
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support
partition for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939
## CI report:
* 4937b8b139bab4957799947b841fb1ae3758ed48 : PENDING
[Build](https://travis-ci.com/flink-ci/
flinkbot edited a comment on issue #10058: [FLINK-12527] Remove
GLOBAL_VERSION_UPDATER in ExecutionGraph
URL: https://github.com/apache/flink/pull/10058#issuecomment-548260082
## CI report:
* 1aec27bd75bab810acc79fca474a8c7aaad89f24 : FAILURE
[Build](https://travis-ci.com/flink-
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963838#comment-16963838
]
Dawid Wysakowicz edited comment on FLINK-13702 at 10/31/19 10:23 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963844#comment-16963844
]
Zhu Zhu commented on FLINK-14566:
-
[~ykt836] When saying "little", I mean even "no" in t
becketqin commented on issue #9824: [FLINK-14302] [kafka]
FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if
`newPartitionsInTransaction` is empty when enable EoS
URL: https://github.com/apache/flink/pull/9824#issuecomment-548304699
@tony810430 Sorry, I missed th
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved FLINK-14302.
--
Resolution: Fixed
> FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-14302:
-
Fix Version/s: 1.10.0
> FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` reque
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963838#comment-16963838
]
Dawid Wysakowicz edited comment on FLINK-13702 at 10/31/19 10:27 AM:
-
flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple
ClusterDescriptor/ClusterSpecification from CommandLine
URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099
## CI report:
* 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS
[Build](
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341056655
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/Task
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341059365
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/Task
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341058817
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/Task
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341058561
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/Task
zhuzhurk commented on a change in pull request #9797: [FLINK-14059][core]
Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig
URL: https://github.com/apache/flink/pull/9797#discussion_r341062247
##
File path:
flink-core/src/main/java/org/apache/flink/api/
[
https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963844#comment-16963844
]
Zhu Zhu edited comment on FLINK-14566 at 10/31/19 10:36 AM:
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341062447
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/Task
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341064902
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManag
flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the
number of bytes from input parameters in HybridMemorySegment
URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242
## CI report:
* 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS
[Buil
flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce
NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.
URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804
## CI report:
* f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE
flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933
## CI report:
* 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN
* 083f6a67ae04af531615736c2fc51
kl0u commented on a change in pull request #9974: [FLINK-14501][FLINK-14502]
Decouple ClusterDescriptor/ClusterSpecification from CommandLine
URL: https://github.com/apache/flink/pull/9974#discussion_r341066690
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnCluste
zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope
of MemoryManager from TaskExecutor to slot
URL: https://github.com/apache/flink/pull/10034#discussion_r341066870
##
File path:
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/
flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805
## CI report:
* f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE
[Build](https://travis-c
pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime]
Respect non-blocking output in StreamTask#processInput
URL: https://github.com/apache/flink/pull/10029#discussion_r341068032
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/r
flinkbot edited a comment on issue #10033:
[FLINK-14021][table-planner][table-planner-blink] Add rules to push down the
Python ScalarFunctions contained in the join condition of Correlate node
URL: https://github.com/apache/flink/pull/10033#issuecomment-547423846
## CI report:
*
flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write
FLINK_PLUGINS_DIR env variable to Configuration
URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114
## CI report:
* d162b69fa12ca127b422d68e79e222415347c24d : FAILURE
[Build](https://travis-c
zentol merged pull request #9797: [FLINK-14059][core] Introduce option
allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig
URL: https://github.com/apache/flink/pull/9797
This is an automated message from the Apache
flinkbot commented on issue #10060: [FLINK-14546] [flink-json] Support map type
in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : UNKNOWN
Bot commands
The @flinkbot bot s
[
https://issues.apache.org/jira/browse/FLINK-14476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-14476.
Resolution: Fixed
master: 782526eb6215962fc4caee6b818f0aade58518b9
> Extend PartitionTrac
zentol merged pull request #9960: [FLINK-14476] Extend PartitionTracker to
support promotions
URL: https://github.com/apache/flink/pull/9960
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-14059.
Resolution: Fixed
master:
6ae3f25d0bbac8d28bfa481796656cfdd85baf22
1f7655f6aa25d7cccbc7f
pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime]
Respect non-blocking output in StreamTask#processInput
URL: https://github.com/apache/flink/pull/10029#discussion_r341069414
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/r
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support
partition for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939
## CI report:
* 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE
[Build](https://travis-ci.com/flink-ci/
flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option
allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig
URL: https://github.com/apache/flink/pull/9797#issuecomment-536255105
## CI report:
* 17be7faf6d9c7dd26408c0649491c9401e65f866 : FAILURE
[
Chesnay Schepler created FLINK-14586:
Summary: JobMaster issues promote calls if job is successful
Key: FLINK-14586
URL: https://issues.apache.org/jira/browse/FLINK-14586
Project: Flink
I
flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040
## CI report:
* 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE
[Build](https://travis-ci
[
https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963873#comment-16963873
]
Piotr Nowojski commented on FLINK-10257:
Just a side comment about the behaviour
flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple
ClusterDescriptor/ClusterSpecification from CommandLine
URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099
## CI report:
* 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS
[Build](
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r341077087
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r341077763
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou
AHeise commented on a change in pull request #10029: [FLINK-14553][runtime]
Respect non-blocking output in StreamTask#processInput
URL: https://github.com/apache/flink/pull/10029#discussion_r341077614
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/Availabili
[
https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963884#comment-16963884
]
Zili Chen commented on FLINK-14565:
---
Thanks for your insights. I agree that we don't m
[
https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963884#comment-16963884
]
Zili Chen edited comment on FLINK-14565 at 10/31/19 11:14 AM:
flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce
NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.
URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804
## CI report:
* f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE
flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805
## CI report:
* f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE
[Build](https://travis-c
flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933
## CI report:
* 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN
* 083f6a67ae04af531615736c2fc51
flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write
FLINK_PLUGINS_DIR env variable to Configuration
URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114
## CI report:
* d162b69fa12ca127b422d68e79e222415347c24d : FAILURE
[Build](https://travis-c
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : PENDING
[Build](https://travis-ci.com/flink-ci/f
yanghua commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER
in ExecutionGraph
URL: https://github.com/apache/flink/pull/10058#issuecomment-548326015
cc @GJL
This is an automated message from the Apache Git
flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040
## CI report:
* 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE
[Build](https://travis-ci
zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime]
Respect non-blocking output in StreamTask#processInput
URL: https://github.com/apache/flink/pull/10029#discussion_r341085791
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/r
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963894#comment-16963894
]
Jark Wu edited comment on FLINK-13702 at 10/31/19 11:30 AM:
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963894#comment-16963894
]
Jark Wu commented on FLINK-13702:
-
I thought about call {{duplicate}} too, but calling {
WeiZhong94 opened a new pull request #10061: [FLINK-14581][python] Let python
UDF execution no longer rely on the flink directory structure to support
running python UDFs on yarn.
URL: https://github.com/apache/flink/pull/10061
## What is the purpose of the change
*This pull request
[
https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14581:
---
Labels: pull-request-available (was: )
> Support to run Python UDF jobs in a YARN cluster
>
pnowojski commented on a change in pull request #9993:
[FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting
with LocalBufferPool.
URL: https://github.com/apache/flink/pull/9993#discussion_r341081009
##
File path:
flink-runtime/src/main/java/org/apache/fl
flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF
execution no longer rely on the flink directory structure to support running
python UDFs on yarn.
URL: https://github.com/apache/flink/pull/10061#issuecomment-548329682
Thanks a lot for your contribution to the Apache
[
https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963896#comment-16963896
]
Gary Yao commented on FLINK-14583:
--
I think it can be removed.
> Remove progressLock f
[
https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963896#comment-16963896
]
Gary Yao edited comment on FLINK-14583 at 10/31/19 11:37 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963897#comment-16963897
]
Jingsong Lee commented on FLINK-13702:
--
Hi [~dwysakowicz] , I think maybe we don't
[
https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963898#comment-16963898
]
Gary Yao commented on FLINK-14582:
--
How much time can we save with this feature? Afaik
hequn8128 closed pull request #10047: [FLINK-14557][python] Cleanup the py4j
package
URL: https://github.com/apache/flink/pull/10047
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963900#comment-16963900
]
Hequn Cheng commented on FLINK-14557:
-
Resolved in 1.10.0 via 63b5c941d795e065fad0d5
[
https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-14557.
---
Resolution: Resolved
> Clean up the package of py4j
>
>
>
flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the
number of bytes from input parameters in HybridMemorySegment
URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242
## CI report:
* 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS
[Buil
flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933
## CI report:
* 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN
* 083f6a67ae04af531615736c2fc51
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963903#comment-16963903
]
Jingsong Lee commented on FLINK-13702:
--
About BinaryGeneric:
I have considered pas
flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805
## CI report:
* f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE
[Build](https://travis-c
[
https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963905#comment-16963905
]
vinoyang commented on FLINK-14583:
--
OK, will open a PR.
> Remove progressLock from Exe
Gary Yao created FLINK-14587:
Summary: HiveTableSourceTest timeouts on Travis
Key: FLINK-14587
URL: https://issues.apache.org/jira/browse/FLINK-14587
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-14587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-14587:
-
Description:
{{HiveTableSourceTest}} failed in nightly tests running on Travis (stage: misc
- scala 2.1
flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write
FLINK_PLUGINS_DIR env variable to Configuration
URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114
## CI report:
* d162b69fa12ca127b422d68e79e222415347c24d : FAILURE
[Build](https://travis-c
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963911#comment-16963911
]
Gary Yao commented on FLINK-14505:
--
Another instance https://api.travis-ci.org/v3/job/6
flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race
condition during task cancellation
URL: https://github.com/apache/flink/pull/10049#issuecomment-547930818
## CI report:
* 7e94dd883cdbfa5f32bdf727166366819f956a17 : SUCCESS
[Build](https://travis-ci.co
JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce
FileSystemOutputFormat for batch
URL: https://github.com/apache/flink/pull/9864#issuecomment-548334839
> We can try to find more appropriate modules for these but
`flink-table-common` is definitely not one of them.
flinkbot commented on issue #10061: [FLINK-14581][python] Let python UDF
execution no longer rely on the flink directory structure to support running
python UDFs on yarn.
URL: https://github.com/apache/flink/pull/10061#issuecomment-548335375
## CI report:
* 6f081dffc4e0da56df96f
JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition
for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548336267
CC: @dawidwys
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963915#comment-16963915
]
Yang Wang commented on FLINK-9953:
--
Hi [~felixzheng],
Do you have some time to help with
flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple
ClusterDescriptor/ClusterSpecification from CommandLine
URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099
## CI report:
* 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS
[Build](
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r341077763
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341102714
##
File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
##
@@ -95,
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341102675
##
File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
##
@@ -95,
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341102751
##
File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java
##
@@ -95,
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341101306
##
File path:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
##
@@
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341102998
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamCont
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude
detach flag from ClusterClient
URL: https://github.com/apache/flink/pull/9972#discussion_r341102126
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
###
flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805
## CI report:
* f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE
[Build](https://travis-c
flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward
configuration to Mesos TaskExecutor
URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933
## CI report:
* 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN
* 083f6a67ae04af531615736c2fc51
pnowojski commented on a change in pull request #10049: [FLINK-14544][runtime]
Fixing race condition during task cancellation
URL: https://github.com/apache/flink/pull/10049#discussion_r341104156
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/ta
[
https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963941#comment-16963941
]
Dawid Wysakowicz commented on FLINK-13702:
--
There is one problem with entirely
GJL commented on issue #10044: [FLINK-14440][tests] Annotate
BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it
URL: https://github.com/apache/flink/pull/10044#issuecomment-548346162
Merging.
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963942#comment-16963942
]
Yang Wang commented on FLINK-14582:
---
>From the experience of our cluster, uploading a
101 - 200 of 491 matches
Mail list logo