Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-87967427
Thank you very much for the review Henry!
I addressed your feedback where applicable. I'll merge the change now.
---
If your project is set up for it, you can
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456302
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java ---
@@ -106,70 +111,129 @@ public FlinkYarnCluster(final YarnClient
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388140#comment-14388140
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456202
--- Diff:
flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
---
@@ -80,7 +80,7 @@ public String getExecutionPlan() throws
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388133#comment-14388133
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456299
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -265,12 +266,32 @@ protected int run(String[] args) {
}
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388138#comment-14388138
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388137#comment-14388137
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456233
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -89,15 +89,20 @@ public void setPrintStatusDuringExecution(boolean
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456244
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -569,15 +590,33 @@ protected int executeProgram(PackagedProgram
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388135#comment-14388135
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/542#discussion_r27456228
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CustomPartitioningGroupingTupleTest.scala
---
@@ -18,12 +18,12 @@
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1771.
---
Resolution: Fixed
Fix Version/s: 0.9
Implemented in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/542
---
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
Till Rohrmann created FLINK-1807:
Summary: Stochastic gradient descent optimizer for ML library
Key: FLINK-1807
URL: https://issues.apache.org/jira/browse/FLINK-1807
Project: Flink
Issue
Ufuk Celebi created FLINK-1806:
--
Summary: Improve S3 file system error message when no
access/secret key provided
Key: FLINK-1806
URL: https://issues.apache.org/jira/browse/FLINK-1806
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1806.
Resolution: Fixed
Fix Version/s: 0.9
Fixed in c0b2975.
Improve S3 file system error
[
https://issues.apache.org/jira/browse/FLINK-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388324#comment-14388324
]
ASF GitHub Bot commented on FLINK-1788:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/550
[FLINK-1788] [table] Make logical plans transformable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink flinq-mutable-plans
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/548#issuecomment-88071167
Looks good 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 vasia commented on the pull request:
https://github.com/apache/flink/pull/544#issuecomment-88062186
Hey @andralungu, I'm not sure I understand what's the problem with
reduceOnEdges and EmitOneEdgePerNode. Can you elaborate a little bit please?
Thanks :)
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388427#comment-14388427
]
ASF GitHub Bot commented on FLINK-1741:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388450#comment-14388450
]
ASF GitHub Bot commented on FLINK-1808:
---
GitHub user senorcarbone opened a pull
GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/551
[FLINK-1808] Send barrier requests only when the execution graph is running
This is a simple optimisation for the current StreamCheckpointCoordinator
that makes it skip barriers whent he
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1052:
--
Assignee: (was: Robert Metzger)
Access to stdout and log information of Taskmanagers from
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1052:
--
Component/s: Webfrontend
Access to stdout and log information of Taskmanagers from the web
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/544#issuecomment-88104306
Yes, actually that is the correct behavior imo.
I mean, if you have a directed edge [4, 5], 4 is the source and 5 is the
target and these should not be swapped.
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/539#issuecomment-88123548
I rebased the code on the current master and unified some of the tests.
When Travis confirms that everything works and if there are no objections, I'll
merge the PR.
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/542#issuecomment-88136878
Awesome!
---
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
Till Rohrmann created FLINK-1809:
Summary: Add standard scaler to ML library
Key: FLINK-1809
URL: https://issues.apache.org/jira/browse/FLINK-1809
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388671#comment-14388671
]
ASF GitHub Bot commented on FLINK-1718:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388616#comment-14388616
]
Theodore Vasiloudis commented on FLINK-1807:
I think it would make sense to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/546
---
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 hsaputra closed the pull request at:
https://github.com/apache/flink/pull/548
---
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-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388825#comment-14388825
]
ASF GitHub Bot commented on FLINK-1805:
---
Github user asfgit closed the pull request
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/548#issuecomment-88171159
I saw some error with certain branch names, will check it out and retry the
PR.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388720#comment-14388720
]
ASF GitHub Bot commented on FLINK-1771:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/511#issuecomment-88183433
LGTM. Will merge later today. Thanks!
---
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-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388971#comment-14388971
]
ASF GitHub Bot commented on FLINK-1766:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388912#comment-14388912
]
ASF GitHub Bot commented on FLINK-1766:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1766.
--
Resolution: Cannot Reproduce
committed to master. Thanks!
Fix the bug of equals function of
[
https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1805.
--
Resolution: Fixed
Merge to master. Thanks!
The class IOManagerAsync(in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/511
---
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 hsaputra commented on the pull request:
https://github.com/apache/flink/pull/552#issuecomment-88189532
Will push this EOD if no objection.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388506#comment-14388506
]
ASF GitHub Bot commented on FLINK-1794:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/540
---
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 andralungu commented on the pull request:
https://github.com/apache/flink/pull/544#issuecomment-88088234
Sure,
I thought it was obvious from the ugly if :)
In EmitOneEdgePerNode we have:
public void flatMap(EdgeK, EV edge, CollectorTuple2K, EdgeK, EV
[
https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-1794.
--
Resolution: Fixed
Fixed with b8aa49ce7d806c52183ab79c17c6024b60d0eaaf
Add test base for
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14389510#comment-14389510
]
ASF GitHub Bot commented on FLINK-1792:
---
GitHub user bhatsachin opened a pull
GitHub user bhatsachin opened a pull request:
https://github.com/apache/flink/pull/553
[FLINK-1792] TM Monitoring: CPU utilization, hide graphs by default and
show summary only
Added CPU Load %, show/hide button for detailed graph and summary for the
metrics
You can merge this
50 matches
Mail list logo
