[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194174#comment-15194174
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-196528621
Screenshots added:
![lTaskManager lo
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194004#comment-15194004
]
Vasia Kalavri commented on FLINK-3612:
--
Thanks, I'li try to figure it out!
I am in fa
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3612:
Assignee: Vasia Kalavri
> Fix/adjust Table API examples
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193982#comment-15193982
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-196486496
Thanks for the PR and the description. Could you add screenshots so that
more people can get a quick idea of the change? :)
---
If your project is set up for it, you can re
[
https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193969#comment-15193969
]
ASF GitHub Bot commented on FLINK-3610:
---
Github user mbalassi closed the pull reques
Github user mbalassi closed the pull request at:
https://github.com/apache/flink/pull/1784
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-3610:
--
Fix Version/s: (was: 1.0.1)
2.0.0
> Scala DataStream#addSink returns Java
[
https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-3610:
--
Priority: Major (was: Critical)
> Scala DataStream#addSink returns Java DataStreamSink
> --
[
https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193959#comment-15193959
]
Márton Balassi commented on FLINK-3610:
---
It is an inconsistency primarily. As per di
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193927#comment-15193927
]
Fabian Hueske commented on FLINK-3612:
--
Good catch [~vkalavri]! The TPC-H specificati
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1791
[FLINK-3129] Add japicmp-maven-plugin to ensure interface stability
Now that Flink 1.0.0 is available on MVN Central, we can ensure that a
maven build does not break any public APIs.
Since
[
https://issues.apache.org/jira/browse/FLINK-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193839#comment-15193839
]
ASF GitHub Bot commented on FLINK-3129:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Todd Lisonbee updated FLINK-3613:
-
Description:
Implement standard deviation, mean, variance for
org.apache.flink.api.java.aggregati
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Todd Lisonbee updated FLINK-3613:
-
Summary: Add standard deviation, mean, variance to list of Aggregations
(was: Add standard deviat
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193827#comment-15193827
]
Todd Lisonbee commented on FLINK-3613:
--
I checked the Spark code base, it looks like
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193792#comment-15193792
]
ASF GitHub Bot commented on FLINK-2732:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/1790
[FLINK-2732] Display TM logs in Dashboard
This PR allows the TM logs to be displayed in the Dashboard.
The page displaying information about a single TaskManager now has two
additional tabs
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193680#comment-15193680
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user kl0u commented on the pull requ
[
https://issues.apache.org/jira/browse/FLINK-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193696#comment-15193696
]
Soila Kavulya commented on FLINK-1932:
--
Thanks [~tvas]. I'll address the comments in
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1764#issuecomment-196422054
@StephanEwen @rmetzger I have integrated your comments.
Please review!
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1741#issuecomment-196413171
I would also need some more time for review if my review is requested.
---
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-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193641#comment-15193641
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3272.
--
Resolution: Implemented
Fix Version/s: 1.1.0
> Generalize vertex value type in ConnectedC
[
https://issues.apache.org/jira/browse/FLINK-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193624#comment-15193624
]
ASF GitHub Bot commented on FLINK-3272:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1785
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193618#comment-15193618
]
Vasia Kalavri commented on FLINK-3612:
--
{{JavaTableExample}} and {{WordCountTable}} w
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193522#comment-15193522
]
Todd Lisonbee commented on FLINK-3613:
--
Hello, I'm new to Apache Flink and would like
Todd Lisonbee created FLINK-3613:
Summary: Add standard deviation to list of Aggregations
Key: FLINK-3613
URL: https://issues.apache.org/jira/browse/FLINK-3613
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193518#comment-15193518
]
ASF GitHub Bot commented on FLINK-3489:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1789#issuecomment-196383687
You're right @twalthr, thanks! I've removed `typeInfo` and renamed
`ExpressionException `.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193456#comment-15193456
]
ASF GitHub Bot commented on FLINK-3489:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1789#issuecomment-196360615
@vasia I looked into the code again. You can remove the `typeInfo()` of
`Expression` savely. It is only used by `typeInfo()` of other expressions.
Never executed.
Re
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3574.
-
Resolution: Implemented
Fix Version/s: 1.1.0
> Implement math functions for Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3612:
-
Issue Type: Sub-task (was: Bug)
Parent: FLINK-3221
> Fix/adjust Table API examples
>
Vasia Kalavri created FLINK-3612:
Summary: Fix/adjust Table API examples
Key: FLINK-3612
URL: https://issues.apache.org/jira/browse/FLINK-3612
Project: Flink
Issue Type: Bug
Compone
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193374#comment-15193374
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1690#issuecomment-196338135
Can you add a test case ensuring the functionality? If I'm not mistaken,
the change would have introduced a pretty bad bug.
---
If your project is set up for it, you c
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1690#discussion_r56009318
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@ -2
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193372#comment-15193372
]
ASF GitHub Bot commented on FLINK-3398:
---
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/1764#discussion_r56008125
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TrailingWatermarkTimestampExtractor.java
---
@@ -0,0 +1,71 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193366#comment-15193366
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193347#comment-15193347
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-196325179
Yes I think they will be removed at runtime. Thus, I guess it should also
be fine to test for `isInstanceOf[StreamMap[_, _]]`. If you also want to check
the input/o
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193327#comment-15193327
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-196321443
@tillrohrmann I just have one minor concern regarding the tests: would
`isInstanceOf[StreamMap[Int, Int]]` work? Wouldn't the generic type parameters
(the two `In
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-196320836
@tillrohrmann Thanks! Outstanding review, it's great to have some guidance
when approaching a new project; thank you for the tips on testing as well, it
turned ou
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193325#comment-15193325
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r56001580
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/package.scala
---
@@ -0,0 +1,201 @@
+/*
+ * Licensed to the Apache So
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-196314763
@stefanobaghino, really good work :-) I think we're close to get this
merged. I had some minor comments.
Concerning the testing, I agree with @StephanEwen t
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193309#comment-15193309
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193305#comment-15193305
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2523.
---
Resolution: Fixed
Implemented in 4f11b401688ac6ba78a1e32a556a2419affa2946
> Make task canceli
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193303#comment-15193303
]
ASF GitHub Bot commented on FLINK-3489:
---
GitHub user vasia opened a pull request:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1789
[FLINK-3489] TableAPI refactoring and cleanup
I applied the proposed changes, except from
- remove `ExpressionException `: it is used in many places
- remove `typeInfo()` of `Expression`: also
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1662
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193297#comment-15193297
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the p
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r56000181
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/acceptPartialFunctions/OnWindowedStream.scala
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193285#comment-15193285
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-3609:
Assignee: Fabian Hueske
> Revisit selection of Calcite rules
>
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193276#comment-15193276
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55999131
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/package.scala
---
@@ -0,0 +1,201 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193273#comment-15193273
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193274#comment-15193274
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user dawidwys closed the pull reques
Github user dawidwys closed the pull request at:
https://github.com/apache/flink/pull/1775
---
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 en
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55998933
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/acceptPartialFunctions/OnDataSet.scala
---
@@ -0,0 +1,104 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3604.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Enable ignored Table API tests
> ---
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193260#comment-15193260
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55997348
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/acceptPartialFunctions/OnDataSet.scala
---
@@ -0,0 +1,104 @@
+/*
+ *
Github user fhueske closed the pull request at:
https://github.com/apache/flink/pull/1783
---
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
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193259#comment-15193259
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1775#issuecomment-196303857
@dawidwys I have merged it. Can you close this 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 you
[
https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193253#comment-15193253
]
ASF GitHub Bot commented on FLINK-3583:
---
Github user fijolekProjects closed the pull
Github user fijolekProjects commented on the pull request:
https://github.com/apache/flink/pull/1768#issuecomment-196301747
Thanks @aljoscha
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193255#comment-15193255
]
ASF GitHub Bot commented on FLINK-3583:
---
Github user fijolekProjects commented on th
Github user fijolekProjects closed the pull request at:
https://github.com/apache/flink/pull/1768
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193243#comment-15193243
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a d
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55996335
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/acceptPartialFunctions/OnDataSet.scala
---
@@ -0,0 +1,104 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3603.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Re-enable Table API explain
> --
[
https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193240#comment-15193240
]
ASF GitHub Bot commented on FLINK-3583:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3597.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Table API operator names should reflect relation
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1768#issuecomment-196300410
Thanks a lot! I merged it.
Could you please close this PR if github does not do so automatically.
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3583.
-
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/c0d5ba3886ea9d124f241fa
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1783#issuecomment-196300324
Merged!
---
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
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55995777
--- Diff: docs/apis/scala_api_extensions.md ---
@@ -0,0 +1,392 @@
+---
+title: "Scala API Extensions"
+# Top-level navigation
+top-nav-g
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193232#comment-15193232
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193230#comment-15193230
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1775#issuecomment-196299119
@dawidwys I have assigned it to you. Thanks for taking care of this.
Merging this PR now...
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193229#comment-15193229
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a d
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55995517
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/package.scala
---
@@ -0,0 +1,201 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193226#comment-15193226
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193222#comment-15193222
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55995289
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/package.scala
---
@@ -0,0 +1,202 @@
+/*
+ * Licen
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55995217
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/acceptPartialFunctions/OnWindowedStream.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193215#comment-15193215
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
I created a pull request wi
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193215#comment-15193215
]
ramkrishna.s.vasudevan edited comment on FLINK-3579 at 3/14/16 12:48 PM:
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1704#discussion_r55994602
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/acceptPartialFunctions/OnWindowedStream.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-3579:
-
Assignee: ramkrishna.s.vasudevan
> Improve String concatenation
> ---
[
https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3563.
-
Resolution: Fixed
Fix Version/s: 1.0.1
1.1.0
Fixed in b376540.
> .retur
1 - 100 of 180 matches
Mail list logo
