- 17 12月, 2015 1 次提交
-
-
由 Peter Vandenabeele 提交于
This closes #1463.
-
- 16 12月, 2015 6 次提交
-
-
由 Till Rohrmann 提交于
-
由 Ufuk Celebi 提交于
This closes #1439
-
由 Nick Dimiduk 提交于
This closes #1442
-
由 Greg Hogan 提交于
- Memoize string representations of AbstractID. - Use lookup table for byte-to-hex conversion in StringUtils. This closes #1455
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
Before, when the Kafka Source would emit a final Long.MAX_VALUE watermark to signal the end of elements (i.e. no partition assigned). This would trip up the AutomaticWatermarkContext and the NonWatermarkContext. Now, a Long.MAX_VALUE watermark is allowed through.
-
- 15 12月, 2015 9 次提交
-
-
由 Stephan Ewen 提交于
[FLINK-3171] [misc] Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[hotfix] Minor cleanups in classes FileSystem, OperatingSystem, CopyableValue, GenericCsvInputFormat
-
由 Ufuk Celebi 提交于
This was removed in 3b8b4f0f. The issue was fixed by this, but it disabled local testing as well. This change re-introduces the variable and sets it to the empty string by default. This way, we can still use the proxy server for local testing. This closes #1449
-
由 Ufuk Celebi 提交于
Many browsers don't allow cross-origin HTTP requests if the respective HTTP header is not set by the server. Because of this it was not possible to test changes to the web frontend with the local proxy server and a running job manager. See here: https://developer.mozilla.org/en-US/docs/Web/HTTP/Access_control_CORS
-
- 13 12月, 2015 2 次提交
-
-
由 Sachin Goel 提交于
This closes #1418
-
由 Sachin Goel 提交于
This closes #1422
-
- 11 12月, 2015 2 次提交
-
-
由 Aljoscha Krettek 提交于
Kafka sources that don't read from any partition never emit a watermark, thereby blocking the progress of event-time in downstream operations. This changes the Kafka Source to emit a Long.MAX_VALUE watermark if it knows that it will never receive data. This also changes the Timestamp Extraction operator to reacto to a Long.MAX_VALUE watermark by itself emitting a Long.MAX_VALUE watermark.
-
由 Aljoscha Krettek 提交于
Before, would throw a ClassCastException when emitting watermarks with timestamp/watermark multiplexing disabled.
-
- 10 12月, 2015 2 次提交
-
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
This closes #1416
-
- 09 12月, 2015 7 次提交
-
-
由 mjsax 提交于
-
由 Maximilian Michels 提交于
This closes #1441.
-
由 Maximilian Michels 提交于
- This solves errors with reflectasm using Scala 2.11 and Java 8 This closes #1445.
-
由 Romeo Kienzler 提交于
This closes #1443.
-
由 Aljoscha Krettek 提交于
Before, streaming mode (either batch or streaming) would specify how memory is allocated on task managers. This introduces a new configuration value taskmanager.memory.allocation that can take values "lazy" or "eager". This controls how memory is allocated.
-
由 Aljoscha Krettek 提交于
-
由 Robert Metzger 提交于
This closes #1437
-
- 08 12月, 2015 5 次提交
-
-
由 twalthr 提交于
This closes #1440
-
由 Fabian Hueske 提交于
This closes #1435
-
由 Fabian Hueske 提交于
This closes #1436
-
由 Stephan Ewen 提交于
-
由 Greg Hogan 提交于
This closes #1292
-
- 07 12月, 2015 6 次提交
-
-
由 Robert Metzger 提交于
-
由 Sachin Goel 提交于
[FLINK-2488] [FLINK-2524] [FLINK-3124] Expose Attempt Number in RuntimeContext and add TaskInfo to hold all task related parameters. This closes #1386
-
由 Omer Katz 提交于
This closes #1366
-
由 Jun Aoki 提交于
This closes #1430 It seems AbstractJobVertex class no longer exists but the doc's link still points to it.
-
由 Jun Aoki 提交于
This closes #1438
-
由 Stephan Ewen 提交于
-