[GitHub] [flink] zhuzhurk commented on a change in pull request #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-31 Thread GitBox
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/

[GitHub] [flink] libenchao opened a new pull request #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
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

[GitHub] [flink] tillrohrmann commented on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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. ---

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
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

[jira] [Updated] (FLINK-14546) Support map type in flink-json

2019-10-31 Thread ASF GitHub Bot (Jira)
[ 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 > -

[GitHub] [flink] flinkbot commented on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Dawid Wysakowicz (Jira)
[ 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 [

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table

2019-10-31 Thread GitBox
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/

[GitHub] [flink] flinkbot edited a comment on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

2019-10-31 Thread GitBox
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-

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Dawid Wysakowicz (Jira)
[ 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: -

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-10-31 Thread Zhu Zhu (Jira)
[ 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

[GitHub] [flink] becketqin commented on issue #9824: [FLINK-14302] [kafka] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enab

2019-10-31 Thread GitBox
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

[jira] [Resolved] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-31 Thread Jiangjie Qin (Jira)
[ 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

[jira] [Updated] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-31 Thread Jiangjie Qin (Jira)
[ 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

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Dawid Wysakowicz (Jira)
[ 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: -

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

2019-10-31 Thread GitBox
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](

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] zhuzhurk commented on a change in pull request #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-31 Thread GitBox
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/

[jira] [Comment Edited] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-10-31 Thread Zhu Zhu (Jira)
[ 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:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] kl0u commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

2019-10-31 Thread GitBox
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/

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-31 Thread GitBox
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

[GitHub] [flink] 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 Corre

2019-10-31 Thread GitBox
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: *

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-31 Thread GitBox
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

[GitHub] [flink] zentol merged pull request #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot commented on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
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

[jira] [Closed] (FLINK-14476) Extend PartitionTracker to support partition promotions

2019-10-31 Thread Chesnay Schepler (Jira)
[ 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

[GitHub] [flink] zentol merged pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

2019-10-31 Thread GitBox
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

[jira] [Closed] (FLINK-14059) Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-31 Thread Chesnay Schepler (Jira)
[ 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

[GitHub] [flink] pnowojski commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table

2019-10-31 Thread GitBox
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/

[GitHub] [flink] flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

2019-10-31 Thread GitBox
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 [

[jira] [Created] (FLINK-14586) JobMaster issues promote calls if job is successful

2019-10-31 Thread Chesnay Schepler (Jira)
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

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

2019-10-31 Thread Piotr Nowojski (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

2019-10-31 Thread GitBox
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](

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-10-31 Thread GitBox
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

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-10-31 Thread GitBox
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

[GitHub] [flink] AHeise commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

2019-10-31 Thread Zili Chen (Jira)
[ 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

[jira] [Comment Edited] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

2019-10-31 Thread Zili Chen (Jira)
[ 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:

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
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

[GitHub] [flink] yanghua commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

2019-10-31 Thread GitBox
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

[GitHub] [flink] zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

2019-10-31 Thread GitBox
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

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jark Wu (Jira)
[ 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:

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jark Wu (Jira)
[ 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 {

[GitHub] [flink] 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.

2019-10-31 Thread GitBox
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

[jira] [Updated] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

2019-10-31 Thread ASF GitHub Bot (Jira)
[ 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 >

[GitHub] [flink] pnowojski commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
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

[GitHub] [flink] 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.

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14583) Remove progressLock from ExecutionGraph

2019-10-31 Thread Gary Yao (Jira)
[ 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

[jira] [Comment Edited] (FLINK-14583) Remove progressLock from ExecutionGraph

2019-10-31 Thread Gary Yao (Jira)
[ 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: -

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ 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

[jira] [Commented] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-10-31 Thread Gary Yao (Jira)
[ 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

[GitHub] [flink] hequn8128 closed pull request #10047: [FLINK-14557][python] Cleanup the py4j package

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14557) Clean up the package of py4j

2019-10-31 Thread Hequn Cheng (Jira)
[ 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

[jira] [Closed] (FLINK-14557) Clean up the package of py4j

2019-10-31 Thread Hequn Cheng (Jira)
[ 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 > > >

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14583) Remove progressLock from ExecutionGraph

2019-10-31 Thread vinoyang (Jira)
[ 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

[jira] [Created] (FLINK-14587) HiveTableSourceTest timeouts on Travis

2019-10-31 Thread Gary Yao (Jira)
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

[jira] [Updated] (FLINK-14587) HiveTableSourceTest timeouts on Travis

2019-10-31 Thread Gary Yao (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-10-31 Thread Gary Yao (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

2019-10-31 Thread GitBox
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

[GitHub] [flink] JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-10-31 Thread GitBox
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.

[GitHub] [flink] 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.

2019-10-31 Thread GitBox
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

[GitHub] [flink] JingsongLi commented on issue #10059: [FLINK-14543][table] Support partition for temporary table

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2019-10-31 Thread Yang Wang (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

2019-10-31 Thread GitBox
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](

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

2019-10-31 Thread GitBox
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

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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,

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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,

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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,

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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 ## @@

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
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 ###

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

2019-10-31 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Dawid Wysakowicz (Jira)
[ 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

[GitHub] [flink] GJL commented on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it

2019-10-31 Thread GitBox
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

[jira] [Commented] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

2019-10-31 Thread Yang Wang (Jira)
[ 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

<    1   2   3   4   5   >