[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203812#comment-15203812
]
Chesnay Schepler commented on FLINK-3579:
-
we can't reopen pull requests, you will have to submit
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203816#comment-15203816
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user zentol commented on the pull request:
Maxim Dobryakov created FLINK-3638:
--
Summary: Invalid default ports in documentation
Key: FLINK-3638
URL: https://issues.apache.org/jira/browse/FLINK-3638
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56793439
--- Diff: docs/apis/streaming/event_timestamps_watermarks.md ---
@@ -308,6 +269,89 @@ class TimeLagWatermarkGenerator extends
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203853#comment-15203853
]
ASF GitHub Bot commented on FLINK-3579:
---
GitHub user ramkrish86 opened a pull request:
GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/1821
FLINK-3579 Improve String concatenation (Ram)
Updated PR against branch after the deletion of tableOnCalcite. It was
suggested over in the old PR an d in JIRA to create a new PR as the old one
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205273#comment-15205273
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1822#discussion_r56904780
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java
---
@@ -90,6 +94,9 @@ public
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1822#discussion_r56904841
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java
---
@@ -61,6 +65,9 @@ public SingleInputPlanNode
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205235#comment-15205235
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205237#comment-15205237
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205236#comment-15205236
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1822#issuecomment-199503791
Thanks for the PR! Just had a suggestion for the wording of the log
message. Looks good otherwise.
---
If your project is set up for it, you can reply to this email
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56907132
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java
---
@@ -45,35 +46,48 @@
private final PartitionMethod
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205180#comment-15205180
]
Eron Wright commented on FLINK-1579:
-
Something to consider before taking a dependency on the YARN
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1823#issuecomment-199506835
Thanks for the PR @ramkrish86
Looks good. Just one minor thing. Can you add a one line comment to each
test that explains why the program should fail such as the
[
https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205250#comment-15205250
]
ASF GitHub Bot commented on FLINK-3631:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205029#comment-15205029
]
Fabian Hueske commented on FLINK-3587:
--
The vote to release Apache Calcite 1.7 just passed. We can
[
https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3587:
-
Summary: Bump Calcite version to 1.7.0 (was: Bump Calcite version to
1.7.0-SNAPSHOT)
> Bump
[
https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205032#comment-15205032
]
Vasia Kalavri commented on FLINK-3587:
--
Yes, I saw it too!
> Bump Calcite version to 1.7.0-SNAPSHOT
[
https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-3587:
Assignee: Fabian Hueske
> Bump Calcite version to 1.7.0
> -
>
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^
[
https://issues.apache.org/jira/browse/FLINK-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3576:
--
Description:
There was a JVM memory leaky problem reported in
https://github.com/xerial/snappy-java/issues/131
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1822#issuecomment-199642001
Done the update @fhueske . Pls review. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205812#comment-15205812
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205767#comment-15205767
]
ASF GitHub Bot commented on FLINK-3644:
---
GitHub user Astralidea opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205813#comment-15205813
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on the pull request:
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1821#issuecomment-199642088
@fhueske - Not sure how to check the failed test cases. Any chance of a
review here? Thank you.
---
If your project is set up for it, you can reply to this email
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1220#issuecomment-199648335
Hi @danielblazevski, thanks for update! Looks good to me for
implementation. (Some minor issues and rebasing will be addressed by me.)
About docs, I meant we
astralidea created FLINK-3644:
-
Summary: WebRuntimMonitor set java.io.tmpdir does not work for
change upload dir.
Key: FLINK-3644
URL: https://issues.apache.org/jira/browse/FLINK-3644
Project: Flink
GitHub user Astralidea opened a pull request:
https://github.com/apache/flink/pull/1824
[FLINK-3644] WebRuntimMonitor set java.io.tmpdir does not work
To fix this issue, I think we should add new config to config flink-web
temp dir.
I don't know why java.io.tmpdir does not
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1814
---
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
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1814#issuecomment-199640748
Merging...
---
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
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205848#comment-15205848
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205811#comment-15205811
]
ASF GitHub Bot commented on FLINK-3631:
---
Github user ramkrish86 commented on the pull request:
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1823#issuecomment-199641069
I have done the update @fhueske .Thanks for the review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Vasia Kalavri created FLINK-3640:
Summary: Add support for SQL queries in DataSet programs
Key: FLINK-3640
URL: https://issues.apache.org/jira/browse/FLINK-3640
Project: Flink
Issue Type:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1814#issuecomment-199277732
+1 to merge
---
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
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1792#issuecomment-199286958
Thanks alot for updating the pull request.
I'm sorry that I have some more comments. We are approaching a mergable
state :)
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204205#comment-15204205
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204206#comment-15204206
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user alkagin commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56797459
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/HistogramBasedWatermarkEmitter.java
---
@@ -0,0 +1,263 @@
+/*
Vasia Kalavri created FLINK-3639:
Summary: Add methods and utilities to register DataSets and Tables
in the TableEnvironment
Key: FLINK-3639
URL: https://issues.apache.org/jira/browse/FLINK-3639
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1792#discussion_r56822903
--- Diff: flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml
---
@@ -0,0 +1,88 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204196#comment-15204196
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user rmetzger commented on a diff in the pull
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56823697
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java
---
@@ -0,0 +1,197 @@
+/**
+ *
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56825317
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java
---
@@ -0,0 +1,197 @@
+/**
+ *
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204224#comment-15204224
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user alkagin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204227#comment-15204227
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1792#discussion_r56823123
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
[
https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204226#comment-15204226
]
Aljoscha Krettek commented on FLINK-3624:
-
That might be an option, yes. Any other opinions on
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-199298767
Just pushed the following changes:
* Fixed AT_LEAST_ONCE type
* CassandraInputFormat.close properly propagates exceptions in close()
* cassandra pom now uses
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204229#comment-15204229
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user kl0u commented on the pull request:
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-199299432
Thanks a lot @rmetzger and @mxm for the comments. I integrated them.
Please review and let me know if there is anything missing.
---
If your project is set up for it,
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1690#issuecomment-199316872
Let me summarize the change:
```
auto.commit.enable=true checkpointing=trueoffsets go to ZK/Broker on
each completed checkpoint
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204353#comment-15204353
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user rmetzger commented on the pull request:
Till Rohrmann created FLINK-3641:
Summary: Document registerCachedFile API call
Key: FLINK-3641
URL: https://issues.apache.org/jira/browse/FLINK-3641
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204203#comment-15204203
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204200#comment-15204200
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204201#comment-15204201
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1792#discussion_r56823244
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1792#discussion_r56823183
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56825863
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java
---
@@ -0,0 +1,197 @@
+/**
+ *
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-2314:
-
Assignee: Kostas Kloudas (was: Sheetal Parade)
> Make Streaming File Sources Persistent
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204337#comment-15204337
]
Roy Ben-Alta commented on FLINK-3211:
-
Hi,
Is there any ETA for releasing the connector?
> Add AWS
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3639:
Assignee: Vasia Kalavri
> Add methods and utilities to register DataSets and Tables in the
Till Rohrmann created FLINK-3642:
Summary: Disentangle ExecutionConfig
Key: FLINK-3642
URL: https://issues.apache.org/jira/browse/FLINK-3642
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204217#comment-15204217
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203997#comment-15203997
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1764#discussion_r56802763
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/FixedAllowedLatenessWatermarkEmitter.java
---
@@ -0,0 +1,84 @@
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203996#comment-15203996
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user rmetzger commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1818#discussion_r56803957
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -109,22 +113,22 @@
private
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204008#comment-15204008
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204025#comment-15204025
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user alkagin commented on the pull request:
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56807419
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204063#comment-15204063
]
ASF GitHub Bot commented on FLINK-3179:
---
GitHub user ramkrish86 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203939#comment-15203939
]
Fabian Hueske commented on FLINK-3179:
--
Yes, would be great if you could open a PR to add the WARN
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1818#discussion_r56804605
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -109,22 +113,22 @@
private
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204013#comment-15204013
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user rmetzger commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56797109
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/HistogramBasedWatermarkEmitter.java
---
@@ -0,0 +1,263 @@
+/*
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1575#issuecomment-199211011
I'll merge this today.
---
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
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1818#discussion_r56803053
--- Diff: flink-core/src/main/java/org/apache/flink/util/UserCodeValue.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204000#comment-15204000
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1818#discussion_r56803087
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -499,7 +514,7 @@ else if (current ==
GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/1822
FLINK-3179 - Adding just a log message
As suggested in the JIRA, just adding a log message indicating to add an
combiner function before the partition operator.
You can merge this pull request
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1791#issuecomment-199192415
I rebased the change to the latest master.
I'm currently discussing with the author of the maven plugin if we can make
it accept the removal of the `Key` interface.
[
https://issues.apache.org/jira/browse/FLINK-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203942#comment-15203942
]
ASF GitHub Bot commented on FLINK-3129:
---
Github user rmetzger commented on the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56798327
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/HistogramBasedWatermarkEmitter.java
---
@@ -0,0 +1,263 @@
+/*
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56799181
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/HistogramBasedWatermarkEmitter.java
---
@@ -0,0 +1,263 @@
+/*
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1764#discussion_r56802608
--- Diff: docs/apis/streaming/event_timestamps_watermarks.md ---
@@ -308,6 +269,72 @@ class TimeLagWatermarkGenerator extends
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204047#comment-15204047
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user alkagin commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1819#discussion_r56796600
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/HistogramBasedWatermarkEmitter.java
---
@@ -0,0 +1,263 @@
+/*
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1819#issuecomment-199213661
After an offline discussion with @rmetzger and @kl0u, we have concluded
that it would be important to have an histogram whose bucket size can
dynamically adapt to
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-199219824
Once the false comments have been fixed, the change is good to merge IMO.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204001#comment-15204001
]
ASF GitHub Bot commented on FLINK-3633:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204584#comment-15204584
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204550#comment-15204550
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204560#comment-15204560
]
Aljoscha Krettek commented on FLINK-3399:
-
Hi [~shikhar] I opened FLINK-3643 as an umbrella issue
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56854368
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/standalone/HeartbeatMessage.java
---
@@ -0,0 +1,60 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204566#comment-15204566
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 175 matches
Mail list logo
