Steffen Hausmann created FLINK-4739:
---
Summary: Adding packaging details for the Elasticsearch connector
Key: FLINK-4739
URL: https://issues.apache.org/jira/browse/FLINK-4739
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546360#comment-15546360
]
ASF GitHub Bot commented on FLINK-4734:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2590
I think that makes a lot of sense!
---
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-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546359#comment-15546359
]
Greg Hogan commented on FLINK-4735:
---
Apologies for sending the PR for FLINK-4734 to this ticket. I
Greg Hogan created FLINK-4740:
-
Summary: Upgrade testing libraries
Key: FLINK-4740
URL: https://issues.apache.org/jira/browse/FLINK-4740
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546531#comment-15546531
]
ASF GitHub Bot commented on FLINK-4729:
---
Github user vasia commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2578
I think this is good. Merging 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
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546343#comment-15546343
]
ASF GitHub Bot commented on FLINK-4730:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2583#discussion_r81829124
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2583#discussion_r81829995
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546342#comment-15546342
]
ASF GitHub Bot commented on FLINK-4730:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546354#comment-15546354
]
ASF GitHub Bot commented on FLINK-4739:
---
Github user StephanEwen commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2587
Great cleanup! Thanks @greghogan. +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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2591
This is very helpful, thanks!
Merging 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
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546239#comment-15546239
]
ASF GitHub Bot commented on FLINK-4739:
---
GitHub user sthm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546155#comment-15546155
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81816707
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546180#comment-15546180
]
ASF GitHub Bot commented on FLINK-4735:
---
GitHub user greghogan opened a pull request:
Till Rohrmann created FLINK-4738:
Summary: Port TaskManager logic to TaskExecutor
Key: FLINK-4738
URL: https://issues.apache.org/jira/browse/FLINK-4738
Project: Flink
Issue Type: Sub-task
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2590
[FLINK-4735] [gelly] Remove use of Tuple setField for fixed position
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
GitHub user sthm opened a pull request:
https://github.com/apache/flink/pull/2591
[FLINK-4739] Adding packaging details for the Elasticsearch connector
When an uber-jar containing an Elasticsearch sink is executed, an
IllegalArgumentException may occur, which is caused by
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Component/s: Webfrontend
> WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups)
Joseph Sims created FLINK-4741:
--
Summary: WebRuntimeMonitor does not shut down all of it's threads
(EventLoopGroups) on exit.
Key: FLINK-4741
URL: https://issues.apache.org/jira/browse/FLINK-4741
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Priority: Minor (was: Major)
> WebRuntimeMonitor does not shut down all of it's threads
[
https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Sims updated FLINK-4741:
---
Component/s: (was: Core)
> WebRuntimeMonitor does not shut down all of it's threads
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2586
Thanks! It's good to address this. I really liked the symbolic link, maybe
we can enable it again after this has been resolved by the Maven plugin.
+1 to merge this to `master` and `release-1.1`
[
https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4731:
--
Summary: HeapKeyedStateBackend restoring broken for scale-in (was:
HeapKeyedStateBackend
[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 7:41 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544936#comment-15544936
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user uce commented on the issue:
Stefan Richter created FLINK-4730:
-
Summary: Introduce CheckpointMetaData
Key: FLINK-4730
URL: https://issues.apache.org/jira/browse/FLINK-4730
Project: Flink
Issue Type: Bug
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2583
[FLINK-4730] Introduce checkpoint meta data
Currently, the meta data for each checkpoint consists of up to 5 long
values which are passed through several functions. When adding/removing meta
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2585
[FLINK-4727] [kafka-connector] Set missing initial offset states with
starting KafkaConsumer position
This was fixed for the 0.8 consumer before. This PR adds the behaviour to
the 0.9 consumer.
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2584
[FLINK-4731] Bugfix for HeapKeyedStateBackend scale-in and additional tests
in RescalingITCase
Restoring the HeapKeyedStateBackend was broken in case that parallelism is
reduced. The
[
https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544833#comment-15544833
]
ASF GitHub Bot commented on FLINK-4731:
---
GitHub user StefanRRichter opened a pull request:
Maximilian Michels created FLINK-4732:
-
Summary: Maven junction plugin security threat
Key: FLINK-4732
URL: https://issues.apache.org/jira/browse/FLINK-4732
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544870#comment-15544870
]
ASF GitHub Bot commented on FLINK-4732:
---
GitHub user mxm opened a pull request:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2586
CC @uce
---
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
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2330
Hi @nielsbasjes, I just posted to the dev mailinglist and proposed to
update the HBase dependency to 1.2.3 (as
[FLINK-2765](https://issues.apache.org/jira/browse/FLINK-2765) suggests). By
the end
Chesnay Schepler created FLINK-4733:
---
Summary: Port WebFrontend to new metric system
Key: FLINK-4733
URL: https://issues.apache.org/jira/browse/FLINK-4733
Project: Flink
Issue Type:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
@greghogan @vasia I've update the code according to your suggestion.
The only thing that I did differently: I return Tuple4 from a more complete
version of a bottom/top projections it contains
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544829#comment-15544829
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issue:
Stefan Richter created FLINK-4731:
-
Summary: HeapKeyedStateBackend restorig broken for scale-in
Key: FLINK-4731
URL: https://issues.apache.org/jira/browse/FLINK-4731
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4730:
--
Component/s: State Backends, Checkpointing
> Introduce CheckpointMetaData
>
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2571
@KurtYoung I see, that makes sense. When the TM looses connection to the
RM, it will eventually be detected by the heartbeating and the list of pending
slot allocation removal requests will be cleared.
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544816#comment-15544816
]
ASF GitHub Bot commented on FLINK-4730:
---
GitHub user StefanRRichter opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544834#comment-15544834
]
ASF GitHub Bot commented on FLINK-4727:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4732:
--
Description:
We use the Maven Junction plugin
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544916#comment-15544916
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544954#comment-15544954
]
ASF GitHub Bot commented on FLINK-3656:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4730:
-
Assignee: Stefan Richter
> Introduce CheckpointMetaData
>
>
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544874#comment-15544874
]
Timo Walther commented on FLINK-4604:
-
Hi [~anmu],
1. Yes, the test should look like the one in your
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2586
[FLINK-4732] remove maven junction plugin
On Windows, the plugin may download code from the author's web
site. The downloaded file is not signed in the same way as Maven
artifacts from Maven
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544871#comment-15544871
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544909#comment-15544909
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544960#comment-15544960
]
Melmoth commented on FLINK-4724:
Hi [~eronwright],
makes sense, that way always the log4j.properties is
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545286#comment-15545286
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4068.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in a71133945e66ec471b4cb07da0693d545c40923c
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545344#comment-15545344
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4546.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 72e6b760fd951764c3ecc6fc191dc99a42d55e0b.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2454
---
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
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545385#comment-15545385
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545247#comment-15545247
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2560
---
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 twalthr commented on the issue:
https://github.com/apache/flink/pull/2454
Thanks @wuchong. Will 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
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2587
[FLINK-4729] [gelly] Use optional VertexCentric CombineFunction
Passes through the CombineFunction to VertexCentricIteration, and other
code cleanup discovered via IntelliJ's code analyzer.
You
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545351#comment-15545351
]
ASF GitHub Bot commented on FLINK-4729:
---
GitHub user greghogan opened a pull request:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2586
Merging to both branches.
---
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 StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2582
Thanks, this is a great set of cleanups and fixes. Merging 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
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2560
@wuchong I heavily tested this PR again as it could introduce difficult
bugs. And I also found one issue that needs to be discussed. If you have an
expression like `CAST(TRUE AS VARCHAR) || 'Test'`
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545063#comment-15545063
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user gaborhermann commented on the issue:
Github user gaborhermann commented on the issue:
https://github.com/apache/flink/pull/1849
Hi all,
What is the status of this PR?
It would be relevant for us, because we might like to use the evaluation
framework proposed here. See
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545093#comment-15545093
]
ASF GitHub Bot commented on FLINK-4728:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2581
Good fix, thanks a lot!
Merging 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
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545101#comment-15545101
]
ASF GitHub Bot commented on FLINK-4709:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544993#comment-15544993
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545404#comment-15545404
]
Fabian Hueske commented on FLINK-4311:
--
Merged for Flink 1.1 as
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2586
Merged to `master` and `release-1.1`.
@uce I also like the symbolic link. I contacted the maintainer of the
plugin because it wouldn't be hard to fix this nowadays with Java 7+ which
supports
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545403#comment-15545403
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/1849
@gaborhermann In terms of missing features, documentation is definitely
missing, as @rawkintrevo mentioned.
For the issues mentioned in the JIRA issue you linked I've replied on the
dev
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2564
The advantage to joining on vertex values before the grouped cross is that
the number of projected vertices is quadratic in the vertex degree. The
projected graphs will usually be much larger than
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4732.
-
Resolution: Fixed
master: 5a573c6bc29c313d34981336d5bfc05185d323d2
release-1.1:
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545390#comment-15545390
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user asfgit closed the pull request at:
Greg Hogan created FLINK-4734:
-
Summary: Remove use of Tuple setField for fixed position
Key: FLINK-4734
URL: https://issues.apache.org/jira/browse/FLINK-4734
Project: Flink
Issue Type:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2586
---
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
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545423#comment-15545423
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545483#comment-15545483
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545557#comment-15545557
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4311:
-
Fix Version/s: 1.1.3
> TableInputFormat fails when reused on next split
>
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81764640
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545473#comment-15545473
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff in the pull
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
Hi @greghogan. Thank you for clarification. I'll update code accordingly.
Do you have any other comments regarding the PR?
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15547157#comment-15547157
]
Neelesh Srinivas Salian commented on FLINK-4260:
Hey [~miaoever], do you have a chance to
Kurt Young created FLINK-4735:
-
Summary: Migrate some job execution related akka messages to rpc
calls
Key: FLINK-4735
URL: https://issues.apache.org/jira/browse/FLINK-4735
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545661#comment-15545661
]
ASF GitHub Bot commented on FLINK-4735:
---
GitHub user KurtYoung opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545783#comment-15545783
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81787532
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java
---
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2453
Thanks for the nice contribution.
I see one minor detail that could cause problems. Even if we do not
register the `CheckpointCoordinator` as `JobStatusListener`, it might still be
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545579#comment-15545579
]
ASF GitHub Bot commented on FLINK-4510:
---
Github user StefanRRichter commented on the issue:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81780392
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Projection.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81781488
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
1 - 100 of 127 matches
Mail list logo
