- 11 11月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 10 11月, 2015 6 次提交
-
-
由 Sachin Goel 提交于
This closes #1327.
-
由 Robert Metzger 提交于
This closes #1343
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
[FLINK-2987] Remove jersey-core and jersey-client dependency exclusion to make Flink on Hadoop 2.6.0+ work This closes #1340
-
由 Robert Metzger 提交于
-
由 Sachin Goel 提交于
This closes #1334.
-
- 09 11月, 2015 4 次提交
-
-
由 Maximilian Michels 提交于
-
由 Martin Junghanns 提交于
This closes #1329
-
由 mjsax 提交于
- added auto-redirect for coding_guidelines and how_to_contribute pages (to keep external links working) - updated menu links to point directly to coding_guidelines and how_to_contribute on Flink project page (only improvement on FLINK-2752; does not resolve it) This closes #1320
-
由 Ufuk Celebi 提交于
-
- 07 11月, 2015 2 次提交
-
-
由 Aljoscha Krettek 提交于
The problem was, that truncate is asynchronous and the RollingSink was not taking this into account. Now it has a loop after the truncate call that waits until the file is actually truncated. This also changes the Hadoop 2.6 travis build to 2.7, instead.
-
由 Till Rohrmann 提交于
-
- 06 11月, 2015 5 次提交
-
-
由 Martin Junghanns 提交于
* added libraries and versions This closes #1335.
-
由 chengxiang li 提交于
This closes #1315.
-
由 vasia 提交于
This closes #1333
-
由 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 3 次提交
-
-
由 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
-