[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Attachment: flink-1.6.png flink-1.4.png > Yarn Resource Manager Acquires Too

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Attachment: Screen Shot 2019-04-29 at 12.06.23 AM.png > Yarn Resource Manager Acquires Too

[jira] [Commented] (FLINK-12279) Create source to allow streaming data from websocket.

2019-04-29 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829603#comment-16829603 ] Dominik Wosiński commented on FLINK-12279: -- AFAIK, it will provide same delivery guarantees as

[jira] [Closed] (FLINK-12367) Create rich versions of functions for Scala

2019-04-29 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński closed FLINK-12367. Resolution: Invalid > Create rich versions of functions for Scala >

[GitHub] [flink] flinkbot commented on issue #8314: [FLINK-12365][table] Add stats related catalog APIs

2019-04-29 Thread GitBox
flinkbot commented on issue #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#issuecomment-487671263 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Closed] (FLINK-12312) Remove CLI command for rescaling

2019-04-29 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-12312. Resolution: Fixed 1.9: 566d10d958d71fd113f8f7ecc08fa9b63a072919 > Remove CLI command for rescaling >

[GitHub] [flink] xuefuz opened a new pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

2019-04-29 Thread GitBox
xuefuz opened a new pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314 ## What is the purpose of the change Added stats related catalog APIs. Made table/column stats first-level meta object in catalog.

[GitHub] [flink] asfgit closed pull request #8260: [FLINK-12312][runtime] Remove CLI command for rescaling

2019-04-29 Thread GitBox
asfgit closed pull request #8260: [FLINK-12312][runtime] Remove CLI command for rescaling URL: https://github.com/apache/flink/pull/8260 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-12312) Remove CLI command for rescaling

2019-04-29 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-12312: - Fix Version/s: 1.9.0 > Remove CLI command for rescaling > > >

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-487665834 @flinkbot attention @zentol

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-487665669 > Stephan pointed you in a good direction, we will have

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r279454577 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r279454577 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r279450999 ## File path:

[GitHub] [flink] zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#issuecomment-487657881 Thanks for reviews @azagrebin ! I think your suggestion of migrating the

[GitHub] [flink] zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279447428 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279447428 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279446413 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r279444906 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-29 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r279444868 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279442622 ## File path:

[jira] [Commented] (FLINK-11921) Upgrade Calcite dependency to 1.19

2019-04-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829427#comment-16829427 ] Rong Rong commented on FLINK-11921: --- Closing to the end of this issue. Found out that one of the

[GitHub] [flink] hequn8128 edited a comment on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

2019-04-29 Thread GitBox
hequn8128 edited a comment on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#issuecomment-487645008 @sunjincheng121 Hi, Thank you very much for your review and great suggestions. I think the pr has been

[GitHub] [flink] hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

2019-04-29 Thread GitBox
hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#issuecomment-487645008 @sunjincheng121 Hi, Thank you very much for your review and great suggestions. I think the pr improved a lot

[GitHub] [flink] hequn8128 commented on a change in pull request #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

2019-04-29 Thread GitBox
hequn8128 commented on a change in pull request #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#discussion_r279434307 ## File path:

[jira] [Commented] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829396#comment-16829396 ] Robert Metzger commented on FLINK-9787: --- +1 to address this. > Change

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2019-04-29 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829395#comment-16829395 ] Yun Tang commented on FLINK-12358: -- [~Zentol] Thanks for your suggestion, I would try to fix this

[jira] [Resolved] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-10446. Resolution: Won't Fix > Use the "guava beta checker" plugin to keep off of @Beta API >

[jira] [Commented] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829390#comment-16829390 ] Robert Metzger commented on FLINK-10446: I'm proposing to close this Jira ticket, as it makes

[jira] [Commented] (FLINK-12353) Add missing module to collect_japicmp_reports.sh

2019-04-29 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829387#comment-16829387 ] Yun Tang commented on FLINK-12353: -- [~Zentol] This sounds more reasonable, I would like to try to

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

2019-04-29 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829386#comment-16829386 ] Rong Rong commented on FLINK-11935: --- I think this issue should not block calcite upgrade, we can still

[jira] [Closed] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12293. -- Resolution: Cannot Reproduce I'm closing this Jira ticket. It doesn't explain the problem

[GitHub] [flink] flinkbot commented on issue #8313: [FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old version

2019-04-29 Thread GitBox
flinkbot commented on issue #8313: [FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old version URL: https://github.com/apache/flink/pull/8313#issuecomment-487639936 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] klion26 opened a new pull request #8313: [FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old version

2019-04-29 Thread GitBox
klion26 opened a new pull request #8313: [FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old version URL: https://github.com/apache/flink/pull/8313 ## What is the purpose of the change If we have old verison json files in history server, the

[GitHub] [flink] rmetzger commented on issue #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java.

2019-04-29 Thread GitBox
rmetzger commented on issue #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#issuecomment-487639163 Thank you for opening this PR to Flink. I would like to close this pull request, without merging it, as

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

2019-04-29 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829381#comment-16829381 ] Seth Wiesman commented on FLINK-10900: -- [~till.rohrmann] Is the universal Kafka connector still

[GitHub] [flink] azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279417805 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279426797 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279410838 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279410097 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#discussion_r279398673 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343]add file replication config for yarn configuration

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487385120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] rmetzger commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration

2019-04-29 Thread GitBox
rmetzger commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487632182 I tend to disagree. I think the problem is well defined, the configuration parameter name is okay (not great) and the

[jira] [Closed] (FLINK-8640) Japicmp fails on java 9

2019-04-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8640. --- Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] zentol merged pull request #8271: [FLINK-8640][build][travis] Enable japicmp on Java 9

2019-04-29 Thread GitBox
zentol merged pull request #8271: [FLINK-8640][build][travis] Enable japicmp on Java 9 URL: https://github.com/apache/flink/pull/8271 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-12353) Add missing module to collect_japicmp_reports.sh

2019-04-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829352#comment-16829352 ] Chesnay Schepler commented on FLINK-12353: -- This is one of those scripts that maybe shouldn't

[GitHub] [flink] walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align

2019-04-29 Thread GitBox
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align URL: https://github.com/apache/flink/pull/8248#discussion_r279415433 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align

2019-04-29 Thread GitBox
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align URL: https://github.com/apache/flink/pull/8248#discussion_r279414601 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align

2019-04-29 Thread GitBox
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC] JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align URL: https://github.com/apache/flink/pull/8248#discussion_r279414202 ## File path:

[jira] [Updated] (FLINK-12202) Consider introducing batch metric register in NetworkEnviroment

2019-04-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12202: - Component/s: Runtime / Metrics > Consider introducing batch metric register in

[GitHub] [flink] tillrohrmann closed pull request #8227: [FLINK-12180][Tests] Port ExecutionVertexCancelTest to new codebase

2019-04-29 Thread GitBox
tillrohrmann closed pull request #8227: [FLINK-12180][Tests] Port ExecutionVertexCancelTest to new codebase URL: https://github.com/apache/flink/pull/8227 This is an automated message from the Apache Git Service. To respond

[jira] [Resolved] (FLINK-12180) Port ExecutionVertexCancelTest to new codebase

2019-04-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12180. --- Resolution: Fixed Fixed via 7054a8b05738fb43ca856849299263bf4f584067 > Port

[jira] [Commented] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829324#comment-16829324 ] Robert Metzger commented on FLINK-12343: The PR proposes to set {{yarn.file-replication}}, which

[GitHub] [flink] wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-29 Thread GitBox
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r279395163 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-29 Thread GitBox
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r279395068 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-487296924 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 #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#issuecomment-487363436 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] rmetzger commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-04-29 Thread GitBox
rmetzger commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-487606252 @flinkbot approve description This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #8305: [hotfix] regenerate rest-docs to latest code

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8305: [hotfix] regenerate rest-docs to latest code URL: https://github.com/apache/flink/pull/8305#issuecomment-487389173 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] rmetzger commented on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

2019-04-29 Thread GitBox
rmetzger commented on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#issuecomment-487605966 @flinkbot approve description This is an automated

[GitHub] [flink] rmetzger commented on issue #8305: [hotfix] regenerate rest-docs to latest code

2019-04-29 Thread GitBox
rmetzger commented on issue #8305: [hotfix] regenerate rest-docs to latest code URL: https://github.com/apache/flink/pull/8305#issuecomment-487605589 @flinkbot attention @zentol @flinkbot approve description This is an

[GitHub] [flink] flinkbot edited a comment on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase URL: https://github.com/apache/flink/pull/8307#issuecomment-487392775 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] rmetzger commented on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase

2019-04-29 Thread GitBox
rmetzger commented on issue #8307: [FLINK-12359][metrics][tests] Harden SystemResourcesMetricsITCase URL: https://github.com/apache/flink/pull/8307#issuecomment-487604812 @flinkbot approve description consensus This is an

[GitHub] [flink] flinkbot edited a comment on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#issuecomment-487553255 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS

2019-04-29 Thread GitBox
flinkbot edited a comment on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS URL: https://github.com/apache/flink/pull/8117#issuecomment-480408700 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] rmetzger commented on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API

2019-04-29 Thread GitBox
rmetzger commented on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#issuecomment-487604013 @flinkbot approve description This is an automated message

[GitHub] [flink] rmetzger commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS

2019-04-29 Thread GitBox
rmetzger commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS URL: https://github.com/apache/flink/pull/8117#issuecomment-487603641 @flinkbot approve description This is an automated message from

[GitHub] [flink] wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-04-29 Thread GitBox
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r279386668 ## File path:

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829298#comment-16829298 ] Jark Wu commented on FLINK-12351: - [~rmetzger] Thanks for the reminder. > AsyncWaitOperator should

[jira] [Updated] (FLINK-12367) Create rich versions of functions for Scala

2019-04-29 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński updated FLINK-12367: - Description: Currently for some of the functions like for example _AsyncFunctions_ have

[GitHub] [flink] XuQianJin-Stars commented on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

2019-04-29 Thread GitBox
XuQianJin-Stars commented on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#issuecomment-487597420 hi @Leev Thank you for review this PR. I have modified it.

[jira] [Created] (FLINK-12367) Create rich versions of functions for Scala

2019-04-29 Thread JIRA
Dominik Wosiński created FLINK-12367: Summary: Create rich versions of functions for Scala Key: FLINK-12367 URL: https://issues.apache.org/jira/browse/FLINK-12367 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #8312: [FLINK-12366][table] Clean up Catalog APIs to make them more consiste…

2019-04-29 Thread GitBox
flinkbot commented on issue #8312: [FLINK-12366][table] Clean up Catalog APIs to make them more consiste… URL: https://github.com/apache/flink/pull/8312#issuecomment-487587486 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase URL: https://github.com/apache/flink/pull/8226#discussion_r279341488 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase URL: https://github.com/apache/flink/pull/8226#discussion_r279342636 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase

2019-04-29 Thread GitBox
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests] Port ExecutionGraphRestartTest to new codebase URL: https://github.com/apache/flink/pull/8226#discussion_r279345597 ## File path:

[jira] [Updated] (FLINK-12366) Clean up Catalog APIs to make them more consistent and coherent

2019-04-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12366: --- Labels: pull-request-available (was: ) > Clean up Catalog APIs to make them more

[GitHub] [flink] xuefuz opened a new pull request #8312: [FLINK-12366][table] Clean up Catalog APIs to make them more consiste…

2019-04-29 Thread GitBox
xuefuz opened a new pull request #8312: [FLINK-12366][table] Clean up Catalog APIs to make them more consiste… URL: https://github.com/apache/flink/pull/8312 …nt and coherent ## What is the purpose of the change Clean up existing catalog APIs to make them more

[jira] [Commented] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task

2019-04-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829273#comment-16829273 ] Andrey Zagrebin commented on FLINK-12203: - Hey [~rmetzger], thanks for correction. I will try to

[GitHub] [flink] becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

2019-04-29 Thread GitBox
becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677#discussion_r279369052 ## File path:

[jira] [Created] (FLINK-12366) Clean up Catalog APIs to make them more consistent and coherent

2019-04-29 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-12366: --- Summary: Clean up Catalog APIs to make them more consistent and coherent Key: FLINK-12366 URL: https://issues.apache.org/jira/browse/FLINK-12366 Project: Flink

[jira] [Updated] (FLINK-12365) Add stats related catalog APIs

2019-04-29 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-12365: Description: This is to support (table and column) stats for table/partition with related to

[jira] [Created] (FLINK-12365) Add stats related catalog APIs

2019-04-29 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-12365: --- Summary: Add stats related catalog APIs Key: FLINK-12365 URL: https://issues.apache.org/jira/browse/FLINK-12365 Project: Flink Issue Type: Sub-task

[GitHub] [flink] fhueske commented on issue #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

2019-04-29 Thread GitBox
fhueske commented on issue #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#issuecomment-487579573 Sorry, I was out for a few days vacation. Will continue with my review soon. Thanks, Fabian

[GitHub] [flink] fhueske commented on issue #8064: [FLINK-7244] Add parquet table source

2019-04-29 Thread GitBox
fhueske commented on issue #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#issuecomment-487579379 Sorry, I was out for a few days vacation. Will continue with my review soon. Thanks, Fabian

[jira] [Updated] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12293: --- Component/s: API / DataStream > Fix some comment typos in flink-streaming-java. >

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12352: --- Component/s: Table SQL / API > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829245#comment-16829245 ] Robert Metzger commented on FLINK-12351: Hey [~jark], thanks a lot for opening a ticket in the

[jira] [Updated] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12351: --- Component/s: API / DataStream > AsyncWaitOperator should deep copy StreamElement when

[jira] [Updated] (FLINK-12338) Update Apache Avro test to use try-with-resources

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12338: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Update Apache Avro test to

[jira] [Updated] (FLINK-12364) Introduce a CheckpointFailureManager to centralized manage checkpoint failure

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12364: --- Component/s: Runtime / Checkpointing > Introduce a CheckpointFailureManager to centralized

[jira] [Commented] (FLINK-12279) Create source to allow streaming data from websocket.

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829244#comment-16829244 ] Robert Metzger commented on FLINK-12279: I'm not sure if we want to have such a connector in

[jira] [Updated] (FLINK-12299) ExecutionConfig#setAutoWatermarkInterval should check param(interval should not less than zero)

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12299: --- Component/s: Runtime / Coordination > ExecutionConfig#setAutoWatermarkInterval should check

[jira] [Updated] (FLINK-12279) Create source to allow streaming data from websocket.

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12279: --- Component/s: Connectors / Common > Create source to allow streaming data from websocket. >

[jira] [Commented] (FLINK-12225) Simplify the interface of the PartFileWriter

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829240#comment-16829240 ] Robert Metzger commented on FLINK-12225: Hey [~Fokko], thanks a lot for opening a ticket in the

[jira] [Updated] (FLINK-12250) Rewrite assembleNewPartPath to let it return a new PartPath

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12250: --- Component/s: Connectors / FileSystem > Rewrite assembleNewPartPath to let it return a new

[jira] [Updated] (FLINK-12225) Simplify the interface of the PartFileWriter

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12225: --- Component/s: Connectors / FileSystem > Simplify the interface of the PartFileWriter >

[jira] [Commented] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829239#comment-16829239 ] Robert Metzger commented on FLINK-12203: Hey [~azagrebin], thanks a lot for opening a ticket in

[jira] [Updated] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task

2019-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12203: --- Component/s: Runtime / Network > Refactor ResultPartitionManager to break tie with Task >

[jira] [Commented] (FLINK-12333) Add documentation for all async operations through REST

2019-04-29 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829232#comment-16829232 ] Yun Tang commented on FLINK-12333: -- [~till.rohrmann] I have already refactored

<    1   2   3   4   >