[
https://issues.apache.org/jira/browse/APEXCORE-445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259115#comment-15259115
]
ASF GitHub Bot commented on APEXCORE-445:
-----------------------------------------
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/319#discussion_r61177760
--- Diff:
common/src/main/java/com/datatorrent/common/util/AsyncFSStorageAgent.java ---
@@ -38,7 +40,7 @@
public class AsyncFSStorageAgent extends FSStorageAgent
{
private final transient Configuration conf;
- private transient volatile String localBasePath;
+ private final AtomicReference<String> localBasePath;
--- End diff --
Doesn't it have to be transient?
> Race condition in AsynFSStorageAgent.save()
> -------------------------------------------
>
> Key: APEXCORE-445
> URL: https://issues.apache.org/jira/browse/APEXCORE-445
> Project: Apache Apex Core
> Issue Type: Bug
> Affects Versions: 3.2.1, 3.4.0, 3.3.1
> Reporter: Vlad Rozov
> Assignee: Vlad Rozov
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)