- 06 1月, 2018 11 次提交
-
-
由 王振涛 提交于
This closes #5204
-
由 Cristian 提交于
This closes #5178
-
由 yew1eb 提交于
This closes #5238
-
由 Greg Hogan 提交于
Fix typos from the IntelliJ "Typos" inspection. This closes #5242
-
由 Raycee 提交于
This closes #5237
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 twalthr 提交于
[FLINK-8203] [FLINK-7681] [table] Make schema definition of DataStream/DataSet to Table conversion more flexible This closes #5132.
-
由 twalthr 提交于
-
由 Aegeaner 提交于
This closes #5065.
-
由 金竹 提交于
This closes #5218
-
- 05 1月, 2018 6 次提交
-
-
由 Nico Kruber 提交于
Previously, NettyBufferPool only wrapped PooledByteBufAllocator but then, any allocated buffer's alloc() method was returning the wrapped PooledByteBufAllocator which allowed heap buffers again. By extending the PooledByteBufAllocator, we prevent this loop hole. This also fixes the invariant that a copy of a buffer should have the same allocator. This closes #4594.
-
由 Nico Kruber 提交于
[FLINK-7499][io] also let AsynchronousBufferFileWriter#writeBlock() recycle the buffer in case of failures This fixes a double-recycle in SpillableSubpartitionView and also makes sure that even if adding the (asynchronous) write operation fails, the buffer is properly freed in code that did not perform this cleanup. It avoids code duplication of this cleanup and it is also more consistent to take over responsibility of the given buffer even if an exception is thrown. [FLINK-7499][io] complete the idiom of ResultSubpartition#add() taking over ownership of the buffer The buffer will now always be released once and at the right time and the caller must not worry about the buffer release if a called function threw an exception. This closes #4581.
-
由 Nico Kruber 提交于
-
由 Nico Kruber 提交于
-
由 Nico Kruber 提交于
- removes one level of (unneeded) abstraction for clarity This closes #4528.
-
由 Xingcan Cui 提交于
This closes #5068.
-
- 04 1月, 2018 3 次提交
- 03 1月, 2018 2 次提交
-
-
由 twalthr 提交于
-
由 Xingcan Cui 提交于
This closes #5169.
-
- 02 1月, 2018 3 次提交
-
-
由 Tony Wei 提交于
[FLINK-8326] CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function
-
由 Xingcan Cui 提交于
-
由 Dian Fu 提交于
This closes #5141
-
- 01 1月, 2018 2 次提交
-
-
由 Till Rohrmann 提交于
The YarnClusterClientV2 is no longer needed since we have removed FlinkYarnCLI.
-
由 Till Rohrmann 提交于
The FlinkYarnCLI is not needed and is, thus, being removed. This closes #5217.
-
- 30 12月, 2017 1 次提交
-
-
由 Till Rohrmann 提交于
It is no longer needed to wait for the registration of task managers and to not use slot sharing when submitting jobs to the Flip-6 MiniCluster. Therefore, we can remove these work arounds from the Flip6LocalStreamEnvironment. Adapt comment in RestClusterClient This closes #5101.
-
- 29 12月, 2017 3 次提交
-
-
由 Till Rohrmann 提交于
-
由 Dian Fu 提交于
This closes #5142
-
由 Xpray 提交于
This closes #5206
-
- 27 12月, 2017 1 次提交
-
-
由 Xingcan Cui 提交于
-
- 26 12月, 2017 1 次提交
-
-
由 Xpray 提交于
This closes #5203
-
- 22 12月, 2017 2 次提交
-
-
由 Cristian 提交于
This closes #5199
-
由 Greg Hogan 提交于
Now that Flink only supports builds for Scala 2.11+ we can unconditionally enable the Kafka 0.11 connector. This closes #5195
-
- 21 12月, 2017 4 次提交
-
-
由 Greg Hogan 提交于
Update 2.7.3 to 2.7.5 and 2.8.0 to 2.8.3 This closes #5137
-
由 Greg Hogan 提交于
This is an incremental upgrade to the Scala security release 2.11.12. This closes #5136
-
由 Greg Hogan 提交于
Double.MIN_VALUE != min(double) This closes #5126
-
由 Nico Kruber 提交于
com.datastax.driver.core.NettyUtil expects netty to be present either at its original package or relocated to com.datastax.shaded.netty. By relocating it to this package we make sure the driver follows its designated path. This closes #5183.
-
- 19 12月, 2017 1 次提交
-
-
由 Rong Rong 提交于
This closes #5148.
-