[
https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950414#comment-15950414
]
ASF GitHub Bot commented on FLINK-6217:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3648
The failed tests are being addressed in FLINK-6175.
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950408#comment-15950408
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske
I just thought of an example. Assume you have 2 events coming at
consecutime processintimes
Ev1,1
Ev2, 2
When ev1 arrives you accumulate it and register the timer at proctim
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950388#comment-15950388
]
Xiaogang Shi commented on FLINK-6219:
-
I prefer to use sorted states (e.g., {{SortedMa
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950319#comment-15950319
]
Luke Hutchison edited comment on FLINK-6115 at 3/31/17 4:49 AM:
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950319#comment-15950319
]
Luke Hutchison commented on FLINK-6115:
---
[~greghogan] You're assuming data with {{nu
[
https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-4577.
--
Resolution: Fixed
Assignee: Tzu-Li (Gordon) Tai
Fix Version/s: 1.3.0
Res
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-5625.
--
Resolution: Fixed
Fix Version/s: 1.3.0
Resolved for 1.3.0 with
http://git-wip-us
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950311#comment-15950311
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950312#comment-15950312
]
ASF GitHub Bot commented on FLINK-4577:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3458
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3651
---
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-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950303#comment-15950303
]
ASF GitHub Bot commented on FLINK-4577:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3458
Merging this to `master` 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 not have this feature
enabled and
Jing Fan created FLINK-6225:
---
Summary: Support Row Stream for CassandraSink
Key: FLINK-6225
URL: https://issues.apache.org/jira/browse/FLINK-6225
Project: Flink
Issue Type: New Feature
Co
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3651
Merging to `master` ..
---
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 s
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950301#comment-15950301
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tzulitai commented on the issue
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/3595
@greghogan Currently we check the position with the EndPosition which is
the size of buffer instead of a max written size , so it is still possible to
leave holes when keeping unmodified. Enabling
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950223#comment-15950223
]
ASF GitHub Bot commented on FLINK-6162:
---
Github user wenlong88 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 1:53 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 1:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950174#comment-15950174
]
sunjincheng commented on FLINK-5994:
Hi [~twalthr] Recently I was working on FLIP 11 S
[
https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950165#comment-15950165
]
sunjincheng commented on FLINK-4680:
Hi[~fhueske], Most of the SQL over has been merge
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950150#comment-15950150
]
ASF GitHub Bot commented on FLINK-6200:
---
Github user hongyuhong commented on a diff
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3649#discussion_r109072158
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -204,21
[
https://issues.apache.org/jira/browse/FLINK-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CanBin Zheng updated FLINK-6224:
Summary: RemoteStreamEnvironment not resolve ip of JobManager to hostname
(was: RemoteStreamEnviron
[
https://issues.apache.org/jira/browse/FLINK-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CanBin Zheng updated FLINK-6224:
Description:
I run two examples in the same client.
first one use
ExecutionEnvironment.cre
CanBin Zheng created FLINK-6224:
---
Summary: RemoteStreamEnvironment not resolve hostname of JobManager
Key: FLINK-6224
URL: https://issues.apache.org/jira/browse/FLINK-6224
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5516:
---
Assignee: Chesnay Schepler
> Hardcoded paths in flink-python/.../PythonPlanBinder.jav
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949995#comment-15949995
]
Fabian Hueske commented on FLINK-5725:
--
Hi [~Yuhong_kyo], sorry for the late feedback
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6216:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-6047
> DataStream unbounded groupby
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6200.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 44f9c76a9ff50e95947c9f78a86b485
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5653.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with ee033c903b20d7a233009764b6b96e7
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3574
---
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-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949946#comment-15949946
]
ASF GitHub Bot commented on FLINK-6200:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949947#comment-15949947
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3653
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3649
---
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-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949948#comment-15949948
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949934#comment-15949934
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949928#comment-15949928
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949932#comment-15949932
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949939#comment-15949939
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949933#comment-15949933
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949936#comment-15949936
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949937#comment-15949937
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949935#comment-15949935
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949941#comment-15949941
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949930#comment-15949930
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949931#comment-15949931
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949938#comment-15949938
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949926#comment-15949926
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949940#comment-15949940
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949929#comment-15949929
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949927#comment-15949927
]
ASF GitHub Bot commented on FLINK-6216:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109047823
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109047104
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109046506
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109046955
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109039910
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala
---
@@ -0,0 +1,117 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109043405
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala
---
@@ -0,0 +1,100 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109045076
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala
---
@@ -123,10 +144,24 @@ class W
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109047011
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109042385
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -73,7 +73,7 @@ object AggregateUtil
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109034147
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -221,8 +221,8 @@ case class Aggregate(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109047127
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109046265
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109045587
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109041002
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupAggregate.scala
---
@@ -0,0 +1,117 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109046937
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r109047090
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -0,0 +1,304 @@
+
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949899#comment-15949899
]
radu commented on FLINK-5725:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949892#comment-15949892
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
for the harness tests - i would let you know after it is implemented...in
the case it does not work i would temporary change the tests - that is until a
new version of harness would be implemented/f
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949887#comment-15949887
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske OK - i will implement this and ping you when it is ready.
One more question - when you say:
"The ProcessFunction does also support to register processing time timers
via the context
[
https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949878#comment-15949878
]
radu commented on FLINK-6082:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949864#comment-15949864
]
radu commented on FLINK-6075:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949864#comment-15949864
]
radu edited comment on FLINK-6075 at 3/30/17 9:23 PM:
--
[~fhueske] [~s
Chesnay Schepler created FLINK-6223:
---
Summary: Rework PythonPlanBinder generics
Key: FLINK-6223
URL: https://issues.apache.org/jira/browse/FLINK-6223
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu reassigned FLINK-6081:
---
Assignee: radu
> Offset/Fetch support for SQL Streaming
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949857#comment-15949857
]
radu commented on FLINK-6081:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949827#comment-15949827
]
radu commented on FLINK-6077:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949816#comment-15949816
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949735#comment-15949735
]
radu edited comment on FLINK-6073 at 3/30/17 9:01 PM:
--
[~fhueske] [~s
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
You are right, with processing time no two records arrive at exactly the
same time. However, we also retract values based on the granularity of
milliseconds. Therefore, I think is makes sense to also
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949795#comment-15949795
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
ignore question 1 - i found an example in the
UnboundedEventTimeOverProcessFunction.scala
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske Thanks for the example. First of all i am happy that we agree that
we need to emit something for every input :). I was scared that this will not
be the case
Now regarding the 2 opt
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949791#comment-15949791
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949769#comment-15949769
]
ASF GitHub Bot commented on FLINK-5915:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949772#comment-15949772
]
ASF GitHub Bot commented on FLINK-5915:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3647
The change looks good in general. I'd prefer to use an array instead of a
List though.
What do you think @shaoxuan-wang?
---
If your project is set up for it, you can reply to this email and hav
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3647#discussion_r109032005
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -857,28 +857,30 @@ object Aggregate
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949735#comment-15949735
]
radu commented on FLINK-6073:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949733#comment-15949733
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
Sorry, I think did not explain the change correctly.
I did not mean to group multiple record together.
We still emit one row per input row, but given the following input
```
(pro
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske - you can check also the definition from the Calcite website
https://calcite.apache.org/docs/stream.html
Standard SQL features so-called âanalytic functionsâ that can be use
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949721#comment-15949721
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
1 - 100 of 315 matches
Mail list logo
