[jira] [Updated] (FLINK-5358) Support Row in TypeExtractor

2016-12-18 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5358: - Description: {code} Row[] data = new Row[]{}; TypeInformation typeInfo = TypeExtractor.getForObjec

[jira] [Updated] (FLINK-5358) Support Row in TypeExtractor

2016-12-18 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5358: - Description: {code} TypeInformation typeInfo = TypeExtractor.getForObject(data[0]); {code} method

[jira] [Updated] (FLINK-5358) Support Row in TypeExtractor

2016-12-18 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5358: - Description: {code} TypeInformation typeInfo = TypeExtractor.getForObject(data[0]); {code} method

[jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he edited comment on FLINK-5342 at 12/19/16 3:35 AM: -

[jira] [Comment Edited] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he edited comment on FLINK-5342 at 12/19/16 3:32 AM: -

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-18 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759971#comment-15759971 ] godfrey he commented on FLINK-5342: --- at present, we can use TableConfig to tune the para

[jira] [Updated] (FLINK-5313) Supporting all tpch queries

2016-12-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5313: -- External issue ID: 5144 > Supporting all tpch queries > --- > >

[jira] [Updated] (FLINK-5313) Supporting all tpch queries

2016-12-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5313: -- External issue ID: (was: 5144) > Supporting all tpch queries > --- > >

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

2016-12-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759957#comment-15759957 ] Kurt Young commented on FLINK-5144: --- Seems there are two issues reflected by this query.

[jira] [Commented] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm

2016-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759822#comment-15759822 ] ASF GitHub Bot commented on FLINK-5365: --- GitHub user EronWright opened a pull reques

[GitHub] flink pull request #3025: [FLINK-5365] Mesos AppMaster/TaskManager should ob...

2016-12-18 Thread EronWright
GitHub user EronWright opened a pull request: https://github.com/apache/flink/pull/3025 [FLINK-5365] Mesos AppMaster/TaskManager should obey sigterm Adjust bash script to propagate signals to the java process. This will allow Marathon to properly stop the JobManager. You can merg

[jira] [Created] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm

2016-12-18 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5365: --- Summary: Mesos AppMaster/TaskManager should obey sigterm Key: FLINK-5365 URL: https://issues.apache.org/jira/browse/FLINK-5365 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2016-12-18 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5364: --- Summary: Rework JAAS configuration to support user-supplied entries Key: FLINK-5364 URL: https://issues.apache.org/jira/browse/FLINK-5364 Project: Flink Issue

[jira] [Created] (FLINK-5363) Fire timers when window state is currently empty

2016-12-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5363: --- Summary: Fire timers when window state is currently empty Key: FLINK-5363 URL: https://issues.apache.org/jira/browse/FLINK-5363 Project: Flink Issue Ty

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758589#comment-15758589 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk closed the pull reque

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-12-18 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2314 The Bahir PR was merged in closed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758588#comment-15758588 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk commented on the issu

[GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto...

2016-12-18 Thread mushketyk
Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/2314 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is e

[jira] [Commented] (FLINK-5362) Implement methods to access BipartiteGraph properties

2016-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758511#comment-15758511 ] ASF GitHub Bot commented on FLINK-5362: --- GitHub user mushketyk opened a pull request

[GitHub] flink pull request #3024: [FLINK-5362] Implement methods to access Bipartite...

2016-12-18 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/3024 [FLINK-5362] Implement methods to access BipartiteGraph properties Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerati

[jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties

2016-12-18 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-5362: - Summary: Implement methods to access BipartiteGraph properties Key: FLINK-5362 URL: https://issues.apache.org/jira/browse/FLINK-5362 Project: Flink Issue T

[jira] [Closed] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-3298. - Resolution: Fixed > Streaming connector for ActiveMQ > > >

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758501#comment-15758501 ] Ivan Mushketyk commented on FLINK-3298: --- Bahir PR was accepted. Closing the issue.

[jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3427: - Assignee: (was: Ivan Mushketyk) > Add watermark monitoring to JobManager web frontend

[jira] [Assigned] (FLINK-4029) Multi-field "sum" function just like "keyBy"

2016-12-18 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4029: - Assignee: (was: Ivan Mushketyk) > Multi-field "sum" function just like "keyBy" >