Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
Hi @radekg ,
There was a recent change to the connector code to how the Kafka metrics
are reported, so right now the PR has conflicts and can't be built. Would you
like to rebase this PR on the
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389060#comment-15389060
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389062#comment-15389062
]
ramkrishna.s.vasudevan commented on FLINK-3397:
---
[~uce]
A gentle ping !!! :)
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2279
@StephanEwen did you merge this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled an
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389181#comment-15389181
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user aljoscha commented on the issue
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/1989
@fpompermaier I think you can close this PR. I will take your commit, put
the Scala conversion on top of it and open a new PR.
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389214#comment-15389214
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user twalthr commented on the issue:
Ufuk Celebi created FLINK-4253:
--
Summary: Rename "recovery.mode" config key to "high-availability"
Key: FLINK-4253
URL: https://issues.apache.org/jira/browse/FLINK-4253
Project: Flink
Issue Type
Ufuk Celebi created FLINK-4254:
--
Summary: Add file system based high-availability mode
Key: FLINK-4254
URL: https://issues.apache.org/jira/browse/FLINK-4254
Project: Flink
Issue Type: New Featur
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2279
Was waiting for travis after the rebase, but got the green light now. Will
push it to master...
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389232#comment-15389232
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user StephanEwen commented on the is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2279
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389233#comment-15389233
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4229.
---
> Do not start Metrics Reporter by default
>
>
>
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2283
[FLINK-3901] [table] Create a RowCsvInputFormat for Table API
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389265#comment-15389265
]
ASF GitHub Bot commented on FLINK-3901:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389269#comment-15389269
]
Till Rohrmann commented on FLINK-4240:
--
Oh yes, you're right. Sorry stupid mistake. W
[
https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4240.
Resolution: Not A Problem
> Cannot use expressions in Scala Table API's groupBy method
> ---
[
https://issues.apache.org/jira/browse/FLINK-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-4249.
---
Resolution: Duplicate
> CsvTableSource does not support reading SqlTimeTypeInfo types
> --
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4246:
---
Assignee: Aljoscha Krettek
> Allow Specifying Multiple Metrics Reporters
> --
[
https://issues.apache.org/jira/browse/FLINK-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389279#comment-15389279
]
Till Rohrmann commented on FLINK-4249:
--
Sorry, I must have clicked twice the create i
Github user fpompermaier closed the pull request at:
https://github.com/apache/flink/pull/1989
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature i
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389280#comment-15389280
]
Till Rohrmann commented on FLINK-4250:
--
Ah ok that makes sense. And indeed when chang
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/1989
Ok for me
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389282#comment-15389282
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389281#comment-15389281
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389284#comment-15389284
]
Timo Walther commented on FLINK-4252:
-
We had a similar issue with the old Table API.
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389284#comment-15389284
]
Timo Walther edited comment on FLINK-4252 at 7/22/16 10:31 AM:
-
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2271
Good points with the documentation and the exposed metrics. I'll update the
documentation.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389285#comment-15389285
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389288#comment-15389288
]
Timo Walther commented on FLINK-4250:
-
We have to figure that out. We should also add
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2284
[FLINK-4202] [metrics] Update restarting time metric documentation
Update the restarting time JM metric documentation.
Please review @zentol.
You can merge this pull request into
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389300#comment-15389300
]
ASF GitHub Bot commented on FLINK-4202:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389308#comment-15389308
]
ASF GitHub Bot commented on FLINK-4173:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2216
I've made the following changes:
* use "append" instead of "override" for the shade configuration
* include the missing `org.acplt:oncrpc` dependency
---
If your project is set up for it, you
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2284
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature i
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389314#comment-15389314
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user zentol commented on the issue:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2218
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389320#comment-15389320
]
ASF GitHub Bot commented on FLINK-4161:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389341#comment-15389341
]
Jark Wu commented on FLINK-4252:
Do we have the JIRA? Or just modify this JIRA to track i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2226
I tried to see if we can move the entire set of metrics classes to the
independent `flink-metrics-core` module. Here is how that would look like:
https://github.com/StephanEwen/incubator-flink/tr
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389345#comment-15389345
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user StephanEwen commented on the is
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2226
I had a chat with @tillrohrmann about moving all classes when i started
working on this issue. We decided to not include implementations in the new
module, to be able to use NetUtils and Preconditions
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389355#comment-15389355
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user zentol commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2245
Done! Thanks @tillrohrmann
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2245#discussion_r71869449
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisSinkTest.java
---
@@ -105,18 +
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2245#discussion_r71869391
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisSinkTest.java
---
@@ -105,18 +
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2284
Merging PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or i
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389385#comment-15389385
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user tillrohrmann commented on the i
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2245#discussion_r71869640
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisSinkTest.java
---
@@ -105,18 +105,13 @
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4202.
Resolution: Fixed
Fixed via b3fa459d4c9657e95fdc875d2566b57d48a0a027
> Add JM metric which shows th
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389389#comment-15389389
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2284
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2276
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4201.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 54f02ec (master).
> Checkpoints for jobs in non-
[
https://issues.apache.org/jira/browse/FLINK-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389401#comment-15389401
]
ASF GitHub Bot commented on FLINK-4201:
---
Github user asfgit closed the pull request
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2226
Think of this as part of the discussion with another guy in the community
;-)
The split of metric classes between `flink-core` and `flink-metric-core`
made it to me a bit complicated to
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2245
I think this is ok now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389406#comment-15389406
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389432#comment-15389432
]
Greg Hogan commented on FLINK-4161:
---
What happened here? PR is closed but ticket remains
[
https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389455#comment-15389455
]
Kanstantsin Kamkou commented on FLINK-4251:
---
I'm not sure who created the first
[
https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389459#comment-15389459
]
ASF GitHub Bot commented on FLINK-4251:
---
Github user kkamkou commented on the issue:
Github user kkamkou commented on the issue:
https://github.com/apache/flink/pull/2281
Please, merge this ticket in 1.1.0, otherwise the rabbitmq sink
functionality is unusable.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389463#comment-15389463
]
Chesnay Schepler commented on FLINK-4161:
-
i deleted the branch by accident.
> Qu
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
GaoLun reassigned FLINK-3940:
-
Assignee: GaoLun
> Add support for ORDER BY OFFSET FETCH
> -
>
>
Github user kkamkou commented on a diff in the pull request:
https://github.com/apache/flink/pull/2281#discussion_r71876785
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -58,6 +58,15 @
[
https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389475#comment-15389475
]
ASF GitHub Bot commented on FLINK-4251:
---
Github user kkamkou commented on a diff in
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2285
[FLINK-4246] Allow Specifying Multiple Metrics Reporters
This also updates documentation and tests.
Reporters can now be specified like this:
metrics.reporters: foo,bar
me
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389487#comment-15389487
]
ASF GitHub Bot commented on FLINK-4246:
---
GitHub user aljoscha opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2286
[FLINK-4210][metrics] Move close()/isClosed() out of MetricGroup
This PR moves the `close()` and `isClosed()` methods from the MetricGroup
interface into the AbstractMetricGroup class.
The r
[
https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389494#comment-15389494
]
ASF GitHub Bot commented on FLINK-4210:
---
GitHub user zentol opened a pull request:
Github user soumyasd commented on the issue:
https://github.com/apache/flink/pull/2051
Any idea which Flink version this feature is going live with ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does n
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389496#comment-15389496
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soumyasd commented on the issue
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2226
Separating classes certainly makes navigation trickier, but should we
sacrifice code-stability (Preconditions/NetUtils) for it? I believe a
separation of interfaces and implementation is a good compro
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389484#comment-15389484
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71879184
--- Diff: docs/apis/metrics.md ---
@@ -227,14 +227,25 @@ or by assigning unique names to jobs and operators.
## Reporter
-Metrics can be ex
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71879710
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -75,77 +78,92 @@ public MetricRegistry(Configuration config) {
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389508#comment-15389508
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389513#comment-15389513
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71879969
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -75,77 +78,92 @@ public MetricRegistry(Configuration config) {
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389503#comment-15389503
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71880194
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -198,8 +220,13 @@ public void register(Metric metric, String metricName,
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389517#comment-15389517
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71880255
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -263,6 +276,7 @@ private ReporterTask(Scheduled reporter) {
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389515#comment-15389515
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389522#comment-15389522
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389525#comment-15389525
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71881023
--- Diff: docs/apis/metrics.md ---
@@ -227,14 +227,25 @@ or by assigning unique names to jobs and operators.
## Reporter
-Metrics can be ex
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389524#comment-15389524
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71881022
--- Diff: docs/apis/metrics.md ---
@@ -227,14 +227,25 @@ or by assigning unique names to jobs and operators.
## Reporter
-Metrics can be ex
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71881920
--- Diff: docs/apis/metrics.md ---
@@ -227,14 +227,25 @@ or by assigning unique names to jobs and operators.
## Reporter
-Metrics can be ex
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71880869
--- Diff: docs/apis/metrics.md ---
@@ -227,14 +227,25 @@ or by assigning unique names to jobs and operators.
## Reporter
-Metrics can be ex
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389532#comment-15389532
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71882304
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -651,14 +651,38 @@
//
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389536#comment-15389536
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71882489
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -651,14 +651,38 @@
//
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389539#comment-15389539
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71882781
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java ---
@@ -75,77 +78,92 @@ public MetricRegistry(Configuration config) {
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389543#comment-15389543
]
ASF GitHub Bot commented on FLINK-4246:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2285#discussion_r71883212
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/DelegatingConfigurationTest.java
---
@@ -28,7 +28,7 @@
import java.util.Comparator;
1 - 100 of 213 matches
Mail list logo
