[FLINK-3666] Remove Nephele references

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Documentation
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 24/Mar/16 14:07
• Updated: 13/Apr/21 20:40
• Resolved: 15/Jul/16 09:53

Description

There still exist a few references to nephele which should be removed:

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  ~~~

flink\flink-runtime\src\main\java\org\apache\flink\runtime\operators\TaskContext.java:
   70: 	AbstractInvokable getOwningNepheleTask();

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,

Issue Links

• links to: GitHub Pull Request #2241