Github user jelmerk commented on a diff in the pull request:
https://github.com/apache/flink/pull/6211#discussion_r198484545
--- Diff:
flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java
---
@@ -159,6 +162,27
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/6211
[FLINK-9665] PrometheusReporter does not properly unregister metrics
## What is the purpose of the change
Prometheus metrics from canceled jobs are not always correctly cleaned up.
This
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/5616
[FLINK-8828] [stream, dataset, scala] Introduce collect method
## What is the purpose of the change
A collect function is a method that takes a Partial Function as its
parameter and
Github user jelmerk commented on the issue:
https://github.com/apache/flink/pull/5603
Thanks!
---
Github user jelmerk closed the pull request at:
https://github.com/apache/flink/pull/5603
---
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/5603
[FLINK-8814] Control over the extension of part files created by
BucketingSink
## What is the purpose of the change
Popular tools like hue and the avro connector for spark require files
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/5376
[FLINK-6214] WindowAssigners do not allow negative offsets
## What is the purpose of the change
The javadoc of TumblingEventTimeWindows and TumblingProcessingTimeWindows
suggest that it is
Github user jelmerk commented on the issue:
https://github.com/apache/flink/pull/5296
All valid points, thanks for the review!
---
Github user jelmerk commented on a diff in the pull request:
https://github.com/apache/flink/pull/5296#discussion_r164158508
--- Diff:
flink-filesystems/flink-openstack-fs-hadoop/src/test/java/org/apache/flink/fs/openstackhadoop/HadoopSwiftFileSystemITCase.java
---
@@ -0,0 +1,208
Github user jelmerk commented on a diff in the pull request:
https://github.com/apache/flink/pull/5296#discussion_r164158160
--- Diff:
flink-filesystems/flink-openstack-fs-hadoop/src/main/java/org/apache/flink/fs/openstackhadoop/SwiftFileSystemFactory.java
---
@@ -0,0 +1,132
Github user jelmerk commented on a diff in the pull request:
https://github.com/apache/flink/pull/5296#discussion_r164158043
--- Diff:
flink-filesystems/flink-openstack-fs-hadoop/src/main/java/org/apache/flink/fs/openstackhadoop/SwiftFileSystemFactory.java
---
@@ -0,0 +1,132
Github user jelmerk commented on the issue:
https://github.com/apache/flink/pull/5296
Hi @tillrohrmann Those files with a lot of changes are unfortunately
copied from hadoop, the readme file contains more information about how this
works. I am not overly happy about the this
GitHub user jelmerk opened a pull request:
https://github.com/apache/flink/pull/5296
[FLINK-8432] [filesystem-connector] Add support for openstack's swift
filesystem
## What is the purpose of the change
Add support for OpenStack's cloud storage solution
13 matches
Mail list logo
