- 17 12月, 2016 7 次提交
-
-
由 David Anderson 提交于
[FLINK-5344] Fixed the dockerized doc build, which has been broken for a while. Fixed the -p option. Reverted the main Gemfile back to ruby 1.9 to make the build bot happy, and created a new Gemfile in ruby2/Gemfile to keep the incremental build option available. This closes #3016.
-
由 Maximilian Michels 提交于
This uses Flakka (a custom Akka 2.3 build) to resolve the issue that the bind address needs to be matching the external address of the JobManager. With the changes applied, we can now bind to all interfaces, e.g. via 0.0.0.0 (IPv4) or :: (IPv6). For this to work properly, the configuration entry JOB_MANAGER_IPC_ADDRESS now represents the external address of the JobManager. Consequently, it should not be resolved to an IP address anymore because it may not be resolvable from within containered environments. Akka treats this address as the logical address. Any messages which are not tagged with this address will be received by the Actor System (because we listen on all interfaces) but will be dropped subsequently. In addition, we need the external address for the JobManager to be able to publish it to Zookeeper for HA setups. Flakka: https://github.com/mxm/flakka Patch applied: https://github.com/akka/akka/pull/15610 - convert host to lower case - use consistent format for IPv6 address - adapt config and test cases - adapt documentation to clarify the address config entry - TaskManager: resolve the initial hostname of the StandaloneLeaderRetrievalService This closes #2917.
-
由 Maximilian Michels 提交于
Two options, either change the default Maven source directory from 'src/main/java' to 'src/main/scala' or use the build-helper-maven-plugin to attach the Scala sources. Opting for both here to be in lines with Maven standards and support Eclipse. This closes #2908.
-
由 Maximilian Michels 提交于
Users may want to use SASL/PLAIN https://tools.ietf.org/html/rfc4616 without Kerberos enabled. Skip security configuration if no Kerberos credentials are available. This closes #3017.
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
This closes #3007.
-
由 Maximilian Michels 提交于
- configure job manager address for both operation modes - introduce argument to specify the external job manager address - replace ARG with ENV for backwards-compatibility - EXPOSE web port and RPC port This closes #2981.
-
- 16 12月, 2016 10 次提交
-
-
由 Nico Kruber 提交于
This closes #2764.
-
由 Fabian Hueske 提交于
-
由 tonycox 提交于
- Add plan tests for projection push down. - Implement ProjectableTableSource in CsvTableSource. - Refactored RowCsvInputFormat This closes #2810.
-
由 Alexander Shoshin 提交于
- Add support for projections and filters following a global aggregation. This closes #3009.
-
由 Fabian Hueske 提交于
This closes #3011.
-
由 Anton Mushin 提交于
This closes #2958.
-
由 twalthr 提交于
[FLINK-5011] [types] TraversableSerializer does not perform a deep copy of the elements it is traversing This closes #2952.
-
由 twalthr 提交于
-
由 Ivan Mushketyk 提交于
This closes #2984
-
由 vasia 提交于
in MapVertices, mapEdges, fromDataSet, and groupReduceOnEdges This closes #2842
-
- 15 12月, 2016 12 次提交
-
-
由 魏偉哲 提交于
This closes #2914.
-
由 Robert Metzger 提交于
-
由 tonycox 提交于
- Port RowCsvInputFormat to Java and move it to flink-core. This closes #3003.
-
由 tonycox 提交于
This closes #3004.
-
由 Jark Wu 提交于
This closes #2968.
-
由 Kurt Young 提交于
This closes #2961.
-
由 Stefan Richter 提交于
-
由 Greg Hogan 提交于
Provide descriptive operator names for Graph and GraphCsvReader. Condense multiple type conversion maps into a single mapper. Reuse objects in operations wrapping user-defined-functions. This closes #2832
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
-
- 14 12月, 2016 11 次提交
-
-
由 Maximilian Michels 提交于
This adds additional test cases to verify the state backends are closed properly upon the end of a task. The state backends should always be closed regardless of the final state of the task. This closes #2997.
-
由 Robert Metzger 提交于
-
由 David Anderson 提交于
This closes #2940
-
由 Raghav 提交于
This closes #3002
-
由 Till Rohrmann 提交于
Using static mocking to reliably fail the InetAddress.getByName call with an UnknowHostException. Furthermore, the PR decreases the connection timeouts which speeds the test execution up. This closes #2998
-
由 Roman Maier 提交于
This closes #2865
-
由 zentol 提交于
This closes #2979
-
由 Stephan Ewen 提交于
The classes were noved to 'flink-test-utils-junit', but apparently copies remained in 'flink-core'.
-
由 Stefan Richter 提交于
This closes #2969
-
由 Stephan Ewen 提交于
[FLINK-5332] [core] Synchronize FileSystem::initOutPathLocalFS() to prevent lost files when called concurrently.
-
由 Stephan Ewen 提交于
-