[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15194174#comment-15194174
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-196528621
Screenshots added:
![lTaskManager
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15194004#comment-15194004
]
Vasia Kalavri commented on FLINK-3612:
--
Thanks, I'li try to figure it out!
I am in favor of removing
[
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=15193982#comment-15193982
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user uce commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193969#comment-15193969
]
ASF GitHub Bot commented on FLINK-3610:
---
Github user mbalassi closed the pull request at:
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
[
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
[
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=15193959#comment-15193959
]
Márton Balassi commented on FLINK-3610:
---
It is an inconsistency primarily. As per discussion on the
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193927#comment-15193927
]
Fabian Hueske commented on FLINK-3612:
--
Good catch [~vkalavri]! The TPC-H specification also includes
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.
[
https://issues.apache.org/jira/browse/FLINK-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193827#comment-15193827
]
Todd Lisonbee commented on FLINK-3613:
--
I checked the Spark code base, it looks like they used the
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15193680#comment-15193680
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user kl0u commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193696#comment-15193696
]
Soila Kavulya commented on FLINK-1932:
--
Thanks [~tvas]. I'll address the comments in the PR. I am
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
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=15193641#comment-15193641
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on the pull request:
[
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
[
https://issues.apache.org/jira/browse/FLINK-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193624#comment-15193624
]
ASF GitHub Bot commented on FLINK-3272:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193618#comment-15193618
]
Vasia Kalavri commented on FLINK-3612:
--
{{JavaTableExample}} and {{WordCountTable}} work fine if the
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193522#comment-15193522
]
Todd Lisonbee commented on FLINK-3613:
--
Hello, I'm new to Apache Flink and would like to contribute
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:
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193518#comment-15193518
]
ASF GitHub Bot commented on FLINK-3489:
---
Github user vasia commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193456#comment-15193456
]
ASF GitHub Bot commented on FLINK-3489:
---
Github user twalthr commented on the pull request:
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.
[
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
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193374#comment-15193374
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user rmetzger commented on the pull request:
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
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193372#comment-15193372
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user rmetzger commented on a diff in the pull
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=15193366#comment-15193366
]
ASF GitHub Bot commented on FLINK-3428:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193347#comment-15193347
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193327#comment-15193327
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193325#comment-15193325
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193309#comment-15193309
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193305#comment-15193305
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user asfgit closed the pull request at:
[
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
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193297#comment-15193297
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the pull request:
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193285#comment-15193285
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a diff in the pull
[
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=15193276#comment-15193276
]
ASF GitHub Bot commented on FLINK-1159:
---
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/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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193273#comment-15193273
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193274#comment-15193274
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user dawidwys closed the pull request at:
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
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=15193260#comment-15193260
]
ASF GitHub Bot commented on FLINK-1159:
---
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/1704#discussion_r55997348
--- 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-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193259#comment-15193259
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user twalthr commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193255#comment-15193255
]
ASF GitHub Bot commented on FLINK-3583:
---
Github user fijolekProjects commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193243#comment-15193243
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a diff in the pull
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=15193240#comment-15193240
]
ASF GitHub Bot commented on FLINK-3583:
---
Github user aljoscha commented on the pull request:
[
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
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193232#comment-15193232
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193230#comment-15193230
]
ASF GitHub Bot commented on FLINK-3574:
---
Github user twalthr commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193229#comment-15193229
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user stefanobaghino commented on a diff in the pull
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=15193226#comment-15193226
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193222#comment-15193222
]
ASF GitHub Bot commented on FLINK-1159:
---
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/1704#discussion_r55995289
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/package.scala
---
@@ -0,0 +1,202 @@
+/*
+ *
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193215#comment-15193215
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
I created a pull request with a necessary
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
---
@@
[
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.
>
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193212#comment-15193212
]
ASF GitHub Bot commented on FLINK-1159:
---
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/1704#discussion_r55994370
--- 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=15193204#comment-15193204
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193205#comment-15193205
]
ASF GitHub Bot commented on FLINK-1159:
---
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/1704#discussion_r55994329
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/extensions/package.scala
---
@@ -0,0 +1,201 @@
+/*
+ * Licensed to the Apache
1 - 100 of 175 matches
Mail list logo
