GitHub user StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/40 Local Executor pick up the plans required degree parallelism. This is a crucial fix for the local mode in the slot based model. Please review soon. You can merge this pull request into a Git repository by running: $ git pull https://github.com/StephanEwen/incubator-flink master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-flink/pull/40.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #40 ---- commit a489762d46110d393adb30388f4665f2f7b3a566 Author: Stephan Ewen <[hidden email]> Date: 2014-06-24T14:06:35Z Changed default number of task slots per machine to one. Add logging for task slots. commit d85ccd3023d1e590d81f365fd0118b121943acc5 Author: Stephan Ewen <[hidden email]> Date: 2014-06-24T15:52:26Z LocalExecutor automatically picks up the maximum DOP for plans as its number of slots. ---- --- 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 enabled but not working, please contact infrastructure at [hidden email] or file a JIRA ticket with INFRA. --- |
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/40#issuecomment-47002309 Extended by adding environment logging (sorry, I oushed to the wrong branch, so it ended up here). JobManager and TaskManager log teh following upon startup: ``` ------------------------------------------------------- Starting TaskManager (Version: 0.6-SNAPSHOT, Rev:77cd963, Date:24.06.2014 @ 18:57:01 CEST) Current user: cicero JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.7/24.55-b03 Startup Options: -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m -XX:NewRatio=6 -Xms512m -Xmx512m Maximum heap size: 504 MiBytes JAVA_HOME: not set ------------------------------------------------------- ``` --- 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 enabled but not working, please contact infrastructure at [hidden email] or file a JIRA ticket with INFRA. --- |
In reply to this post by zentol
Github user rmetzger commented on the pull request:
https://github.com/apache/incubator-flink/pull/40#issuecomment-47068580 Great! I think its good to merge. --- 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 enabled but not working, please contact infrastructure at [hidden email] or file a JIRA ticket with INFRA. --- |
In reply to this post by zentol
Github user mariemayadi commented on the pull request:
https://github.com/apache/incubator-flink/pull/40#issuecomment-47068686 Great. On Wed, Jun 25, 2014 at 9:28 AM, Robert Metzger <[hidden email]> wrote: > Great! > I think its good to merge. > > â > Reply to this email directly or view it on GitHub > <https://github.com/apache/incubator-flink/pull/40#issuecomment-47068580>. > --- 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 enabled but not working, please contact infrastructure at [hidden email] or file a JIRA ticket with INFRA. --- |
In reply to this post by zentol
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/40 --- 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 enabled but not working, please contact infrastructure at [hidden email] or file a JIRA ticket with INFRA. --- |
Free forum by Nabble | Edit this page |