Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88016998
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -264,27 +282,23 @@
//
-------------------------------------------§-------------------------------------------------
/**
- * Our subtask index, retrieved from the {@code RuntimeContext} in
{@link #open}.
- */
- private transient int subtaskIndex;
-
- /**
- * We use reflection to get the .truncate() method, this is only
available starting with
- * Hadoop 2.7
+ * We use reflection to get the .truncate() method, this is only
available starting with Hadoop 2.7
*/
private transient Method refTruncate;
/**
- * The state object that is handled by flink from snapshot/restore. In
there we store state for
- * every open bucket: the current part file path, the valid length of
the in-progress files and
- * pending part files.
+ * The state object that is handled by Flink from snapshot/restore.
This contains state for
+ * every open bucket: the current {@code in-progress} part file path,
its valid length and
+ * the {@code pending} part files.
--- End diff --
why the annotation around pending?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
