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)