GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/324
Rename coGroupDataSet.scala to CoGroupDataSet.scala, and crossDataSet.scala
to CrossDataSet.scala
This PR contains changes to follow Scala style:
-) Rename coGroupDataSet.scala to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/318#discussion_r23195339
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/SharedSlot.java
---
@@ -0,0 +1,154 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282593#comment-14282593
]
Till Rohrmann commented on FLINK-1372:
--
It always depends on the location from where
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/311#issuecomment-70517390
IMO, users should only be allowed to set semantic properties though field
expression strings. There should be no need to implement an own
SemanticProperty class or
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/321
[FLINK-1372] [runtime] Fix akka logging
Fixes logging settings. The logging is now exclusively controlled by the
logging properties provided to the system and thus removes akka.loglevel config
[
https://issues.apache.org/jira/browse/FLINK-1296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1296:
--
Fix Version/s: (was: 0.8)
0.9
Add support for very large record for
[
https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-937:
-
Fix Version/s: (was: 0.8)
0.9
Change the YARN Client to allocate all
[
https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1278:
--
Fix Version/s: (was: 0.8)
0.9
Remove the Record special code paths
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1297:
--
Fix Version/s: (was: 0.8)
0.9
Add support for tracking statistics of
[
https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-938:
-
Fix Version/s: (was: 0.8)
0.9
Change start-cluster.sh script so that users
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/292#discussion_r23169293
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -860,8 +910,50 @@ protected Properties getYarnProperties() throws
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/314#issuecomment-70519951
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 feature
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/322
[FLINK-1392] Add Kryo serializer for Protobuf
I've checked the added dependencies and its not overriding any versions and
no transitive dependencies are added.
You can merge this pull request into
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/60
---
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-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1003:
Assignee: (was: Till Rohrmann)
Spread out scheduling strategy
[
https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282360#comment-14282360
]
Fabian Hueske commented on FLINK-1418:
--
I agree, printing to the TMs std-out is
[
https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282393#comment-14282393
]
Fabian Hueske commented on FLINK-1419:
--
I think it is fine to make files in the DC
GitHub user ajaybhat opened a pull request:
https://github.com/apache/flink/pull/320
[FLINK-1165] No createCollectionsEnvironment in Java API
This commit adds a new method to ExecutionEnvironment to create a
CollectionEnvironment, and applies the method to cases where a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/292#discussion_r23169866
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/FlinkYarnSessionCli.java ---
@@ -0,0 +1,429 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282690#comment-14282690
]
Stephan Ewen commented on FLINK-1400:
-
Good point. The Webfrontend could write {{-1}}
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/292#discussion_r23171500
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/net/NetUtils.java ---
@@ -86,7 +86,7 @@ public static InetAddress
[
https://issues.apache.org/jira/browse/FLINK-1372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282739#comment-14282739
]
Till Rohrmann commented on FLINK-1372:
--
I think, it should work now with my latest
22 matches
Mail list logo
