[
https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544170#comment-15544170
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4722 at 10/4/16 7:41 AM:
---
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
Repo
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
[
https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544816#comment-15544816
]
ASF GitHub Bot commented on FLINK-4730:
---
GitHub user StefanRRichter opened a pull re
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 v
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 Type
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544829#comment-15544829
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issu
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 restore
[
https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544833#comment-15544833
]
ASF GitHub Bot commented on FLINK-4731:
---
GitHub user StefanRRichter opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544834#comment-15544834
]
ASF GitHub Bot commented on FLINK-4727:
---
GitHub user tzulitai 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: Bug
[
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
http://pyx4j.com/pyx4j-maven-plugins/mave
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 featur
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 cent
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544871#comment-15544871
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544874#comment-15544874
]
Timo Walther commented on FLINK-4604:
-
Hi [~anmu],
1. Yes, the test should look like t
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. T
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544909#comment-15544909
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
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 of
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544916#comment-15544916
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on the issue:
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-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544936#comment-15544936
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user uce commented on the issue:
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: Improve
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2567
---
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-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544954#comment-15544954
]
ASF GitHub Bot commented on FLINK-3656:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544960#comment-15544960
]
Melmoth commented on FLINK-4724:
Hi [~eronwright],
makes sense, that way always the log4j
[
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-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4731:
--
Summary: HeapKeyedStateBackend restoring broken for scale-in (was:
HeapKeyedStateBackend restor
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'` t
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544993#comment-15544993
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr 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
[FLINK-4713](https://issues.apache.org/j
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545063#comment-15545063
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user gaborhermann commented on the i
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 do
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545093#comment-15545093
]
ASF GitHub Bot commented on FLINK-4728:
---
Github user StephanEwen commented on the is
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 this
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545101#comment-15545101
]
ASF GitHub Bot commented on FLINK-4709:
---
Github user StephanEwen commented on the is
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545247#comment-15545247
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user asfgit closed the pull request
[
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 an
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 an
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545286#comment-15545286
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user twalthr commented on the issue:
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545344#comment-15545344
]
ASF GitHub Bot commented on FLINK-4546:
---
Github user asfgit closed the pull request
[
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 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&focusedCommentId=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 so,
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545385#comment-15545385
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545390#comment-15545390
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user asfgit closed the pull request
[
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: a31a22ec7f
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: Improveme
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 th
[
https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545403#comment-15545403
]
ASF GitHub Bot commented on FLINK-4732:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545404#comment-15545404
]
Fabian Hueske commented on FLINK-4311:
--
Merged for Flink 1.1 as 98b399d4b4ddc9ab5d01e
[
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 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 lis
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545423#comment-15545423
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the issue
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 Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545473#comment-15545473
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
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-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545483#comment-15545483
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545557#comment-15545557
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issu
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 hav
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
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
po
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545579#comment-15545579
]
ASF GitHub Bot commented on FLINK-4510:
---
Github user StefanRRichter commented on the
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81776392
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81777101
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java
---
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache S
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 Soft
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 Apache
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81781081
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545636#comment-15545636
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545632#comment-15545632
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81779541
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545633#comment-15545633
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545634#comment-15545634
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545637#comment-15545637
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545635#comment-15545635
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2588
[FLINK-4735] [cluster management] Migrate some job execution related akka
messages to rpc calls
This includes the following operations about job execution:
1. checkpointing
2. kvstate
[
https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545661#comment-15545661
]
ASF GitHub Bot commented on FLINK-4735:
---
GitHub user KurtYoung opened a pull request
Greg Hogan created FLINK-4736:
-
Summary: Don't duplicate fields in Ordering
Key: FLINK-4736
URL: https://issues.apache.org/jira/browse/FLINK-4736
Project: Flink
Issue Type: Improvement
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81787458
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
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 S
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545783#comment-15545783
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545784#comment-15545784
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2002
Sorry for the delay. This looks good to me, let's merge it and add further
changes separately.
Will merge this...
---
If your project is set up for it, you can reply to this email and h
Stephan Ewen created FLINK-4737:
---
Summary: Add more compression algorithms to FileInputFormat
Key: FLINK-4737
URL: https://issues.apache.org/jira/browse/FLINK-4737
Project: Flink
Issue Type: Im
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81797332
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545884#comment-15545884
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545908#comment-15545908
]
ASF GitHub Bot commented on FLINK-3932:
---
GitHub user vijikarthi opened a pull reques
GitHub user vijikarthi opened a pull request:
https://github.com/apache/flink/pull/2589
FLINK-3932 State Backend Security
This PR addresses ZK authorization (ACLs) requirement of FLINK-3932 and its
dependency FLINK-4667 (Yarn session CLI not using correct ZK namespace in
secure env
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2580
Looks quite good. I would suggest one change, though:
Can we avoid copying the offsets in the checkpoint into a new map (with
increment by one) and passing that to the ZooKeeper Offset Co
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545989#comment-15545989
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user StephanEwen commented on the is
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 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 Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15546155#comment-15546155
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
1 - 100 of 129 matches
Mail list logo
