Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2467
Hi @StephanEwen
All images are coming from this repo:
https://github.com/nathancahill/Split.js
It has a very permissive license:
https://github.com/nathancahill/Split.js/blob/master/L
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512390#comment-15512390
]
Ivan Mushketyk commented on FLINK-4641:
---
Hi [~kervel]
I think the method chaining w
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512350#comment-15512350
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 closed the pull request at
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512351#comment-15512351
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin updated FLINK-4564:
Comment: was deleted
(was: Not all clear.
How should look like {{MetricGroup#getMetricIdentifier()}}
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512352#comment-15512352
]
ASF GitHub Bot commented on FLINK-4564:
---
GitHub user ex00 reopened a pull request:
GitHub user ex00 reopened a pull request:
https://github.com/apache/flink/pull/2517
[FLINK-4564] [metrics] Delimiter should be configured per reporter
Hi
It is my fix FLINK-4564. I want fix this issue, please send me your
comments about this implementation.
I could assign to
Github user ex00 closed the pull request at:
https://github.com/apache/flink/pull/2517
---
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 enable
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
Not all clear.
How should look like `MetricGroup#getMetricIdentifier()`call in this case?
If we use single reporter for other reporters and know their indexes, we
must know name or index where w
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512181#comment-15512181
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
I agree with @delding here.
>* Method that does a batch call on Deletes, Gets, Puts, Increments and
Appends.
* The ordering of execution of the actions is not defined. Meaning
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512173#comment-15512173
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
` #2330 updates the version of the batch TableInputFormat to HBase 1.1.2. I
think we should use the same version here.`
Valid point. But is it possible to upgrade to even newer version like 1.1
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
I can change back to HBase 1.1.2. The reason of using 2.0.0-SNAPSHOT is
because this bug (https://issues.apache.org/jira/browse/HBASE-14963 ). It's
only fixed for version 1.3.0+ and 2.0.0 and my exam
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511953#comment-15511953
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511945#comment-15511945
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi @fhueske , in HBase writes to a single row have ACID guarantee. The
exactly once semantic can be implemented the way CassandraSink did, storing
input records in a state backend and flushing to HBa
[
https://issues.apache.org/jira/browse/FLINK-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511396#comment-15511396
]
ASF GitHub Bot commented on FLINK-4494:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2532
[FLINK-4494] Expose the TimeServiceProvider from the Task to each Operator.
This is a PR for both [FLINK-4496] and [FLINK-4494].
R: @aljoscha
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15511311#comment-15511311
]
Nagarjun Guraja commented on FLINK-4650:
[~StephanEwen] I haven't spent lot of tim
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Attachment: Screen Shot 2016-09-20 at 2.49.32 PM.png
Screen Shot 2016-09-20 at 2.49.1
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
[
https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4660:
Description:
Flink job with checkpoints enabled and configured to use S3A file system
backend, some
Zhenzhong Xu created FLINK-4660:
---
Summary: HadoopFileSystem (with S3A) may leak connections, which
cause job to stuck in a restarting loop
Key: FLINK-4660
URL: https://issues.apache.org/jira/browse/FLINK-4660
Ted Yu created FLINK-4659:
-
Summary: Potential resource leak due to unclosed InputStream in
SecurityContext#populateSystemSecurityProperties()
Key: FLINK-4659
URL: https://issues.apache.org/jira/browse/FLINK-4659
[
https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510703#comment-15510703
]
ASF GitHub Bot commented on FLINK-4248:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2303
I still think that methods should be named after what they do (and there is
nothing numeric about their behavior) and not in which context they are
supposed to be called. The error messages are numer
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2479
Thank you for the pull request! I've rebased the changes and will merge
them to the master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510670#comment-15510670
]
ASF GitHub Bot commented on FLINK-4537:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510680#comment-15510680
]
Fabian Hueske commented on FLINK-4506:
--
I'm not sure about that. The CsvInputFormat s
[
https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510667#comment-15510667
]
ASF GitHub Bot commented on FLINK-4535:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2451
Thank you for the pull request! I've rebased the changes and will merge
them to the master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510589#comment-15510589
]
Michael Wong commented on FLINK-4506:
-
Ok, but let's forget about what was there befor
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2531
---
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-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4658.
Resolution: Fixed
Fixed via b5f6a06b01436a8b0e7243e3f8af7444f8058868
> Allow RpcService to execute
[
https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510460#comment-15510460
]
ASF GitHub Bot commented on FLINK-4658:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510452#comment-15510452
]
ASF GitHub Bot commented on FLINK-4658:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2531
Thanks for the review @mxm. Will merge it.
---
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 feat
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2531
+1 Looks good!
---
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
[
https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510440#comment-15510440
]
ASF GitHub Bot commented on FLINK-4658:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510429#comment-15510429
]
ASF GitHub Bot commented on FLINK-4656:
---
Github user tillrohrmann closed the pull re
[
https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4656.
Resolution: Fixed
Fixed via 31a091b930178bf2aec2881ee273fe0e5e17464d
> Port existing code to use Fl
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2530
---
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-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510423#comment-15510423
]
ASF GitHub Bot commented on FLINK-4656:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2530
Will merge the PR since it's prone to merge conflicts.
---
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 ha
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2531
[FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in
its executor
The PR is based on #2530.
The newly introduced methods are `void RpcService.execute(Runnable)` an
[
https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510421#comment-15510421
]
ASF GitHub Bot commented on FLINK-4658:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946
]
Anton Mushin edited comment on FLINK-4564 at 9/21/16 4:10 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4645.
-
Resolution: Fixed
Fixed via 82ef021cb8f77635bcec61d49eedce1ddefd1e48
> Hard to register Kryo Seri
[
https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4645.
---
> Hard to register Kryo Serializers due to generics
> -
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2522
---
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-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4640.
---
> Serialization of the initialValue of a Fold on WindowedStream fails
> --
[
https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4640.
-
Resolution: Fixed
Fixed in
- 1.1.3 via 52a4440d916fb450c4999f6e1f42f392e247b426
- 1.2.0 via 4d
Till Rohrmann created FLINK-4658:
Summary: Allow RpcService to execute Callables in the RpcService
executor
Key: FLINK-4658
URL: https://issues.apache.org/jira/browse/FLINK-4658
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4651:
Fix Version/s: 1.2.0
> Re-register processing time timers at the WindowOperator upon recovery.
> ---
[
https://issues.apache.org/jira/browse/FLINK-4656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510296#comment-15510296
]
ASF GitHub Bot commented on FLINK-4656:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510313#comment-15510313
]
Aljoscha Krettek commented on FLINK-4616:
-
+1, I think this would be good to have.
[
https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510349#comment-15510349
]
ASF GitHub Bot commented on FLINK-4248:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2303
@fhueske I think we should keep the methods as they currently are. I
renamed them to "nextNumericString"/"nextNumericStringEndPos" and added a
explanation what a numeric string is. You are right they
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2530
[FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction
This pull request removes Scala's `Futures` from all new Flip-6 components
and replaces them with Flink's own `Future
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510291#comment-15510291
]
Frank Dekervel commented on FLINK-4641:
---
i think the second option would made it har
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r79854335
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -365,19 +364,6 @@ public Long getValue() {
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510265#comment-15510265
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r79858930
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/TimeProviderTest.java
---
@@ -0,0 +1,198 @@
+/*
+ * Licens
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r79854646
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -326,6 +322,9 @@ public Long getValue() {
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510266#comment-15510266
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510267#comment-15510267
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510268#comment-15510268
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r79854449
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -486,6 +472,9 @@ private void disposeAllOperato
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510269#comment-15510269
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r79853936
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -212,10 +212,6 @@ public void setTimeService(Ti
[
https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510252#comment-15510252
]
ASF GitHub Bot commented on FLINK-4241:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2529
[FLINK-4241] [table] Cryptic expression parser exceptions
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4657:
--
Description:
For flip-6, we will have ResourceManager and every JobManager as potential
leader contende
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2525
Thank you for the contribution @alpinegizmo.
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510200#comment-15510200
]
ASF GitHub Bot commented on FLINK-4654:
---
Github user greghogan commented on the issu
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2528
[FLINK-4643] [gelly] Average Clustering Coefficient
Questions:
- Can we generalize "average" to operator on a common interface (i.e.
"ScorableResult")? Here, the average clustering coefficient
[
https://issues.apache.org/jira/browse/FLINK-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510186#comment-15510186
]
ASF GitHub Bot commented on FLINK-4643:
---
GitHub user greghogan opened a pull request
Kurt Young created FLINK-4657:
-
Summary: Implement HighAvailabilityServices based on zookeeper
Key: FLINK-4657
URL: https://issues.apache.org/jira/browse/FLINK-4657
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510166#comment-15510166
]
ASF GitHub Bot commented on FLINK-4654:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2525
No worries. ð
---
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
[
https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4654.
-
Resolution: Implemented
Implemented in 7212202036235f41e376872dc268735ba9ef81e9
> clean up docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510155#comment-15510155
]
ASF GitHub Bot commented on FLINK-4654:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2525
---
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-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510153#comment-15510153
]
ASF GitHub Bot commented on FLINK-4654:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2525
Oh no! I just committed.
---
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 wishe
[
https://issues.apache.org/jira/browse/FLINK-4654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4654:
--
Fix Version/s: 1.2.0
> clean up docs
> -
>
> Key: FLINK-4654
>
[
https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510114#comment-15510114
]
ASF GitHub Bot commented on FLINK-4379:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2512
I think most of the proposed renames are good. One thing that would be good
to change is to remove `SnapshotProvider` and just have that method directly on
`OperatorStateBackend`.
I really
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510069#comment-15510069
]
ASF GitHub Bot commented on FLINK-4624:
---
GitHub user s1ck opened a pull request:
GitHub user s1ck opened a pull request:
https://github.com/apache/flink/pull/2527
[FLINK-4624] Allow for null values in Graph Summarization
* Bug was caused by serializers that cannot handle null values (e.g. Long)
* VertexGroupItem now uses Either instead of VV
* Generalized
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946
]
Anton Mushin commented on FLINK-4564:
-
Not all clear.
How should look like MetricGroup
[
https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509930#comment-15509930
]
ASF GitHub Bot commented on FLINK-4248:
---
Github user fhueske commented on a diff in
1 - 100 of 232 matches
Mail list logo