- 13 11月, 2015 3 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Jun Aoki 提交于
This closes #1325
-
由 zentol 提交于
This closes #1257
-
- 12 11月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
In addition to dd66e61e, removes the left-over source files.
-
- 11 11月, 2015 7 次提交
-
-
由 tedyu 提交于
[FLINK-2826] [runtime] Fix race condition and locking in BroadcastVariableMaterialization#decrementReferenceInternal This closes #1339
-
由 Stephan Ewen 提交于
For jobs that do not switch to FAILED, but rather RESTARTING, this now prints the error cause as well. Also minor improvement to exception printing in CliFrontend.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Previously, this fiel pointed to the different versions of the LICENSE and NOTICE files (source version, bin version). Since we dropped the convenience binary distribution LICENSE and NOTICE files and only ship the source release related ones, this is no longer necessary.
-
由 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 5 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
- fix hard-coded defaults This closes #1304.
-
由 Patrice Freydiere 提交于
This closes #1314.
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
-