[jira] [Closed] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client

2015-12-11 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2629. - Resolution: Duplicate > Refactor YARN ApplicationMasterActor to use the async AM<-->RM

[GitHub] flink pull request: [FLINK-2936] Fix ClassCastException for Event-...

2015-12-11 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1448#issuecomment-163918357 @StephanEwen do we want to fix it like this now, or do we want to integrate it into the StreamRecordSerializer? --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052655#comment-15052655 ] ASF GitHub Bot commented on FLINK-2936: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052551#comment-15052551 ] ASF GitHub Bot commented on FLINK-2769: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-2769] [runtime-web] Add configurable jo...

2015-12-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1449#issuecomment-163893598 Thanks for the reviews Robert and Sachin! I've addressed Robert's comment. If there are no objections, I would like to merge this. --- If your project is set up

[GitHub] flink pull request: [FLINK-2769] [runtime-web] Add configurable jo...

2015-12-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1449#issuecomment-163953942 I think its good to merge, +1 --- 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

[jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052853#comment-15052853 ] ASF GitHub Bot commented on FLINK-2769: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052782#comment-15052782 ] ASF GitHub Bot commented on FLINK-2936: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-2936] Fix ClassCastException for Event-...

2015-12-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1448#issuecomment-163940693 Probably okay to do it like this. How hard is it to pass the "timestamps" flag into the constructor of the SourceOperator, rather than through the runtime

[GitHub] flink pull request: [FLINK-2936] Fix ClassCastException for Event-...

2015-12-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1448 --- 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

[GitHub] flink pull request: [FLINK-3121] Emit Final Watermark in Kafka Sou...

2015-12-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1447 --- 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

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052874#comment-15052874 ] ASF GitHub Bot commented on FLINK-3134: --- GitHub user mxm opened a pull request:

[jira] [Commented] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052989#comment-15052989 ] ASF GitHub Bot commented on FLINK-3121: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052990#comment-15052990 ] ASF GitHub Bot commented on FLINK-2936: --- Github user asfgit closed the pull request at:

[jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3160: - Summary: Aggregate operator statistics by TaskManager Key: FLINK-3160 URL: https://issues.apache.org/jira/browse/FLINK-3160 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3121. - Resolution: Fixed Fix Version/s: 1.0.0 Fixed in

[jira] [Resolved] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-2936. - Resolution: Fixed Fixed in

[jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3161: - Summary: Externalize cluster start-up and tear-down when available Key: FLINK-3161 URL: https://issues.apache.org/jira/browse/FLINK-3161 Project: Flink Issue

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-11 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1450 [FLINK-3134][yarn] asynchronous YarnJobManager heartbeats - use AMRMClientAsync instead of AMRMClient - handle allocation and startup of containers in callbacks - remove YarnHeartbeat message

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-12-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15052409#comment-15052409 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-12-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1255#issuecomment-163873769 Thanks for the update. Looks good. Will try it once more on a cluster. @uce, @StephanEwen , we inject a `DataExchangeMode.BATCH` for range partitioning

[jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3162: - Summary: Configure number of TaskManager slots as ratio of available processors Key: FLINK-3162 URL: https://issues.apache.org/jira/browse/FLINK-3162 Project: Flink

[jira] [Created] (FLINK-3164) Spread out scheduling strategy

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3164: - Summary: Spread out scheduling strategy Key: FLINK-3164 URL: https://issues.apache.org/jira/browse/FLINK-3164 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3163) Configure Flink for NUMA systems

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3163: - Summary: Configure Flink for NUMA systems Key: FLINK-3163 URL: https://issues.apache.org/jira/browse/FLINK-3163 Project: Flink Issue Type: Improvement