[
https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384687#comment-15384687
]
Faye Beligianni commented on FLINK-1815:
Hi,
I find the idea of storing graphs as adjacency
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384672#comment-15384672
]
Greg Hogan commented on FLINK-3042:
---
[~twalthr] and [~StephanEwen] are there differences between this
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3695:
--
Component/s: (was: Core)
Type Serialization System
> ValueArray types
>
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-3674:
-
Assignee: ramkrishna.s.vasudevan
> Add an interface for EventTime aware
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2245
Hi @tillrohrmann !Thanks for the comments, I addressed the ones that should
be addressed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2245#discussion_r71379345
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java
---
[
https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-3397:
-
Assignee: ramkrishna.s.vasudevan
> Failed streaming jobs should fall
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2259
@tillrohrmann I integrated the comments.
Please review.
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2249
---
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-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4166.
-
Resolution: Fixed
Assignee: Stefan Richter
Fix Version/s: 1.1.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-4199.
---
Resolution: Fixed
Fixed via 17589d454d00efa43cdf6116ea29ff4f513b6f20
> Misleading
[
https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384415#comment-15384415
]
ASF GitHub Bot commented on FLINK-4166:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384416#comment-15384416
]
ASF GitHub Bot commented on FLINK-4199:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2264
---
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 mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71355731
--- Diff: flink-dist/src/main/flink-bin/bin/flink ---
@@ -17,21 +17,39 @@
# limitations under the License.
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384333#comment-15384333
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2257
+1 Let's get it out of the way for the 1.1 release.
---
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 tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71355929
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a
[
https://issues.apache.org/jira/browse/FLINK-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384273#comment-15384273
]
Timo Walther commented on FLINK-3153:
-
[~jark] you are right. I will close this issue.
> Support all
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384302#comment-15384302
]
Josh Forman-Gornall commented on FLINK-4190:
Hmm it is showing up here for me as a "links
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354413
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendMainTest.java ---
@@ -0,0 +1,39 @@
+package org.apache.flink.client;
+
+
[
https://issues.apache.org/jira/browse/FLINK-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3153.
-
Resolution: Fixed
Assignee: Timo Walther
Fix Version/s: 1.1.0
Fixed as part of
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354777
--- Diff: flink-dist/src/main/flink-bin/bin/flink ---
@@ -17,21 +17,39 @@
# limitations under the License.
--- End diff --
You change the mode
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354529
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendRunTest.java ---
@@ -110,6 +110,8 @@ public void testRun() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354329
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java ---
@@ -148,4 +148,5 @@ public boolean getDetachedMode() {
public
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384280#comment-15384280
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384291#comment-15384291
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384288#comment-15384288
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384275#comment-15384275
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384249#comment-15384249
]
Aljoscha Krettek commented on FLINK-4190:
-
Did you open the PR with the correct FLINK-4190 tag?
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354132
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
---
@@ -451,4 +479,25 @@ public static InfoOptions
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384283#comment-15384283
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384279#comment-15384279
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384276#comment-15384276
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384278#comment-15384278
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384252#comment-15384252
]
ASF GitHub Bot commented on FLINK-4230:
---
Github user StefanRRichter commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71354207
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
---
@@ -451,4 +479,25 @@ public static InfoOptions
[
https://issues.apache.org/jira/browse/FLINK-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384274#comment-15384274
]
ASF GitHub Bot commented on FLINK-4230:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2263
Oh, and I forgot: the checking for the correct number of elements can be
moved out of the window function and into the test itself, like this:
```
JobExecutionResult result =
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71353752
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
---
@@ -451,4 +479,25 @@ public static InfoOptions
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384268#comment-15384268
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2263
Thanks a lot for the review. I agree on all your points and will address
them.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4183.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in e85f787b280b63960e7f3add5aa8613b4ee23795.
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384234#comment-15384234
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384251#comment-15384251
]
ASF GitHub Bot commented on FLINK-4183:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2221
---
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-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384250#comment-15384250
]
Aljoscha Krettek commented on FLINK-4190:
-
Did you open the PR with the correct FLINK-4190 tag?
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2221
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
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384245#comment-15384245
]
ASF GitHub Bot commented on FLINK-4183:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3792.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed as part of FLINK-2985.
> RowTypeInfo
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2263
Nice pice of code! I finally understood how it works... ð
Some remarks about the code: in some places there are method names that
seem to stem from an initial implementation but don't
[
https://issues.apache.org/jira/browse/FLINK-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384242#comment-15384242
]
ASF GitHub Bot commented on FLINK-4230:
---
Github user aljoscha commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71350758
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a TaskManager is
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384206#comment-15384206
]
Josh Forman-Gornall commented on FLINK-4190:
Ok cool, thanks! I've just submitted a pull
GitHub user joshfg opened a pull request:
https://github.com/apache/flink/pull/2269
[FLINK-4190] Generalise RollingSink to work with arbitrary buckets
I've created a new bucketing package with a BucketingSink, which improves
on the existing RollingSink by enabling arbitrary
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384133#comment-15384133
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2257
My main concern is actually that the JM-RM interaction is not well tested.
Thus, I fear the more complex the code is the more possibility for mistakes
there are. For example, I couldn't find a
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2265
Yes, I see. That's great!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384115#comment-15384115
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4130.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in dd53831aa00e8160e8db14d6de186ce8f1f82b92.
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384113#comment-15384113
]
Aljoscha Krettek commented on FLINK-2491:
-
I think we want to tackle this for the 1.2 release,
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384111#comment-15384111
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2265
Ah ok, thats perfect! (about infix and postfix)
---
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-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384109#comment-15384109
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r71332501
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs a program.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2182
---
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 twalthr commented on the issue:
https://github.com/apache/flink/pull/2182
Thanks for the contribution @unsleepy22.
I changed the code a little bit, so that we can prevent an `if(false)`
branch.
Will merge...
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384105#comment-15384105
]
ASF GitHub Bot commented on FLINK-4166:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2249
Travis cache seems to be corrupted. Have you run `mvn verify` from the
command-line?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Stephan Ewen created FLINK-4233:
---
Summary: Simplify leader election / leader session ID assignment
Key: FLINK-4233
URL: https://issues.apache.org/jira/browse/FLINK-4233
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384103#comment-15384103
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71331743
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384104#comment-15384104
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71331665
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384094#comment-15384094
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2257
I don't feel particularly great about breaking the contract between
JobManager and ResourceManager but it is a path we can go until we expand the
ResourceManager capabilities. The figures here would
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384081#comment-15384081
]
Valentin Denisenkov commented on FLINK-2491:
Can you please give an ETA for this issue?
>
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384077#comment-15384077
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71327721
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +374,13 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384069#comment-15384069
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2257
I think by imposing this contract we actually introduced problems we didn't
have before. Thus, in order to remedy these problems for the upcoming release
and go back a bit in the direction of
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-2985.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 5758c91999efcf45457e4c25d4a75b13ce13e486.
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384046#comment-15384046
]
ASF GitHub Bot commented on FLINK-2985:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2078
---
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-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384040#comment-15384040
]
ASF GitHub Bot commented on FLINK-2985:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2078
Thanks for the contribution @gallenvara. I will merge it now...
---
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-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384035#comment-15384035
]
ASF GitHub Bot commented on FLINK-4166:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2249
Thank you! Merging after tests pass.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384031#comment-15384031
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user twalthr commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71325247
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a TaskManager is
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71325200
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +374,13 @@ class JobManager(
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2265
I was also thinking a lot about the names, because we have currently many
`Function`s in Flink. I chose `UserDefinedFunction` as the top-level function
for all user-defined functions such as
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384029#comment-15384029
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384030#comment-15384030
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384026#comment-15384026
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71325133
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +374,13 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384014#comment-15384014
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71323898
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -405,36 +374,13 @@ class JobManager(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2257#discussion_r71322624
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -78,6 +79,9 @@
/** The containers where a
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15384005#comment-15384005
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 128 matches
Mail list logo
