You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/07/13 14:16:20 UTC

[jira] [Assigned] (FLINK-3666) Remove Nephele references

     [ https://issues.apache.org/jira/browse/FLINK-3666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler reassigned FLINK-3666:
---------------------------------------

    Assignee: Chesnay Schepler

> Remove Nephele references
> -------------------------
>
>                 Key: FLINK-3666
>                 URL: https://issues.apache.org/jira/browse/FLINK-3666
>             Project: Flink
>          Issue Type: Improvement
>          Components: Documentation
>            Reporter: Chesnay Schepler
>            Assignee: Chesnay Schepler
>            Priority: Trivial
>
> There still exist a few references to nephele which should be removed:
> {code}
> flink\docs\setup\local_setup.md:
>    79  $ tail log/flink-*-jobmanager-*.log
>    80  INFO ... - Initializing memory manager with 409 megabytes of memory
>    81: INFO ... - Trying to load org.apache.flinknephele.jobmanager.scheduler.local.LocalScheduler as scheduler
>    82  INFO ... - Setting up web info server, using web-root directory ...
>    83: INFO ... - Web info server will display information about nephele job-manager on localhost, port 8081.
>    84  INFO ... - Starting web info server for JobManager on port 8081
>    85  ~~~
>    ..
>   118  $ cd flink
>   119  $ bin/start-local.sh
>   120: Starting Nephele job manager
>   121  ~~~
> {code}
> {code}
> flink\flink-runtime\src\main\java\org\apache\flink\runtime\operators\TaskContext.java:
>    70: 	AbstractInvokable getOwningNepheleTask();
> {code}
> {code}
> flink\flink-runtime\src\main\java\org\apache\flink\runtime\operators\BatchTask.java:
>  1149  	 * @param message The main message for the log.
>  1150  	 * @param taskName The name of the task.
>  1151: 	 * @param parent The nephele task that contains the code producing the message.
>  1152  	 *
>  1153  	 * @return The string for logging.
>  ....
>  1254  	 */
>  1255  	@SuppressWarnings("unchecked")
>  1256: 	public static <T> Collector<T> initOutputs(AbstractInvokable nepheleTask, ClassLoader cl, TaskConfig config,
>  1257  										List<ChainedDriver<?, ?>> chainedTasksTarget,
>  1258  										List<RecordWriter<?>> eventualOutputs,
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)