[FLINK-23764] add RuntimeContext to SourceReaderContext - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Resolved
Priority: Major
Resolution: Won't Fix
Affects Version/s: None
Fix Version/s: None
Component/s: Connectors / Common
Labels:
- connector

Language:
- java

Description

RuntimeContext is the important information for sourceReader. Not only the subtask index, we sometimes need to get other information in RuntimeContext like the operator id.

Attachments

Issue Links

relates to

FLINK-24051 Make consumer.group-id optional for KafkaSource

Resolved

Activity

People

Assignee:: Unassigned

Reporter:: Hang Ruan

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 13/Aug/21 08:53

Updated:: 17/Nov/21 15:21

Resolved:: 31/Aug/21 17:48