- 27 11月, 2017 1 次提交
-
-
由 Piotr Nowojski 提交于
Increasing timeout for reading the records from 30s to 60s seems to solve the issue for failing at-least-one tests.
-
- 25 11月, 2017 1 次提交
-
-
由 gyao 提交于
Migrate logic in org.apache.flink.runtime.rest.handler.legacy.metrics.JobVertexMetricsHandler to new handler and add new handler to DispatcherRestEndpoint. Add common classes for remaining implementations of org.apache.flink.runtime.rest.handler.legacy.metrics.AbstractMetricsHandler, which require migration as well. [FLINK-7718] [flip6] Clean up JobVertexMetricsHandlerHeaders [FLINK-7718] [flip6] Assert that HTTP code is 404 if metric is unknown [FLINK-7718] [flip6] Minor fixes in Javadocs [FLINK-7718] [flip6] Add unit test for AbstractMetricsHandlerHeaders [FLINK-7718] [flip6] Let unit tests inherit from TestLogger [FLINK-7718] [flip6] Re-format Metric constructor [FLINK-7718] [flip6] Fix mistake in Javadoc of AbstractMetricsHandlerHeaders [FLINK-7718] [flip6] Rename AbstractMetricsHandlerHeaders to AbstractMetricsHeaders Strip the term Handler from the Header class. Also rename its subclasses. [FLINK-7718] [flip6] No longer return HTTP 404 if metric is unknown [FLINK-7718] [flip6] Make JobVertexMetricsHeaders class final [FLINK-7718] [flip6] Introduce MetricsHandlerTestBase for future MetricHandlers [FLINK-7718] [flip6] Always return same MessageParameter objects in JobVertexMetricsMessageParameters This closes #5055.
-
- 24 11月, 2017 5 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Nico Kruber 提交于
This is another step at using or own (off-heap) buffers for network communication that we pass through netty in order to avoid unnecessary buffer copies. This closes #4481.
-
由 Aljoscha Krettek 提交于
This was causing the snapshot deployment to fail.
-
- 23 11月, 2017 11 次提交
-
-
由 Stefan Richter 提交于
[FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown. This closes #5058.
-
由 Piotr Nowojski 提交于
-
由 twalthr 提交于
-
由 Xingcan Cui 提交于
This closes #5056.
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
Previously faulty scenario with producer pool of 2. 1. started transaction 1 with producerA, written record 42 2. checkpoint 1 triggered, pre committing txn1, started txn2 with producerB, written record 43 3. checkpoint 1 completed, committing txn1, returning producerA to the pool 4. checkpoint 2 triggered , committing txn2, started txn3 with producerA, written record 44 5. crash.... 6. recover to checkpoint 1, txn1 from producerA found to "pendingCommitTransactions", attempting to recoverAndCommit(txn1) 7. unfortunately txn1 and txn3 from the same producers are identical from KafkaBroker perspective and thus txn3 is being committed result is that both records 42 and 44 are committed. With this fix, after re-initialization txn3 will have different producerId/epoch counters compared to txn1.
-
由 Piotr Nowojski 提交于
-
由 Bowen Li 提交于
-
由 Fabian Hueske 提交于
This closes #5043.
-
由 uybhatti 提交于
This closes #4670.
-
由 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 7 次提交
-
-
由 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 提交于
-