[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15065213#comment-15065213
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user rawkintrevo commented on the pu
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-165941576
I think I really screwed this up... I was just trying to undo the changes
to flink-staging/flink-ml/pom.xml
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064765#comment-15064765
]
ASF GitHub Bot commented on FLINK-3118:
---
GitHub user s1ck opened a pull request:
GitHub user s1ck opened a pull request:
https://github.com/apache/flink/pull/1471
[FLINK-3118] [Gelly] Consider ResultTypeQueryable in Message and
GatherFunction
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/s1ck/flink FLINK-3
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1470
Introduce RestartStrategy to decouple restarting behaviour from
ExecutionGraph
Disclaimer: This PR is based on PR #1468.
## Description
This PR decouples the restart behaviour
[
https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sebastian Klemke updated FLINK-3188:
Attachment: kafka-deletions.patch
Patch to LegacyFetcher to pass deletions on to Deserializa
Sebastian Klemke created FLINK-3188:
---
Summary: Deletes in Kafka source should be passed on to
KeyedDeserializationSchema
Key: FLINK-3188
URL: https://issues.apache.org/jira/browse/FLINK-3188
Project
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-165848516
Do we want to make the IOFormats Public as well?
Most of them are hidden by helper methods of the `ExecutionEnvironment`.
However, they can also be used as regular in
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064289#comment-15064289
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user fhueske commented on the pull r
Till Rohrmann created FLINK-3187:
Summary: Decouple restart strategy from ExecutionGraph
Key: FLINK-3187
URL: https://issues.apache.org/jira/browse/FLINK-3187
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064280#comment-15064280
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-165847905
Created a PR for `flink-java`.
**Summary**
Changed to Experimental:
- DataSink.sortLocalOutput (should be deprecated, IMO. See FLINK-3186)
- Dat
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064148#comment-15064148
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1465#issuecomment-165819420
I now use lazy vals for that.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064128#comment-15064128
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1465#issuecomment-165813593
I implemented your feedback. But I don't know if we should use `Option` for
the `deserializedKeyFields`, because we then need to add checks for each
serialized compariso
Fabian Hueske created FLINK-3186:
Summary: Deprecate DataSink.sortLocalOutput() methods
Key: FLINK-3186
URL: https://issues.apache.org/jira/browse/FLINK-3186
Project: Flink
Issue Type: Task
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1465#discussion_r48026706
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RowComparator.scala
---
@@ -0,0 +1,468 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063976#comment-15063976
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063961#comment-15063961
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1465#discussion_r48025862
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RowComparator.scala
---
@@ -0,0 +1,468 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063948#comment-15063948
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165780008
Ahhh sorry for my stupid comment. The actual config values didn't change.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165779642
I've created
https://docs.google.com/document/d/1987ydc2rez79Pph7qBbcXwu6XzMU2Hm-nX8kORLoZBM/edit?usp=sharing
and added the config renaming as an API breaking change. I will
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063947#comment-15063947
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063920#comment-15063920
]
Stephan Ewen commented on FLINK-2315:
-
I think this is pretty easy to fix.
The {{Writ
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063899#comment-15063899
]
Stephan Ewen commented on FLINK-3160:
-
I can of like that it shows all tasks when you
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063857#comment-15063857
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063855#comment-15063855
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165754886
The idea is to decouple the restart logic from the `JobManager` and to make
it configurable on a per job basis. Different strategies are conceivable. For
instance,
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-165754941
Olrite. :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063854#comment-15063854
]
ASF GitHub Bot commented on FLINK-3166:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1464#discussion_r48017305
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ObjectReuseITCase.java
---
@@ -124,26 +125,30 @@ public static String runProgr
[
https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063853#comment-15063853
]
ASF GitHub Bot commented on FLINK-3166:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3110:
-
Labels: requires-design-doc (was: )
> Add support for partition-centric iterations
>
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1464#issuecomment-165753852
Good catch. I think all of these changes look actually good.
Minor comment in-line, otherwise +1
---
If your project is set up for it, you can reply to this
Ufuk Celebi created FLINK-3185:
--
Summary: Silent failure during job graph recovery
Key: FLINK-3185
URL: https://issues.apache.org/jira/browse/FLINK-3185
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063847#comment-15063847
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-165752988
I'll merge this PR in the next days. If I find a minor issue on the way,
would fix it on the fly.
Thanks for the good work, @sachingoel0101
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063843#comment-15063843
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063844#comment-15063844
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165752782
What is the `RestartStrategy` about?
---
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 StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165752725
With upcoming Mesos integration (and some YARN refactoring), we can
probably drop the heartbeats between master and worker as well from Akka.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063839#comment-15063839
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user StephanEwen commented on the pu
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165752514
This is true. Might be a bit anticipated but I plan to remove them
completely with my next PR. I want to introduce a `RestartStrategy` which can
be set on a job bas
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063840#comment-15063840
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user tillrohrmann commented on the p
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165752418
I like having lower ask timeouts.
+1 from my side
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3182:
---
Priority: Minor (was: Major)
> TaskManagersHandler can block web frontend
> -
[
https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063832#comment-15063832
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-165750742
Good changes.
I like the configuration key changes, but we have to keep in mind that they
are API breaking. With 1.0 approaching, I think it's good to do the changes
[
https://issues.apache.org/jira/browse/FLINK-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063827#comment-15063827
]
Stephan Ewen commented on FLINK-3182:
-
I think this is a minor issue right now. Fixing
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1457
---
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-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063810#comment-15063810
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-165744791
@StephanEwen can you have a look at this again? Apologies for being hasty,
but I've already addressed all concerns; this should be mergeable now.
---
If your pro
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1457#discussion_r48012762
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
---
@@ -574,8 +574,11 @@ private static String
getEntryPointC
[
https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063797#comment-15063797
]
ASF GitHub Bot commented on FLINK-2716:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1462#discussion_r48012505
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -394,6 +396,21 @@ public long count() throws Exception {
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1466#issuecomment-165741781
Nice addition.
+1
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063795#comment-15063795
]
ASF GitHub Bot commented on FLINK-3180:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063792#comment-15063792
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1469#issuecomment-165740727
Thanks for the PR! I will shepherd 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 do
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063769#comment-15063769
]
ASF GitHub Bot commented on FLINK-7:
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1255#issuecomment-165732606
Range partitioning serves two purposes:
1. producing fully sorted results.
2. evenly balancing the load in case of skewed key distributions.
Producin
[
https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063754#comment-15063754
]
ASF GitHub Bot commented on FLINK-3180:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1466#issuecomment-165726928
@uce Sure. We can do that.
---
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-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063684#comment-15063684
]
Martin Junghanns commented on FLINK-2315:
-
Hi, is this hard to fix? I wanted to ap
66 matches
Mail list logo