Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1429#issuecomment-172460239
Yes, sounds good!
---
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-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105398#comment-15105398
]
Kay commented on FLINK-3245:
Yes this some kind of confusing. It took me half a day to check why my results
Fabian Hueske created FLINK-3254:
Summary: CombineFunction interface not respected
Key: FLINK-3254
URL: https://issues.apache.org/jira/browse/FLINK-3254
Project: Flink
Issue Type: Bug
godfrey he created FLINK-3253:
-
Summary: deserializeObject exception on WindowOperator
Key: FLINK-3253
URL: https://issues.apache.org/jira/browse/FLINK-3253
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49995125
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
Ufuk Celebi created FLINK-3251:
--
Summary: Checkpoint stats show ghost numbers
Key: FLINK-3251
URL: https://issues.apache.org/jira/browse/FLINK-3251
Project: Flink
Issue Type: Bug
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1452#issuecomment-172523934
Closing this for a future pull request which uses a different approach and
also exposes accumulators.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105259#comment-15105259
]
ASF GitHub Bot commented on FLINK-3170:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105260#comment-15105260
]
ASF GitHub Bot commented on FLINK-3170:
---
Github user mxm closed the pull request at:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1500#issuecomment-172526377
Thanks for your work @chiwanpark. On the whole your changes look good. I
had some minor comments.
I also think that this won't work if the YARN cluster was
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105276#comment-15105276
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105282#comment-15105282
]
ASF GitHub Bot commented on FLINK-3246:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-2831:
--
Found an instance of {{WrapperSetupHelperTest}} which produced a dead lock:
[
https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2831:
-
Affects Version/s: 1.0.0
> Failing Test: WrapperSetupHelperTest
>
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1468#issuecomment-172533113
Testing failure seems to be unrelated. Merging the PR.
---
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-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105310#comment-15105310
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user tillrohrmann commented on the pull request:
Github user mxm closed the pull request at:
https://github.com/apache/flink/pull/1452
---
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
Ufuk Celebi created FLINK-3252:
--
Summary: Checkpoint stats only displayed after click on graph
Key: FLINK-3252
URL: https://issues.apache.org/jira/browse/FLINK-3252
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105298#comment-15105298
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1515#issuecomment-172531896
Yes, fixed the other dependencies now. Waiting for Travis to check...
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105297#comment-15105297
]
ASF GitHub Bot commented on FLINK-3246:
---
Github user StephanEwen commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1500#issuecomment-172531939
I have to correct myself. This should not be an issue if you start a Yarn
cluster in HA and then use `bin/flink run ...`, because a
`LeaderRetrievalService` will
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105302#comment-15105302
]
Stephan Ewen commented on FLINK-3178:
-
+1 for dropping incomplete windows on close
> Make Closing
[
https://issues.apache.org/jira/browse/FLINK-2911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105304#comment-15105304
]
Till Rohrmann commented on FLINK-2911:
--
I found another occurrence:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1513#issuecomment-172533529
I think the documentation hasn't been adopted to the changes.
---
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-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105313#comment-15105313
]
ASF GitHub Bot commented on FLINK-3184:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105314#comment-15105314
]
ASF GitHub Bot commented on FLINK-3243:
---
Github user rmetzger commented on the pull request:
Ufuk Celebi created FLINK-3250:
--
Summary: Savepoint coordinator requires too strict parallelism
match
Key: FLINK-3250
URL: https://issues.apache.org/jira/browse/FLINK-3250
Project: Flink
Issue
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49995630
--- Diff: flink-staging/flink-scala-shell/start-script/start-scala-shell.sh
---
@@ -75,11 +75,20 @@ do
fi
done
+log_setting=""
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas reassigned FLINK-2523:
-
Assignee: Kostas (was: Stephan Ewen)
> Make task canceling interrupt interval configurable
>
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105250#comment-15105250
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1515#issuecomment-172527568
-1 breaks build.
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1468
---
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-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105419#comment-15105419
]
Aljoscha Krettek commented on FLINK-3253:
-
Hi,
could you please specify what kind of
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1513#issuecomment-172567227
Right as always. I'm changing the docs 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
[
https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105450#comment-15105450
]
ASF GitHub Bot commented on FLINK-3243:
---
Github user aljoscha commented on the pull request:
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1429#issuecomment-172459799
@fhueske I will rebase and merge this into the `tableOnCalcite` branch
today, ok?
---
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-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104922#comment-15104922
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user twalthr commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104909#comment-15104909
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user andralungu closed the pull request at:
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/1291#issuecomment-172458727
Hi @vasia,
This PR contained a bugfix that could have been validated, but I don't mind
closing it!
---
If your project is set up for it, you can reply to
Github user andralungu closed the pull request at:
https://github.com/apache/flink/pull/1291
---
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-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104908#comment-15104908
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user andralungu commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104924#comment-15104924
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104929#comment-15104929
]
Stefano Baghino commented on FLINK-992:
---
Sure, thanks for the reply. I just wanted to check out if I
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105084#comment-15105084
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-172493786
The context environment is set in the `ScalaShellRemoteEnvironment` to
disable creation of new environments by the user. This is done when you first
create the batch
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-172494058
By the way, sorry for the late response. I was traveling.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105087#comment-15105087
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3242:
---
Assignee: Aljoscha Krettek
> User-specified StateBackend is not Respected if
[
https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105076#comment-15105076
]
Robert Metzger commented on FLINK-3248:
---
I would prefer the {{ConnectionFactory}} variant. How would
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105006#comment-15105006
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1291#issuecomment-172475425
Thanks @andralungu! Maybe you could open a PR with the bugfix only? Is
there a jira for it?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105079#comment-15105079
]
Robert Metzger commented on FLINK-3067:
---
[~gyfora], did you see this issue again or can we close it?
[
https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105110#comment-15105110
]
ASF GitHub Bot commented on FLINK-3242:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1516
[FLINK-3242] Also Set User-specified StateBackend without Checkpointing
Before, the user-specified StateBackedn would not be set when generating the
JobGraph if checkpointing was disabled.
You
[
https://issues.apache.org/jira/browse/FLINK-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104984#comment-15104984
]
Till Rohrmann commented on FLINK-3245:
--
Agreed to what the k-means algorithm does [~fhueske] but I
[
https://issues.apache.org/jira/browse/FLINK-3220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3220:
-
Assignee: Robert Metzger
> Flink does not start on Hortonworks Sandbox 2.3.2 due to
[
https://issues.apache.org/jira/browse/FLINK-3233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3233:
-
Assignee: Fabian Hueske
> PartitionOperator does not support expression keys on atomic types
>
[
https://issues.apache.org/jira/browse/FLINK-1903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1903:
Assignee: Fabian Hueske
> Joins where one side uses a field more than once don't work
>
[
https://issues.apache.org/jira/browse/FLINK-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1666:
Assignee: Fabian Hueske
> Clean-up Field Expression Code
> --
Maximilian Michels created FLINK-3248:
-
Summary: RMQSource does not provide a constructor for credentials
or other options
Key: FLINK-3248
URL: https://issues.apache.org/jira/browse/FLINK-3248
Ufuk Celebi created FLINK-3249:
--
Summary: Wrong "unknown partition state/input gate" error messages
Key: FLINK-3249
URL: https://issues.apache.org/jira/browse/FLINK-3249
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3241:
-
Assignee: Robert Metzger
> Scala 2.11 Flink binaries pull in Scala 2.10 dependencies
>
Stephan Ewen created FLINK-3255:
---
Summary: Chaining behavior should not depend on parallelism
Key: FLINK-3255
URL: https://issues.apache.org/jira/browse/FLINK-3255
Project: Flink
Issue Type:
Paris Carbone created FLINK-3256:
Summary: Invalid execution graph cleanup for jobs with colocation
groups
Key: FLINK-3256
URL: https://issues.apache.org/jira/browse/FLINK-3256
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105115#comment-15105115
]
ASF GitHub Bot commented on FLINK-2634:
---
Github user andralungu commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105163#comment-15105163
]
Gyula Fora commented on FLINK-3067:
---
It is running seamlessly so I think we can close it :)
> Kafka
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105207#comment-15105207
]
Robert Metzger commented on FLINK-3067:
---
Awesome! I'll close it.
> Kafka source fails during
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49992667
--- Diff: docs/apis/scala_shell.md ---
@@ -69,6 +69,18 @@ Scala-Flink> env.execute("MyProgram")
The Flink Shell comes with command history and
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105214#comment-15105214
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105221#comment-15105221
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49993429
--- Diff: docs/apis/scala_shell.md ---
@@ -69,6 +69,18 @@ Scala-Flink> env.execute("MyProgram")
The Flink Shell comes with command history and
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49993393
--- Diff: docs/apis/scala_shell.md ---
@@ -69,6 +69,18 @@ Scala-Flink> env.execute("MyProgram")
The Flink Shell comes with command history and
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105241#comment-15105241
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49995021
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105240#comment-15105240
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1045:
-
Priority: Blocker (was: Minor)
> Remove Combinable Annotation
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105195#comment-15105195
]
Maximilian Michels commented on FLINK-3248:
---
Yes, that approach is more future proof. I would
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49993273
--- Diff: docs/apis/scala_shell.md ---
@@ -69,6 +69,18 @@ Scala-Flink> env.execute("MyProgram")
The Flink Shell comes with command history and
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105220#comment-15105220
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105218#comment-15105218
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49993179
--- Diff: docs/apis/scala_shell.md ---
@@ -69,6 +69,18 @@ Scala-Flink> env.execute("MyProgram")
The Flink Shell comes with command history and
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105230#comment-15105230
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49993897
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49993916
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1500#discussion_r49993833
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105228#comment-15105228
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105227#comment-15105227
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49993975
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105236#comment-15105236
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3067.
---
Resolution: Fixed
> Kafka source fails during checkpoint notifications with NPE
>
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105222#comment-15105222
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49994742
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105239#comment-15105239
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105118#comment-15105118
]
Aljoscha Krettek commented on FLINK-3178:
-
I can't come up with cases where emitting the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1509#issuecomment-172501737
Will merge this PR tomorrow, unless somebody objects.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1045:
Assignee: Fabian Hueske
> Remove Combinable Annotation
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105233#comment-15105233
]
ASF GitHub Bot commented on FLINK-2935:
---
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/1500#discussion_r49994064
--- Diff:
flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
---
@@ -61,99 +73,217 @@ object FlinkShell {
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105232#comment-15105232
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 122 matches
Mail list logo
