[APEXCORE-510] Enforce DefaultOutputPort.emit() or Sink.put() thread affinity

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 3.5.0
• Assignee: Sanjay M Pujare
• Reporter: Vlad Rozov
• Created: 17/Aug/16 21:45
• Updated: 10/Dec/16 18:42
• Resolved: 21/Oct/16 22:17

Description

Apex platform assumes that an operator interacts with the platform using the dedicated operator thread. Currently, operators may create worker threads and emit tuples from a worker thread. This leads to undefined behavior and hard to find bugs, so it should be possible to enforce that DefaultOutputPort.emit() and/or Sink.put() are called on the operator thread.

Issue Links

• links to: GitHub Pull Request #411