- 23 11月, 2017 1 次提交
-
-
由 twalthr 提交于
This closes #5054.
-
- 22 11月, 2017 13 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Cristian 提交于
This closes #5051.
-
由 Aljoscha Krettek 提交于
-
由 zentol 提交于
This closes #5020.
-
由 zentol 提交于
This closes #5042.
-
由 zentol 提交于
This closes #5012.
-
由 Greg Hogan 提交于
Update to the latest checkstyle version and fix the errors not previously detected. This closes #5044.
-
由 Nico Kruber 提交于
This closes #5029
-
由 Gabor Gevay 提交于
This closes #5041
-
由 zentol 提交于
-
由 Dian Fu 提交于
This closes #5027.
-
由 twalthr 提交于
-
由 Rong Rong 提交于
This closes #5015.
-
- 21 11月, 2017 2 次提交
-
-
由 Gabor Gevay 提交于
This closes #5039.
-
由 Aljoscha Krettek 提交于
Before, the "hadoop2" profile would create a binary release for whatever happens to be the default hadoop.version.
-
- 20 11月, 2017 15 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Joerg Schad 提交于
This closes #5033.
-
由 yew1eb 提交于
This close #4794.
-
由 Till Rohrmann 提交于
This commit changes the serialization of the ParameterTool such that only the data map is contained. The defaultData and the unrequestedParameters maps are not serialized because they are only used on the client side. Additionally, the defaultData and unrequestedParameters map are being made thread safe by using ConcurrentHashMaps. This closes #4921.
-
由 zentol 提交于
This closes #8110.
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 Aljoscha Krettek 提交于
-
由 Piotr Nowojski 提交于
ProducerFencedException can happen if we restore twice from the same checkpoint or if we restore from an old savepoint. In both cases transactional.ids that we want to recoverAndCommit have been already committed and reused. Reusing mean that they will be known by Kafka's brokers under newer producerId/epochId, which will result in ProducerFencedException if we try to commit again some old (and already committed) transaction. Ignoring this exception might hide some bugs/issues, because instead of failing we might have a semi silent (with a warning) data loss.
-
由 Piotr Nowojski 提交于
-
由 Stefan Richter 提交于
This closes #4883.
-
由 Xpray 提交于
This closes #5026.
-
由 Dian Fu 提交于
This closes #5025.
-
- 18 11月, 2017 2 次提交
-
-
由 Nico Kruber 提交于
This closes #4950.
-
由 Nico Kruber 提交于
+ includes a new unit tests for recursive uploads to hfds:// targets + add a unit test for recursive file uploads to s3:// via s3a [FLINK-4228][yarn/s3] turn the dependencies around Instead of having flink-s3-fs-hadoop depend on flink-yarn_<scala_version>, let flink-yarn depend on the s3 filesystem and implement the test there. This is safer with regards to the scala-independent flink-s3-fs-hadoop project. [FLINK-4228][yarn] change the S3 upload tests to use Hadoop's S3 implementations This is how YARN would use it and what should really be tested. [FLINK-4228][yarn] enable S3 tests for newer Hadoop versions - requires the 'include_hadoop_aws' build profile (or property) to be set - requires a newer aws-sdk version (than Hadoop pulls in) to work with our httpcomponents version - we also add a check that at least one S3 implementation is tested to not silently ignore all tests because of such a missing dependency This closes #4939.
-
- 17 11月, 2017 7 次提交
-
-
由 Stephan Ewen 提交于
This closes #4397
-
由 Stephan Ewen 提交于
-
由 Vetriselvan1187 提交于
-
由 kkloudas 提交于
-
由 kkloudas 提交于
-
由 kkloudas 提交于
-
由 kkloudas 提交于
-