Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r49655894
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -420,15 +440,23 @@ public MutableHashTable(TypeSerializer<BT>
buildSideSerializer, TypeSerializer<P
// Life-Cycle
//
------------------------------------------------------------------------
+ public void open(final MutableObjectIterator<BT> buildSide, final
MutableObjectIterator<PT> probeSide)
+ throws IOException {
+
+ open(buildSide, probeSide, false);
+ }
+
/**
* Opens the hash join. This method reads the build-side input and
constructs the initial
* hash table, gradually spilling partitions that do not fit into
memory.
*
* @throws IOException Thrown, if an I/O problem occurs while spilling
a partition.
--- End diff --
Can you add the parameters of the `open` method?
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
