[
https://issues.apache.org/jira/browse/FLINK-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7611:
--
Affects Version/s: 1.3.0
> add metrics to measure the data drop by watermark
>
[
https://issues.apache.org/jira/browse/FLINK-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162401#comment-16162401
]
mingleizhang commented on FLINK-2395:
-
The link was broken. 404 error.
> Check Scala catch blocks for
[
https://issues.apache.org/jira/browse/FLINK-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7611:
--
Affects Version/s: 1.2.0
> add metrics to measure the data drop by watermark
>
[
https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou closed FLINK-2428.
---
Resolution: Fixed
> Clean up unused properties in StreamConfig
> --
>
[
https://issues.apache.org/jira/browse/FLINK-3542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162054#comment-16162054
]
Hai Zhou commented on FLINK-3542:
-
[~till.rohrmann]
In flink 1.3.x, FlinkKafkaConsumer08 also have this
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161996#comment-16161996
]
Bowen Li edited comment on FLINK-6703 at 9/11/17 9:09 PM:
--
I tested on our
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161996#comment-16161996
]
Bowen Li commented on FLINK-6703:
-
I tested on our Flink-YARN cluster, and {{-m yarn-cluster}} is actually
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6703:
Comment: was deleted
(was: [~Zentol] is this still valid? is the above savepoint command for Flink
job
[
https://issues.apache.org/jira/browse/FLINK-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161843#comment-16161843
]
Bowen Li commented on FLINK-6957:
-
[~Zentol] I'm able to run this example after running a build fot the
[
https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161656#comment-16161656
]
ASF GitHub Bot commented on FLINK-7609:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4662
There's no output with 100/50 either, because the default text we use at
WordCountData.WORDS is not very long and cannot satisfy the count window size.
There's only 11 window ouputs even with
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161616#comment-16161616
]
ASF GitHub Bot commented on FLINK-4047:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4659
+1.
---
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161611#comment-16161611
]
ASF GitHub Bot commented on FLINK-7521:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4654
The actual solution that I'm thinking of currently is to have a modified
`HttpObjectAggregator` implementation that spills larger messages to disk.
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4647#discussion_r138133547
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/utils/MutableIOMetrics.java
---
@@ -72,13 +72,54 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161608#comment-16161608
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161607#comment-16161607
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161609#comment-16161609
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4647#discussion_r138133369
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/utils/MutableIOMetrics.java
---
@@ -72,13 +72,54 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4647#discussion_r138133763
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/utils/MutableIOMetrics.java
---
@@ -99,11 +140,35 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161598#comment-16161598
]
ASF GitHub Bot commented on FLINK-7609:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4662
Aren't these values a bit too low? (I'm specifically worried about cases
where users supply their own data)
Would 100/50 maybe work?
---
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161590#comment-16161590
]
Chesnay Schepler commented on FLINK-5944:
-
Option 2/3 are out imo as they extend the existing API
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161582#comment-16161582
]
ASF GitHub Bot commented on FLINK-4831:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4661
Really nice that you figured out to rename the package to slf4j :)
I'll check this out in more detail next week.
---
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161573#comment-16161573
]
ASF GitHub Bot commented on FLINK-6549:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4663
I think this looks good.
---
[
https://issues.apache.org/jira/browse/FLINK-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161570#comment-16161570
]
ASF GitHub Bot commented on FLINK-7562:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4664
Ill check this out sometime next week.
---
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161568#comment-16161568
]
ASF GitHub Bot commented on FLINK-7521:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4654
removing the object aggregator will break the remaining pipeline, so that
option is out too.
As for the client upload, that's exactly whats being done right now. The
jar is uploaded to the
aitozi created FLINK-7611:
-
Summary: add metrics to measure the data drop by watermark
Key: FLINK-7611
URL: https://issues.apache.org/jira/browse/FLINK-7611
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161200#comment-16161200
]
Kostas Kloudas commented on FLINK-7606:
---
Hi Matteo,
Thanks for reporting this!
Any additional
[
https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161119#comment-16161119
]
Hai Zhou commented on FLINK-6444:
-
I already have an idea.
When I am not busy with work;), I will go to
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161107#comment-16161107
]
Ashish Pokharel commented on FLINK-4319:
Thanks Till - this ia great.
> Rework Cluster Management
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161075#comment-16161075
]
Philipp Grulich commented on FLINK-7001:
Hey,
what is the current state of this?
Over the last
[
https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160925#comment-16160925
]
mingleizhang commented on FLINK-6444:
-
Hello, [~StephanEwen] . I would like work on this. But I need
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160890#comment-16160890
]
Till Rohrmann commented on FLINK-4319:
--
Hi Ashish,
great to hear that things are working so far :-)
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160810#comment-16160810
]
Erik van Oosten commented on FLINK-4796:
A workaround is to override {{setRuntimeContext}} (make
40 matches
Mail list logo
