[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8415:
--
Description:
{code}
public void shutdown() {
running = false;
recordsToSend.complete(0L);
{code}
In
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8415:
--
Description:
{code}
public void shutdown() {
running = false;
recordsToSend.complete(0L);
{code}
In
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8415:
--
Description:
{code}
public void shutdown() {
running = false;
recordsToSend.complete(0L);
{code}
In
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8415:
--
Component/s: Streaming
> Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()
>
