[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14623099#comment-14623099
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-120554092
If I get 1 more LGTM, I'll 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
[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622813#comment-14622813
]
ASF GitHub Bot commented on FLINK-2138:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-120506018
Looks good to merge. If no objections, I will merge it tomorrow. :+1:
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/904
[FLINK-2218] Web client cannot distinguesh between Flink options and
program arguments
added new input fields 'options' to WebClient
adapted WebClient-to-JobManager job submission logic
updated
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622775#comment-14622775
]
ASF GitHub Bot commented on FLINK-2218:
---
GitHub user mjsax opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2218:
---
Description:
WebClient has only one input field for arguments. This field is used for Flink
o
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2218:
---
Summary: Web client cannot distinguesh between Flink options and program
arguments (was: Web
[
https://issues.apache.org/jira/browse/FLINK-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622669#comment-14622669
]
ASF GitHub Bot commented on FLINK-2337:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/903#issuecomment-120479371
Travis failed due to unrelated error:
Failed tests:
ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFa
Stephan Ewen created FLINK-2344:
---
Summary: Deprecate/Remove the old Pact Pair type
Key: FLINK-2344
URL: https://issues.apache.org/jira/browse/FLINK-2344
Project: Flink
Issue Type: Improvement
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120460741
I've addressed your comments in a new commit.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622590#comment-14622590
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on the pull reque
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/903
[FLINK-2337] Multiple SLF4J bindings using Storm compatibility layer
exclude logback from Storm dependencies
You can merge this pull request into a Git repository by running:
$ git pull https://gi
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/902
[FLINK-2108] [ml] [WIP] Add score function for Predictors
This PR build upon the evaluation PR currently under review (#871) and adds
to new operations to the Predictor class, one that takes a scor
[
https://issues.apache.org/jira/browse/FLINK-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622407#comment-14622407
]
ASF GitHub Bot commented on FLINK-2337:
---
GitHub user mjsax opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622406#comment-14622406
]
ASF GitHub Bot commented on FLINK-2108:
---
GitHub user thvasilo opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2328.
-
Resolution: Duplicate
This issue will be solved by this:
https://issues.apache.org/jira/browse/FLINK-2335
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/901
[FLINK-2343] [scripts] Make CMS the default GC for streaming setups
When the system is started with `start-cluster-streaming.sh`, this patch
sets the Garbage Collector to "Concurrent Mark Sweep",
[
https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622388#comment-14622388
]
ASF GitHub Bot commented on FLINK-2343:
---
GitHub user StephanEwen opened a pull reque
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-120423639
Looks very neat!
---
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 fe
Stephan Ewen created FLINK-2343:
---
Summary: Change default garbage collector in streaming environments
Key: FLINK-2343
URL: https://issues.apache.org/jira/browse/FLINK-2343
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622381#comment-14622381
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user aalexandrov commented on the pu
Github user senorcarbone commented on a diff in the pull request:
https://github.com/apache/flink/pull/900#discussion_r34359293
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
---
@@ -201
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622359#comment-14622359
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/895#issuecomment-120421266
:+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 have this feature
enabled an
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/900#discussion_r34357746
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
---
@@ -201,14 +2
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622276#comment-14622276
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-120411775
Hi, I updated PR :)
---
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-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622264#comment-14622264
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-120408249
Changes applied:
- renamed signal name from TERMINATE to STOP (as decided by community vote)
- reverted changes to execution graph state machine
- added interface
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/900#issuecomment-120405183
There are quite a few changes in this PR! In general I am very keen to
eliminating DataStream "mutations" and adding that logic into the jobgraph
building phase. The
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-120404920
You can use this PR for the exact computation, no need to open a new one!
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622253#comment-14622253
]
ASF GitHub Bot commented on FLINK-2310:
---
Github user vasia commented on the pull req
Github user senorcarbone commented on a diff in the pull request:
https://github.com/apache/flink/pull/900#discussion_r34352021
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
---
@@ -201
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622248#comment-14622248
]
Fabian Hueske commented on FLINK-2106:
--
Having a working outer join algorithm (FLINK-
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622235#comment-14622235
]
Johann Kovacs commented on FLINK-2106:
--
[~r-pogalz] and I would like to start working
[
https://issues.apache.org/jira/browse/FLINK-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622166#comment-14622166
]
ASF GitHub Bot commented on FLINK-2328:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/900
Make streaming iterations more robust
This PR reworks the way iterations are constructed in the streamgraph from
the previous eager approach to do it when we actually create the jobgraph.
Thi
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/897
---
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 enabl
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/897#issuecomment-120384704
Merging...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
e
[
https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622107#comment-14622107
]
ASF GitHub Bot commented on FLINK-2310:
---
Github user shghatge commented on the pull
Github user shghatge commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-120366455
Hello @vasia
Thanks for the clarification. I was only thinking of changing the data
structure :) But this method seems much more sensible. In any case... Should I
c
[
https://issues.apache.org/jira/browse/FLINK-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622075#comment-14622075
]
ASF GitHub Bot commented on FLINK-2342:
---
GitHub user thvasilo opened a pull request:
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/899
[FLINK-2342] [ml] Add new fit operation and more tests for StandardScaler
StandardScaler currently has a transform operation for types (Vector,
Double), but no corresponding fit operation.
Theodore Vasiloudis created FLINK-2342:
--
Summary: Add new fit operation and more tests for StandardScaler
Key: FLINK-2342
URL: https://issues.apache.org/jira/browse/FLINK-2342
Project: Flink
Github user samk3211 closed the pull request at:
https://github.com/apache/flink/pull/898
---
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 ena
GitHub user samk3211 opened a pull request:
https://github.com/apache/flink/pull/898
[Flink-gelly] Added local clustering coefficient (for directed graph) exaâ¦
â¦mple in the tutorialExamples subfolder.
You can merge this pull request into a Git repository by running:
$ git p
[
https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622039#comment-14622039
]
ASF GitHub Bot commented on FLINK-2310:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-120319905
Hi @shghatge!
I agree, let's deal with the approximate version as a separate issue. In
the end though, it would be nice to have a single library method and an input
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14622010#comment-14622010
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120305327
The reporter object has the advantage that it is more easily extensible. At
some point we will want to differentiate between locally received bytes, and
remotely rece
[
https://issues.apache.org/jira/browse/FLINK-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2339.
---
> Prevent asynchronous checkpoint calls from overtaking each other
> -
[
https://issues.apache.org/jira/browse/FLINK-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2339.
-
Resolution: Fixed
Fixed in cbde2c2a3d71e17990d76d603e1bb6d275c888be
> Prevent asynchronous checkp
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621997#comment-14621997
]
Stephan Ewen commented on FLINK-2293:
-
No worries, just glad the bug is fixed :-)
> D
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621992#comment-14621992
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120302065
> Looks like this change breaks the YARN integration. The YARN WordCount no
longer works.
Should be working again now.
> It would be good if the accumulator
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu resolved FLINK-2293.
Resolution: Fixed
Sorry for reopening it when it was already fixed. Never hurts to make sure that
i
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621986#comment-14621986
]
Andra Lungu commented on FLINK-2293:
Hi [~StephanEwen],
Thank you for your patience.
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335963
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621981#comment-14621981
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621977#comment-14621977
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621978#comment-14621978
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335824
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -131,6 +133,35 @@
private SerializedValue> op
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335830
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -172,13 +173,20 @@
/** The library cache, from which the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335420
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1017,6 +1040,9 @@ object TaskManager {
val HEAR
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621969#comment-14621969
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621967#comment-14621967
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621965#comment-14621965
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335345
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/StreamingAbstractRecordReader.java
---
@@ -57,6 +
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335337
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -172,13 +173,20 @@
/** The library cache, from which the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335380
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -306,99 +308,100 @@ extends Actor with ActorLogMessages with
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335330
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java
---
@@ -212,19 +218,19 @@ public InputGate getInputGate(int ind
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335342
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -237,12 +246,13 @@ public Task(TaskDeploymentDescriptor tdd,
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621964#comment-14621964
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621962#comment-14621962
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34335325
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
---
@@ -60,6 +60,7 @@ public static void main(S
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621961#comment-14621961
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621963#comment-14621963
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user mxm commented on a diff in the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/897#issuecomment-120279506
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
en
[
https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621938#comment-14621938
]
ASF GitHub Bot commented on FLINK-2180:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/802#issuecomment-120276079
I am currently preparing a new PR with a rework of how the iterations are
constructed in the StreamGraph it will be ready today. It will solve many
issues that we currentl
82 matches
Mail list logo
