[jira] [Closed] (FLINK-7259) Match not exhaustive in TaskMonitor

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7259. Resolution: Duplicate > Match not exhaustive in TaskMonitor > ---

[GitHub] [flink] hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release.

2019-10-25 Thread GitBox
hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release. URL: https://github.com/apache/flink/pull/9982#discussion_r338978765 ## File path: flink-python/README.md ## @@ -1,37 +1,28 @@

[GitHub] [flink] hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release.

2019-10-25 Thread GitBox
hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release. URL: https://github.com/apache/flink/pull/9982#discussion_r338978547 ## File path: flink-python/README.md ## @@ -1,37 +1,28 @@

[GitHub] [flink] hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release.

2019-10-25 Thread GitBox
hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release. URL: https://github.com/apache/flink/pull/9982#discussion_r338975210 ## File path: flink-python/README.md ## @@ -1,37 +1,28 @@

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release.

2019-10-25 Thread GitBox
hequn8128 commented on a change in pull request #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release. URL: https://github.com/apache/flink/pull/9982#discussion_r338980127 ## File path: flink-python/README.md ## @@ -1,37 +1,28 @@

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[jira] [Created] (FLINK-14530) Capture partition meta info in PartitionTable

2019-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-14530: Summary: Capture partition meta info in PartitionTable Key: FLINK-14530 URL: https://issues.apache.org/jira/browse/FLINK-14530 Project: Flink Issue

[GitHub] [flink] nealsun commented on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

2019-10-25 Thread GitBox
nealsun commented on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#issuecomment-546310355 > Hi @nealsun , I think you can use `JDBCUpsertTableSink` with `setIsAppendOnly(true)` first, it support `maxRetryTime` now.

[jira] [Closed] (FLINK-14342) Remove method FunctionDefinition#getLanguage

2019-10-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14342. --- Resolution: Resolved > Remove method FunctionDefinition#getLanguage >

[jira] [Commented] (FLINK-14342) Remove method FunctionDefinition#getLanguage

2019-10-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959655#comment-16959655 ] Hequn Cheng commented on FLINK-14342: - Resolved in 1.10.0 via

[jira] [Commented] (FLINK-14519) Fail on invoking declineCheckpoint remotely

2019-10-25 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959667#comment-16959667 ] Jiayi Liao commented on FLINK-14519: [~tison] I'm choosing the wrong affected version by mistake.

[GitHub] [flink] sunhaibotb commented on a change in pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

2019-10-25 Thread GitBox
sunhaibotb commented on a change in pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#discussion_r339010844 ## File path:

[GitHub] [flink] wuchong commented on issue #9980: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

2019-10-25 Thread GitBox
wuchong commented on issue #9980: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/9980#issuecomment-546330201 Hi @haodang , I just found this pull request is based on release-1.8. However, usually, the

[jira] [Assigned] (FLINK-13815) Implement the SpaceAllocator

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13815: - Assignee: Yu Li > Implement the SpaceAllocator > > >

[jira] [Assigned] (FLINK-13801) Introduce a HybridStateTable to combine everything together

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13801: - Assignee: PengFei Li > Introduce a HybridStateTable to combine everything together >

[jira] [Comment Edited] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

2019-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959721#comment-16959721 ] Piotr Nowojski edited comment on FLINK-13848 at 10/25/19 12:44 PM: ---

[jira] [Assigned] (FLINK-13803) Introduce SpillableHeapKeyedStateBackend and all necessities

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13803: - Assignee: PengFei Li > Introduce SpillableHeapKeyedStateBackend and all necessities >

[jira] [Commented] (FLINK-14482) Bump up rocksdb version to support WriteBufferManager

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959722#comment-16959722 ] Till Rohrmann commented on FLINK-14482: --- I guess this JIRA needs to be updated in order to reflect

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

2019-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959721#comment-16959721 ] Piotr Nowojski commented on FLINK-13848: Have you thought how to resolve the issue from you

[jira] [Assigned] (FLINK-14482) Bump up rocksdb version to support WriteBufferManager

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14482: - Assignee: Yun Tang > Bump up rocksdb version to support WriteBufferManager >

[GitHub] [flink] flinkbot edited a comment on issue #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#issuecomment-546340693 ## CI report: * 6f8df3c0d62bcf206edbb473dadad6a77b1bbf63 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS

[GitHub] [flink] dawidwys commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions.

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions. URL: https://github.com/apache/flink/pull/9976#discussion_r339040692 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions

2019-10-25 Thread GitBox
zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions URL: https://github.com/apache/flink/pull/9958#discussion_r339079293 ## File path:

[jira] [Created] (FLINK-14529) Compile-jdk11 fails in nightly end-to-end test

2019-10-25 Thread Yu Li (Jira)
Yu Li created FLINK-14529: - Summary: Compile-jdk11 fails in nightly end-to-end test Key: FLINK-14529 URL: https://issues.apache.org/jira/browse/FLINK-14529 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9277) Reduce noisiness of SlotPool logging

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959600#comment-16959600 ] Till Rohrmann commented on FLINK-9277: -- I think you are right [~sihuazhou] that this issue is kind

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338967232 ## File path:

[GitHub] [flink] zentol edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

2019-10-25 Thread GitBox
zentol edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#issuecomment-546286606 Ah shoot, they should be grouped by the corresponding `IntermediateDataSetID` instead, the

[GitHub] [flink] flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#issuecomment-545338875 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] zentol commented on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

2019-10-25 Thread GitBox
zentol commented on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#issuecomment-546286606 Ah shoot, they should be grouped by the corresponding `IntermediateDataSetID` instead

[jira] [Updated] (FLINK-14322) Add watermark information in TableSchema

2019-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14322: --- Labels: pull-request-available (was: ) > Add watermark information in TableSchema >

[GitHub] [flink] wuchong opened a new pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
wuchong opened a new pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994 ## What is the purpose of the change As discussed in FLIP-66, the watermark information should be part of

[GitHub] [flink] flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#issuecomment-542062879 ## CI report: * efdb2ad3942939590bbb0203ab04bae5fec634a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#issuecomment-491760218 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 #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539902528 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-14520) Could not find a suitable table factory, but Factory is available

2019-10-25 Thread Miguel Serrano (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959644#comment-16959644 ] Miguel Serrano commented on FLINK-14520: Thanks Jark, worked like a charm. > Could not find a

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[jira] [Updated] (FLINK-14519) Fail on invoking declineCheckpoint remotely

2019-10-25 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-14519: --- Affects Version/s: (was: 1.9.1) 1.9.0 > Fail on invoking

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

2019-10-25 Thread GitBox
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_r339025236 ## File path:

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

2019-10-25 Thread GitBox
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_r339025236 ## File path:

[GitHub] [flink] zentol commented on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

2019-10-25 Thread GitBox
zentol commented on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#issuecomment-546340144 We don't have access to the DataSetID at the time of release, since the tracking works exclusively with

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : FAILURE

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959752#comment-16959752 ] Piotr Nowojski commented on FLINK-14382: > Are you suggesting to set

[jira] [Commented] (FLINK-13839) Support to set yarn node label for flink jobmanager and taskmanager container

2019-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959778#comment-16959778 ] Chesnay Schepler commented on FLINK-13839: -- What changes would this require? > Support to set

[GitHub] [flink] dawidwys commented on a change in pull request #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account

2019-10-25 Thread GitBox
dawidwys commented on a change in pull request #9915: [FLINK-14415][table-common] ValueLiteralExpression#equals should take array value into account URL: https://github.com/apache/flink/pull/9915#discussion_r339082528 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS

[jira] [Closed] (FLINK-8032) Create job control handler for JobMasterRestHandler

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8032. Resolution: Invalid No longer valid > Create job control handler for JobMasterRestHandler >

[jira] [Closed] (FLINK-7073) Create RESTful JobManager endpoint

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7073. Resolution: Done > Create RESTful JobManager endpoint > -- > >

[jira] [Assigned] (FLINK-12048) ZooKeeperHADispatcherTest failed on Travis

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-12048: - Assignee: (was: Till Rohrmann) > ZooKeeperHADispatcherTest failed on Travis >

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

2019-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959622#comment-16959622 ] Chesnay Schepler commented on FLINK-13639: -- May be required for FLIP-67, specifically to derive

[jira] [Closed] (FLINK-7340) Taskmanager hung after temporary DNS outage

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7340. Resolution: Fixed Since the user did not get back to us, I suppose that the issue has been fixed

[jira] [Commented] (FLINK-13722) Speed up documentation generation

2019-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959638#comment-16959638 ] Chesnay Schepler commented on FLINK-13722: -- [~NicoK] ruby 2.6.3 is now used for generating the

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

2019-10-25 Thread Alexander Kasyanenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959658#comment-16959658 ] Alexander Kasyanenko commented on FLINK-14074: -- [~trohrmann] thanks a lot for explanation

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959663#comment-16959663 ] Piotr Nowojski commented on FLINK-14382: > I think we just need to ship the plugin directory

[jira] [Comment Edited] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959663#comment-16959663 ] Piotr Nowojski edited comment on FLINK-14382 at 10/25/19 11:30 AM: --- > 

[GitHub] [flink] GJL commented on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment

2019-10-25 Thread GitBox
GJL commented on issue #9902: [FLINK-14363][runtime] Prevent vertex from being affected by outdated deployment URL: https://github.com/apache/flink/pull/9902#issuecomment-546317759 Merging. This is an automated message from

[GitHub] [flink] hequn8128 commented on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

2019-10-25 Thread GitBox
hequn8128 commented on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-546331941 @HuangXingBo Thanks a lot for the update. LGTM. Merging...

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : PENDING

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

2019-10-25 Thread GitBox
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_r339025236 ## File path:

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

2019-10-25 Thread GitBox
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_r339025236 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-25 Thread GitBox
tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-546350171 Thanks a lot for the review @GJL. I've addressed your comments, rebased and force pushed. Merging once Travis gives

[GitHub] [flink] flinkbot edited a comment on issue #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release.

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9982: [FLINK-14509][python] Improve the README.md in flink-python to prepare for PyPI release. URL: https://github.com/apache/flink/pull/9982#issuecomment-545785964 ## CI report: * adcf4ae485ab9905c80b4a93fc31bbb233fa7afb : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[jira] [Created] (FLINK-14533) PushFilterIntoTableSourceScanRule misses predicate pushdowns

2019-10-25 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-14533: --- Summary: PushFilterIntoTableSourceScanRule misses predicate pushdowns Key: FLINK-14533 URL: https://issues.apache.org/jira/browse/FLINK-14533 Project: Flink

[GitHub] [flink] zentol commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-25 Thread GitBox
zentol commented on a change in pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#discussion_r339058764 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9983: [FLINK-14518][coordination] Generalize TE->RM heartbeat payload

2019-10-25 Thread GitBox
tillrohrmann commented on a change in pull request #9983: [FLINK-14518][coordination] Generalize TE->RM heartbeat payload URL: https://github.com/apache/flink/pull/9983#discussion_r339071836 ## File path:

[GitHub] [flink] flinkbot commented on issue #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version

2019-10-25 Thread GitBox
flinkbot commented on issue #9997: [FLINK-14522] Introduce JavaGcCleanerWrapper to find Java GC Cleaner depending on JVM version URL: https://github.com/apache/flink/pull/9997#issuecomment-546370246 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-25 Thread GitBox
ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#discussion_r339072220 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions

2019-10-25 Thread GitBox
zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions URL: https://github.com/apache/flink/pull/9958#discussion_r339081254 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

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

2019-10-25 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14522: -- Priority: Blocker (was: Major) Escalate the priority to blocker since this fails the nightly end-to-end test

[jira] [Assigned] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7286: Assignee: (was: Hai Zhou) > Flink Dashboard fails to display bytes/records received

[jira] [Closed] (FLINK-7285) allow submission of big job graphs

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7285. Resolution: Invalid No longer a problem. > allow submission of big job graphs >

[jira] [Commented] (FLINK-13642) Refactor ShuffleMaster to optionally provide preferred TM location for produced partitions

2019-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959613#comment-16959613 ] Chesnay Schepler commented on FLINK-13642: -- is this still valid? > Refactor ShuffleMaster to

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959625#comment-16959625 ] Yang Wang commented on FLINK-14382: --- Thanks for updating the ticket [~pnowojski]. I think we just need

[GitHub] [flink] nealsun commented on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry

2019-10-25 Thread GitBox
nealsun commented on issue #8429: [FLINK-12499][JDBC] JDBCAppendTableSink support retry URL: https://github.com/apache/flink/pull/8429#issuecomment-546290627 hi, what is this PR's progress? I get mysql open failed exception, and the job will restart. Retry is a good feature to avoid

[jira] [Closed] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7486. Resolution: Abandoned > flink-mesos: Support for adding unique attribute / group_by attribute >

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

2019-10-25 Thread GitBox
JingsongLi commented on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-546295168 @KurtYoung Can you take a look when you're free? This

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

2019-10-25 Thread GitBox
flinkbot commented on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[jira] [Created] (FLINK-14532) Separate PartitionTracker into generic and JM-specific versions

2019-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-14532: Summary: Separate PartitionTracker into generic and JM-specific versions Key: FLINK-14532 URL: https://issues.apache.org/jira/browse/FLINK-14532 Project:

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

2019-10-25 Thread GitBox
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_r339025236 ## File path:

[jira] [Comment Edited] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959717#comment-16959717 ] Yang Wang edited comment on FLINK-14382 at 10/25/19 12:38 PM: -- [~pnowojski]

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959717#comment-16959717 ] Yang Wang commented on FLINK-14382: --- [~pnowojski] > About the environment What i mean is to set

[GitHub] [flink] zentol commented on a change in pull request #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

2019-10-25 Thread GitBox
zentol commented on a change in pull request #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#discussion_r339043883 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions

2019-10-25 Thread GitBox
zentol commented on a change in pull request #9958: [FLINK-14475][coordination] Adjust TaskExecutor interface to accept promotions URL: https://github.com/apache/flink/pull/9958#discussion_r339083598 ## File path:

[jira] [Resolved] (FLINK-9277) Reduce noisiness of SlotPool logging

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9277. -- Resolution: Duplicate > Reduce noisiness of SlotPool logging >

[jira] [Closed] (FLINK-7296) Validate commit messages in git pre-receive hook

2019-10-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7296. Resolution: Abandoned > Validate commit messages in git pre-receive hook >

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546288706 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
flinkbot commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-25 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : PENDING

  1   2   3   4   5   6   >