[jira] [Created] (FLINK-12855) Stagger panes on partitions to distribute workload.

2019-06-14 Thread Teng Hu (JIRA)
Teng Hu created FLINK-12855: --- Summary: Stagger panes on partitions to distribute workload. Key: FLINK-12855 URL: https://issues.apache.org/jira/browse/FLINK-12855 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-12855) Stagger panes on partitions to distribute workload.

2019-06-14 Thread Teng Hu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Teng Hu updated FLINK-12855: Attachment: (was: stagger_window_delay.png) > Stagger panes on partitions to distribute workload. >

[jira] [Updated] (FLINK-12855) Stagger panes on partitions to distribute workload.

2019-06-14 Thread Teng Hu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Teng Hu updated FLINK-12855: Attachment: stagger_window.png > Stagger panes on partitions to distribute workload. >

[GitHub] [flink] mans2singh commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics …

2019-06-14 Thread GitBox
mans2singh commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics … URL: https://github.com/apache/flink/pull/8668#discussion_r294030972 ## File path:

[GitHub] [flink] wangkuiyi opened a new pull request #7015: Add the -p option to nc

2019-06-14 Thread GitBox
wangkuiyi opened a new pull request #7015: Add the -p option to nc URL: https://github.com/apache/flink/pull/7015 ## Purpose When I run the [quick start](https://ci.apache.org/projects/flink/flink-docs-release-1.6/quickstart/setup_quickstart.html) tutorial in Docker containers

[GitHub] [flink] wangkuiyi commented on issue #7015: Add the -p option to nc

2019-06-14 Thread GitBox
wangkuiyi commented on issue #7015: Add the -p option to nc URL: https://github.com/apache/flink/pull/7015#issuecomment-502324878 Thanks for following up @greghogan and @zentol . I am closing this PR. This is an automated

[GitHub] [flink] wangkuiyi closed pull request #7015: Add the -p option to nc

2019-06-14 Thread GitBox
wangkuiyi closed pull request #7015: Add the -p option to nc URL: https://github.com/apache/flink/pull/7015 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] wangkuiyi closed pull request #7015: Add the -p option to nc

2019-06-14 Thread GitBox
wangkuiyi closed pull request #7015: Add the -p option to nc URL: https://github.com/apache/flink/pull/7015 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] XuPingyong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
XuPingyong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r294029650 ## File path:

[GitHub] [flink] XuPingyong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
XuPingyong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r294029548 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8700: [FLINK-12657][hive] Integrate Flink with Hive UDF

2019-06-14 Thread GitBox
bowenli86 commented on issue #8700: [FLINK-12657][hive] Integrate Flink with Hive UDF URL: https://github.com/apache/flink/pull/8700#issuecomment-502312751 I created FLINK-12854 to evaluate if we should support primitive types and convert them for Hive functions. This is not critical and

[jira] [Created] (FLINK-12854) evaluate and support for primitive array in Hive functions

2019-06-14 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12854: Summary: evaluate and support for primitive array in Hive functions Key: FLINK-12854 URL: https://issues.apache.org/jira/browse/FLINK-12854 Project: Flink Issue

[jira] [Closed] (FLINK-12705) Allow user to specify the Hive version in use

2019-06-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12705. Resolution: Fixed merged in 1.9.0: ec383d6c737fa0bc24ec6984bbc70207f8da9c53 > Allow user to specify the

[GitHub] [flink] asfgit closed pull request #8694: [FLINK-12705][hive] Allow user to specify the Hive version in use

2019-06-14 Thread GitBox
asfgit closed pull request #8694: [FLINK-12705][hive] Allow user to specify the Hive version in use URL: https://github.com/apache/flink/pull/8694 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] bowenli86 commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog URL: https://github.com/apache/flink/pull/8720#issuecomment-502237063 @xuefuz good idea to add tests for mixed operations, I'll add them. As I can think of for now, there should be no

[GitHub] [flink] Myasuka commented on issue #8745: [FLINK-11662] Disable task to fail on checkpoint errors

2019-06-14 Thread GitBox
Myasuka commented on issue #8745: [FLINK-11662] Disable task to fail on checkpoint errors URL: https://github.com/apache/flink/pull/8745#issuecomment-502235022 @flinkbot attention @StefanRRichter This is an automated

[GitHub] [flink] flinkbot commented on issue #8745: [FLINK-11662] Disable task to fail on checkpoint errors

2019-06-14 Thread GitBox
flinkbot commented on issue #8745: [FLINK-11662] Disable task to fail on checkpoint errors URL: https://github.com/apache/flink/pull/8745#issuecomment-502234862 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] Myasuka opened a new pull request #8745: Task not fail checkpoint

2019-06-14 Thread GitBox
Myasuka opened a new pull request #8745: Task not fail checkpoint URL: https://github.com/apache/flink/pull/8745 ## What is the purpose of the change FLINK-11662 has been a known and urgent issue after Flink-1.8 release. There exist two parts to fix this problem, one is from task

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293931882 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293934696 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293934522 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293932672 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293934316 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293932284 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293932104 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r293935284 ## File path:

[jira] [Comment Edited] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864356#comment-16864356 ] Xuefu Zhang edited comment on FLINK-12771 at 6/14/19 6:49 PM: -- Hi

[jira] [Commented] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864356#comment-16864356 ] Xuefu Zhang commented on FLINK-12771: - Hi [~dawidwys], Re: #2, communicating with Hive metastore

[GitHub] [flink] bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8703#discussion_r293925009 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8703#discussion_r293926968 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog

2019-06-14 Thread GitBox
bowenli86 commented on a change in pull request #8703: [FLINK-12807][hive]Support Hive table columnstats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8703#discussion_r293927620 ## File path:

[jira] [Commented] (FLINK-12836) Allow retained checkpoints to be persisted on success

2019-06-14 Thread Andrew Duffy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864343#comment-16864343 ] Andrew Duffy commented on FLINK-12836: -- Hey, yea the intention is to allow checkpoints to be reused

[jira] [Updated] (FLINK-12647) Make partition release on consumption optional

2019-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12647: - Description: ResultPartitions being released on consumption should no longer a

[jira] [Updated] (FLINK-12647) Make partition release on consumption optional

2019-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12647: - Summary: Make partition release on consumption optional (was: Add feature flag to

[jira] [Closed] (FLINK-12647) Make partition release on consumption optional

2019-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12647. Resolution: Fixed master: d9ac854a4155d14ffd9d81f883f796231b8e55e5 > Make partition

[GitHub] [flink] zentol merged pull request #8654: [FLINK-12647][network] Add feature flag to disable release of consumed blocking partitions

2019-06-14 Thread GitBox
zentol merged pull request #8654: [FLINK-12647][network] Add feature flag to disable release of consumed blocking partitions URL: https://github.com/apache/flink/pull/8654 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-12851) Add travis profile for gelly/kafka

2019-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12851. Resolution: Fixed master: b63c0f16dc0cd727d30459ee4d450662e47fe5f0 > Add travis profile

[GitHub] [flink] zentol merged pull request #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile

2019-06-14 Thread GitBox
zentol merged pull request #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile URL: https://github.com/apache/flink/pull/8743 This is an automated message from the Apache Git Service. To respond to the

[jira] [Comment Edited] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864321#comment-16864321 ] Bowen Li edited comment on FLINK-12771 at 6/14/19 6:15 PM: --- Hi [~dawidwys] ,

[jira] [Commented] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864321#comment-16864321 ] Bowen Li commented on FLINK-12771: -- Hi [~dawidwys] , here the [spec for Hive temp tables

[GitHub] [flink] xuefuz commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog

2019-06-14 Thread GitBox
xuefuz commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog URL: https://github.com/apache/flink/pull/8720#issuecomment-502209972 Also, since we are using a map to store the temp tables with combo of db name and table name as the key, I'm wondering

[GitHub] [flink] banmoy commented on issue #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on issue #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#issuecomment-502176398 @StefanRRichter I have addressed the comments.

[GitHub] [flink] banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#discussion_r293880412 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8225: [FLINK-10984]Remove flink-shaded-hadoop from flink

2019-06-14 Thread GitBox
sunjincheng121 commented on issue #8225: [FLINK-10984]Remove flink-shaded-hadoop from flink URL: https://github.com/apache/flink/pull/8225#issuecomment-502163792 I appreciate if you can have another look :) @zentol This is

[GitHub] [flink] Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-06-14 Thread GitBox
Xpray commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r293862114 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

2019-06-14 Thread GitBox
StephanEwen commented on a change in pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#discussion_r293857231 ## File path:

[GitHub] [flink] sunhaibotb commented on issue #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

2019-06-14 Thread GitBox
sunhaibotb commented on issue #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream URL: https://github.com/apache/flink/pull/8642#issuecomment-502151128 Thank you for reviewing @aljoscha . Because `JobMasterTest.Java` conflicts with

[GitHub] [flink] banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#discussion_r293850537 ## File path:

[GitHub] [flink] flinkbot commented on issue #8744: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

2019-06-14 Thread GitBox
flinkbot commented on issue #8744: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8744#issuecomment-502145656 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] aljoscha opened a new pull request #8744: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

2019-06-14 Thread GitBox
aljoscha opened a new pull request #8744: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8744 Copy of #8280 for running CI This is an automated message from the

[GitHub] [flink] banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#discussion_r293838949 ## File path:

[GitHub] [flink] banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#discussion_r293838949 ## File path:

[GitHub] [flink] banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-06-14 Thread GitBox
banmoy commented on a change in pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611#discussion_r293838949 ## File path:

[GitHub] [flink] asfgit closed pull request #8623: [FLINK-12719][python] Add the Python catalog API

2019-06-14 Thread GitBox
asfgit closed pull request #8623: [FLINK-12719][python] Add the Python catalog API URL: https://github.com/apache/flink/pull/8623 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293830121 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[jira] [Closed] (FLINK-12719) Add the Python catalog API

2019-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12719. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Congxian Qiu(klion26) (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864111#comment-16864111 ] Congxian Qiu(klion26) commented on FLINK-12619: --- Thanks for the doc [~carp84], and the

[GitHub] [flink] xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293826982 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293825335 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
xuyang1706 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293823761 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293789454 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864098#comment-16864098 ] Aljoscha Krettek commented on FLINK-12619: -- We had a short (but productive) call on this topic,

[jira] [Comment Edited] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864068#comment-16864068 ] Aljoscha Krettek edited comment on FLINK-12619 at 6/14/19 1:59 PM: ---

[jira] [Commented] (FLINK-12773) Unstable kafka e2e test

2019-06-14 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864095#comment-16864095 ] Alex commented on FLINK-12773: -- Is it possible to download/prepare external dependencies once and provision

[jira] [Commented] (FLINK-12143) Mechanism to ship plugin jars in the cluster

2019-06-14 Thread Alex (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864085#comment-16864085 ] Alex commented on FLINK-12143: -- The problem is because * {{parentFirstLoaderPatterns}} contains

[GitHub] [flink] EugeneYushin commented on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format

2019-06-14 Thread GitBox
EugeneYushin commented on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format URL: https://github.com/apache/flink/pull/8187#issuecomment-502113331 @dawidwys can you please ping an another person who can help reviewing this PR in case you have no capacity?

[jira] [Comment Edited] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864068#comment-16864068 ] Yu Li edited comment on FLINK-12619 at 6/14/19 1:32 PM: Wrote a document to

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864068#comment-16864068 ] Yu Li commented on FLINK-12619: --- Wrote a document to arrange and better share my thoughts, and below is a

[jira] [Comment Edited] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

2019-06-14 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864068#comment-16864068 ] Yu Li edited comment on FLINK-12619 at 6/14/19 1:31 PM: Wrote a document to

[GitHub] [flink] sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput

2019-06-14 Thread GitBox
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8731#discussion_r293805008 ## File path:

[jira] [Updated] (FLINK-12806) Remove beta feature remark from the Universal Kafka connector

2019-06-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12806: - Priority: Major (was: Blocker) > Remove beta feature remark from the Universal Kafka

[jira] [Comment Edited] (FLINK-12776) Ambiguous content in flink-dist NOTICE file

2019-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863997#comment-16863997 ] sunjincheng edited comment on FLINK-12776 at 6/14/19 1:05 PM: -- Thanks for

[jira] [Commented] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis

2019-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864037#comment-16864037 ] Till Rohrmann commented on FLINK-12071: --- How would this harden the test case? Maybe you could try

[GitHub] [flink] flinkbot commented on issue #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile

2019-06-14 Thread GitBox
flinkbot commented on issue #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile URL: https://github.com/apache/flink/pull/8743#issuecomment-502097767 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput

2019-06-14 Thread GitBox
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8731#discussion_r293744349 ## File path:

[GitHub] [flink] sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput

2019-06-14 Thread GitBox
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8731#discussion_r293793699 ## File path:

[jira] [Updated] (FLINK-12851) Add travis profile for gelly/kafka

2019-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12851: --- Labels: pull-request-available (was: ) > Add travis profile for gelly/kafka >

[GitHub] [flink] zentol opened a new pull request #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile

2019-06-14 Thread GitBox
zentol opened a new pull request #8743: [FLINK-12851][travis] Move gelly/kafka to separate profile URL: https://github.com/apache/flink/pull/8743 Introduces another test profile for running gelly and kafka (universal) tests. Additionally, now that kafka is out of misc. the

[GitHub] [flink] shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293789454 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[jira] [Comment Edited] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

2019-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16862841#comment-16862841 ] Till Rohrmann edited comment on FLINK-12541 at 6/14/19 12:46 PM: -

[GitHub] [flink] shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

2019-06-14 Thread GitBox
shaomengwang commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r293789454 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] tillrohrmann closed pull request #7227: [FLINK-11059] [runtime] do not add releasing failed slot to free slots

2019-06-14 Thread GitBox
tillrohrmann closed pull request #7227: [FLINK-11059] [runtime] do not add releasing failed slot to free slots URL: https://github.com/apache/flink/pull/7227 This is an automated message from the Apache Git Service. To

[jira] [Resolved] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout

2019-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11059. --- Resolution: Fixed Fixed via 1.9.0: a4865cd67239c938e0075bcc2b112b944cc3c249 1.8.1:

[GitHub] [flink] sunjincheng121 commented on issue #8623: [FLINK-12719][python] Add the Python catalog API

2019-06-14 Thread GitBox
sunjincheng121 commented on issue #8623: [FLINK-12719][python] Add the Python catalog API URL: https://github.com/apache/flink/pull/8623#issuecomment-502091680 +1 to merged  This is an automated message from the Apache Git

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293765451 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293751698 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293773998 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293752274 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293786650 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL

2019-06-14 Thread GitBox
wuchong commented on a change in pull request #8718: [FLINK-12824][table-planner-blink] Set parallelism for stream SQL URL: https://github.com/apache/flink/pull/8718#discussion_r293750904 ## File path:

[GitHub] [flink] HuangXingBo commented on issue #8732: [FLINK-12720][python] Add the Python Table API Sphinx docs

2019-06-14 Thread GitBox
HuangXingBo commented on issue #8732: [FLINK-12720][python] Add the Python Table API Sphinx docs URL: https://github.com/apache/flink/pull/8732#issuecomment-502090131 Thanks a lot for @dianfu @sunjincheng121. 1. I add logic about sphinx installed and check in lint-python.sh. 2. I add

[GitHub] [flink] sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput

2019-06-14 Thread GitBox
sunhaibotb commented on a change in pull request #8731: [FLINK-11878][runtime] Implement the runtime handling of BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8731#discussion_r293741881 ## File path:

[jira] [Commented] (FLINK-12776) Ambiguous content in flink-dist NOTICE file

2019-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863997#comment-16863997 ] sunjincheng commented on FLINK-12776: - Thanks for the reply [~Zentol]!  I want to share the good

[GitHub] [flink] aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

2019-06-14 Thread GitBox
aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream URL: https://github.com/apache/flink/pull/8642#discussion_r293771876 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

2019-06-14 Thread GitBox
aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream URL: https://github.com/apache/flink/pull/8642#discussion_r293781768 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

2019-06-14 Thread GitBox
aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream URL: https://github.com/apache/flink/pull/8642#discussion_r293781464 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream

2019-06-14 Thread GitBox
aljoscha commented on a change in pull request #8642: [FLINK-1722][datastream] Enable the InitializeOnMaster and FinalizeOnMaster interfaces on datastream URL: https://github.com/apache/flink/pull/8642#discussion_r293781871 ## File path:

[jira] [Commented] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis

2019-06-14 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863986#comment-16863986 ] leesf commented on FLINK-12071: --- It is difficult to reproduce errors in travis when running failed test

[GitHub] [flink] flinkbot commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

2019-06-14 Thread GitBox
flinkbot commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8742#issuecomment-502084160 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-11879) Add JobGraph validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

2019-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11879: --- Labels: pull-request-available (was: ) > Add JobGraph validators for the uses of

  1   2   3   >