- 06 11月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
-
由 Sachin Goel 提交于
This closes #1319.
-
- 05 11月, 2015 2 次提交
-
-
由 Maximilian Michels 提交于
-
由 Till Rohrmann 提交于
[FLINK-2968] [streaming] Let AbstractUdfStreamOperator forward output type information to WindowFunction The fold operation needs the output type information to serialize the initial value of it. Therefore, the OutputTypeConfigurable interface was defined. It is called by the StreamGraph upon adding a StreamOperator to the StreamGraph. Since some stream operators, such as the window stream operator, don't work directly on the data, but instead call a WindowFunction for the actual logic, the output type information has to be forwarded to this function to set output type information at the right place. Thus, the AbstractUdfStreamOperator checks whether its udf function supports the OutputTypeConfigurable interface. If this is the case, then it forwards the output type information to the udf. This closes #1328.
-
- 04 11月, 2015 5 次提交
-
-
由 Robert Metzger 提交于
-
由 Sachin Goel 提交于
This closes #1326
-
由 Sachin Goel 提交于
[hotfix][web-dashboard] Fix taskmanager charts legend. This closes #1323
-
由 Till Rohrmann 提交于
The HashPartition did not count properly the number of occupied memory segments, because it excluded the memory segments of the BuildSideBuffer. That caused the MutableHashTable to fail when trying to spill a partition which did not have any overflow segments. This PR fixes the problem by also counting the memory segments of the BuildSideBuffer. This closes #1324.
-
由 smarthi 提交于
This closes #1299
-
- 03 11月, 2015 11 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
- fix hard-coded defaults This closes #1304.
-
由 Patrice Freydiere 提交于
This closes #1314.
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
The tool can be used to list the set of dependencies to make a diff of dependencies between releases.
-
由 Sachin Goel 提交于
-
由 Sachin Goel 提交于
This closes #1313.
-
由 Fabian Hueske 提交于
- Added tests for Scala DataSet sortPartition This closes #1317.
-
由 Aljoscha Krettek 提交于
This closes #1316.
-
由 Maximilian Michels 提交于
-
- 02 11月, 2015 5 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
- skip was only necessary because Java 8 couldn't build the java docs
-
由 Maximilian Michels 提交于
- Prevents crashing of IntelliJ Checkstyle plugin
-
由 Maximilian Michels 提交于
- This ensures Checkstyle works properly, e.g. in IDEs
-
由 Maximilian Michels 提交于
-
- 30 10月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
-
- 29 10月, 2015 10 次提交
-
-
由 Sachin Goel 提交于
This closes #1296
-
由 Sachin Goel 提交于
This closes #1307
-
由 Hubert Czerpak 提交于
- Remove broken HTML tags like <br/>, <p/>, ... - close unclosed HTML tags - replaces special chars by HTML escaping, e.g., '<' by < - wrap code examples by {@code} - fix incorrect @see and @link references - fix incorrect @throws - fix typos This closes #1298
-
由 Frederick F. Kautz IV 提交于
This closes #1309
-
由 Fabian Hueske 提交于
This closes #1293
-
由 gallenvara 提交于
This closes #1302
-
由 gallenvara 提交于
This closes #1270.
-
由 Till Rohrmann 提交于
The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This Output class is flushed by Flink's KryoSerializer upon finishing its serialize call. However, in case of an exception when flushing the Output, the buffered data is kept in the buffer. Since Flink uses EOFExceptions to mark that an underlying buffer is full and has to be spilled, for example, it can happen that the record triggering the spilling is written twice after it is rewritten. The reason is that Kryo's Output buffer still contains the serialization data of the failed attempt which is also flushed to the emptied output stream. This duplication of records can lead to corrupted data which eventually let's the Flink program crash. The problem is solved by clearing Kryo's Output when the flush operation was not successful. This closes #1308
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
Otherwise the javadoc fails to generate..
-
- 28 10月, 2015 4 次提交
-
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
[FLINK-2927] [runtime] Provide default required configuration keys in flink-conf of binary distribution This closes #1303.
-
由 Ufuk Celebi 提交于
This closes #1301.
-