- 11 3月, 2016 3 次提交
-
-
由 Márton Balassi 提交于
Consolidation is done via plugin management. Closes #1753
-
由 Maximilian Michels 提交于
-
由 Jark Wu 提交于
This closes #1762
-
- 10 3月, 2016 3 次提交
-
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
Superseded by new 'Event Time' section.
-
由 Stephan Ewen 提交于
-
- 09 3月, 2016 8 次提交
-
-
由 Ufuk Celebi 提交于
A failure to add the job graph to the submitted job graphs in ZooKeeper could lead to a job restart w/o the job graph ever being added to the submitted graphs store. Although the job submission was not ACK'd in this case before, it received job status messages. Now the job will not be ACK'd as before, but the job will be failed. This closes #1657.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
Saw this one failing, but it's impossible to get any insight from the logs, because you can't tell what is what.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Aljoscha Krettek 提交于
-
由 Maximilian Michels 提交于
-
- 08 3月, 2016 6 次提交
-
-
由 zentol 提交于
This closes #1658
-
由 zentol 提交于
This closes #1667.
-
由 zentol 提交于
This closes #1654.
-
由 zentol 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
Deployment will be handled by ASF's Jenkins instances which trigger the deployment of snapshot versions every night. This way, we have not only separated deployment from CI testing, but also improved the reliability of the test and deployment infrastructure. - remove Travis dependency from Maven deploy script - set force-dependency version to Flink version This assures deployment works when only credentials for the snapshot deployment are available. Previously, we deployed snapshots with release credentials. These credentials would be over-privileged. - remove old credentials from Travis config file This closes #1619.
-
- 07 3月, 2016 2 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
-
- 06 3月, 2016 1 次提交
-
-
由 vasia 提交于
-
- 05 3月, 2016 11 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-3550] [examples] Rework WindowJoin to properly demonstrate continuous window joins (Java + Scala)
-
由 twalthr 提交于
This closes #1759
-
由 zentol 提交于
This closes #1711
-
由 zentol 提交于
[FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows This closes #1703
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
This closes #1760
-
由 Jark Wu 提交于
This closes #1756
-
由 Jark Wu 提交于
This closes #1763
-
由 Stephan Ewen 提交于
This also consolidates the various wrapper classes for fold() and reduce() functions. This closes #1765
-
由 Maximilian Michels 提交于
-
- 04 3月, 2016 3 次提交
-
-
由 Robert Metzger 提交于
-
由 Till Rohrmann 提交于
The ConnectionUtils.findAddressUsingStrategy method tries to find out the local address which is accessible by other machines of the cluster. It tries to connect to a specified address to do so. In case that the no connection could be established, it uses an heuristic. Before it randomly picked a NetworkInterface which is bound to an Inet4Address, not a loop back address and not a link local address. In most cases it makes more sense to default to the InetAddress.getLocalHost() address instead. This PR replaces the old heuristic with simply returning the InetAddress.getLocalHost(). This of course requires that the system on which Flink is running, is properly configured. This closes #1758.
-
由 Aljoscha Krettek 提交于
-
- 03 3月, 2016 3 次提交
-
-
由 zentol 提交于
This closes #1664.
-
由 zentol 提交于
This closes #1710.
-
由 Stephan Ewen 提交于
-