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

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Affects Version/s: 1.10.0 1.9.1 > Do not upload

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

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Priority: Minor (was: Major) > Do not upload {uuid}-taskmanager-conf.yaml for each task

[GitHub] [flink] JingsongLi opened a new pull request #10059: [FLINK-14543][table] Support partition for temporary table

JingsongLi opened a new pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059 ## What is the purpose of the change Now, temporary table not carry partition keys information. We need add these information

[jira] [Updated] (FLINK-14543) Support partition for temporary table

[ https://issues.apache.org/jira/browse/FLINK-14543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14543: --- Labels: pull-request-available (was: ) > Support partition for temporary table >

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

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_r341030546 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[jira] [Updated] (FLINK-14573) Support time data types in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14573: - Fix Version/s: 1.10.0 > Support time data types in Python user-defined functions >

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

Dian Fu created FLINK-14581: --- Summary: Support to run Python UDF jobs in a YARN cluster Key: FLINK-14581 URL: https://issues.apache.org/jira/browse/FLINK-14581 Project: Flink Issue Type: Sub-task

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

zhijiangW 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_r340984301 ## File path:

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

zhijiangW 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_r340984437 ## File path:

[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963714#comment-16963714 ] Gyula Fora commented on FLINK-14577: [~nickRyan], we can draft a proposal with our current

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

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

KurtYoung commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548244289 why putting this to `flink-table-common`? This is an

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340989060 ## File path:

[GitHub] [flink] KarlManong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

KarlManong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r340991295 ## File path:

[jira] [Updated] (FLINK-14488) Update python table API with temporary tables & views methods

[ https://issues.apache.org/jira/browse/FLINK-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14488: --- Labels: pull-request-available (was: ) > Update python table API with temporary tables &

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r340996123 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340999040 ## File path:

[GitHub] [flink] HuangXingBo commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

HuangXingBo commented on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-548258003 Thanks for @hequn8128 @JingsongLi review, I have

[jira] [Updated] (FLINK-14522) Adjust GC Cleaner for unsafe memory and Java 11

[ https://issues.apache.org/jira/browse/FLINK-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-14522: Priority: Major (was: Blocker) > Adjust GC Cleaner for unsafe memory and Java 11 >

[jira] [Closed] (FLINK-14522) Adjust GC Cleaner for unsafe memory and Java 11

[ https://issues.apache.org/jira/browse/FLINK-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-14522. --- Resolution: Fixed Merged into master by e41c0feaea174642c7c05d3baef7d011b47401d8 > Adjust

[GitHub] [flink] azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r341009633 ## File path:

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

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

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

flinkbot edited a comment on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057#issuecomment-548252146 ## CI report: * 53d0b7dd23f39f6b8308958475c23ca8dd32aa1c : SUCCESS

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

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

[GitHub] [flink] wangyang0918 commented on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

wangyang0918 commented on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-548282516 LGTM, ready for merge. This is an

[jira] [Created] (FLINK-14584) Support complex data types in Python user-defined functions

Huang Xingbo created FLINK-14584: Summary: Support complex data types in Python user-defined functions Key: FLINK-14584 URL: https://issues.apache.org/jira/browse/FLINK-14584 Project: Flink

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963709#comment-16963709 ] Gyula Fora commented on FLINK-14531: I think the first step here would be to draft up a proposal

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

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 :

[jira] [Commented] (FLINK-14570) KeyedStateBootstrapFunction missed onTimer callback method to fire timer

[ https://issues.apache.org/jira/browse/FLINK-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963720#comment-16963720 ] vinoyang commented on FLINK-14570: -- [~sjwiesman] Re-understand your comments and feel that the design

[GitHub] [flink] docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548245095 @wuchong 1. Adding new interface for BaseRow is another

[GitHub] [flink] docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548245095 @wuchong 1. Adding new interface for BaseRow is another

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

JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548247589 > why putting this to `flink-table-common`? You mean we can put it to `flink-connector-filesystem`? 1.Now

[GitHub] [flink] zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548248413 Thanks for the updates @wsry and the supplement reviews @pnowojski . I reviewed

[GitHub] [flink] dianfu opened a new pull request #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

dianfu opened a new pull request #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057 ## What is the purpose of the change *This pull request update the Python table API with temporary tables &

[GitHub] [flink] flinkbot commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

flinkbot commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057#issuecomment-548249280 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods

flinkbot commented on issue #10057: [FLINK-14488][python] Update python table API with temporary tables & views methods URL: https://github.com/apache/flink/pull/10057#issuecomment-548252146 ## CI report: * 53d0b7dd23f39f6b8308958475c23ca8dd32aa1c : UNKNOWN Bot

[GitHub] [flink] yanghua opened a new pull request #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

yanghua opened a new pull request #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10058 ## What is the purpose of the change *This pull request removed GLOBAL_VERSION_UPDATER in ExecutionGraph* ## Brief

[GitHub] [flink] GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

GJL commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340999720 ## File path:

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

KurtYoung commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-548258234 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 #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

flinkbot commented on issue #10058: [FLINK-12527] Remove GLOBAL_VERSION_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10058#issuecomment-548260082 ## CI report: * 1aec27bd75bab810acc79fca474a8c7aaad89f24 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] azagrebin merged pull request #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version

azagrebin merged pull request #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version URL: https://github.com/apache/flink/pull/9997 This is an automated message from the Apache

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r341012096 ## File path:

[GitHub] [flink] docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

docete edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548245095 @wuchong 1. Adding new interface for BaseRow is another

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

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10257: --- Assignee: huang zheng (was: Hequn Cheng) > Incorrect CHAR type support in Flink SQL and

[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

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 commented on issue #10059: [FLINK-14543][table] Support partition for temporary table

flinkbot commented on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548281854 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

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

wsry 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_r341032280 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963806#comment-16963806 ] Till Rohrmann commented on FLINK-14566: --- Would it be possible to say in the first version that

[GitHub] [flink] liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r341036760 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

liyafan82 commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r341036537 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions

zentol commented on a change in pull request #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#discussion_r341038943 ## File path:

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963811#comment-16963811 ] Till Rohrmann commented on FLINK-11127: --- This sounds a bit strange that cancelling a job makes the

[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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963812#comment-16963812 ] Jark Wu commented on FLINK-13702: - Thanks for the approach. I think it can solve the problem of

[jira] [Created] (FLINK-14585) flink connector for sink to apache/incubator-druid

xiaodao created FLINK-14585: --- Summary: flink connector for sink to apache/incubator-druid Key: FLINK-14585 URL: https://issues.apache.org/jira/browse/FLINK-14585 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

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

zentol 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_r341045086 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r341046403 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

tillrohrmann commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r341046403 ## File path:

[GitHub] [flink] becketqin merged pull request #9824: [FLINK-14302] [kafka] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when ena

becketqin merged pull request #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

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

wsry 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_r341048184 ## File path:

[GitHub] [flink] wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548296338 @zhijiangW Thanks for the review. I have updated the PR.

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

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:

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

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

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

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

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

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

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 :

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

[ 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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963844#comment-16963844 ] Zhu Zhu commented on FLINK-14566: - [~ykt836] When saying "little", I mean even "no" in the worst case.

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

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963844#comment-16963844 ] Zhu Zhu edited comment on FLINK-14566 at 10/31/19 10:36 AM: [~ykt836] When

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

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:

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

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:

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

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 *

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

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:

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

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:

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

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

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

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

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

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

[GitHub] [flink] flinkbot commented on issue #10060: [FLINK-14546] [flink-json] 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-548313242 ## CI report: * c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : UNKNOWN Bot commands The @flinkbot bot

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

[ 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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963809#comment-16963809 ] Till Rohrmann commented on FLINK-14565: --- Thanks for reporting this issue [~tison]. This sounds

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

flinkbot commented on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 4937b8b139bab4957799947b841fb1ae3758ed48 : UNKNOWN Bot commands The @flinkbot bot

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

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-10257: - Fix Version/s: (was: 1.10.0) > Incorrect CHAR type support in Flink SQL and Table API >

[jira] [Updated] (FLINK-14081) Support precision of TimeType

[ https://issues.apache.org/jira/browse/FLINK-14081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14081: - Fix Version/s: (was: 1.10.0) > Support precision of TimeType >

[jira] [Updated] (FLINK-14082) Support precision of DayTimeIntervalType and YearMonthIntervalType

[ https://issues.apache.org/jira/browse/FLINK-14082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14082: - Fix Version/s: (was: 1.10.0) > Support precision of DayTimeIntervalType and

[jira] [Updated] (FLINK-14083) Support StructuredType

[ https://issues.apache.org/jira/browse/FLINK-14083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14083: - Fix Version/s: (was: 1.10.0) > Support StructuredType > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963822#comment-16963822 ] Chesnay Schepler commented on FLINK-14565: -- +1 to managing the thread outside the metric

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

KarmaGYZ commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r341034021 ## File path:

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

KarmaGYZ commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r340457215 ## File path:

<    1   2   3   4   5   >