[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4728.
-
Resolution: Fixed
Fixed via 9206b483b68bb41195bdf2da4f0b9c2de517c031
> Replace reference equality
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4728.
---
> Replace reference equality with object equality
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4329.
---
> Fix Streaming File Source Timestamps/Watermarks Handling
> -
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4709.
---
> InputStreamFSInputWrapper does not close wrapped stream
> --
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4709.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 28b37ef97d803855e884900d1a983813ea2ac99d
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4329.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 8ff451bec58e9f5800eb77c74c1d7457b776cc94
- 1.1.3 via ba
[
https://issues.apache.org/jira/browse/FLINK-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4737.
---
> Add more compression algorithms to FileInputFormat
> --
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4718.
---
> Confusing label in Parallel Streams Diagram
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4718.
-
Resolution: Fixed
Fix Version/s: (was: 1.1.2)
1.2.0
Fixed via 8000b6
[
https://issues.apache.org/jira/browse/FLINK-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4737.
-
Resolution: Fixed
Fixed in 81aec4109adc18f4bd4d1ddb91892faed10f4f14
Minor addition in 7a76328d4ec9
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4739.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via beb31fc1c5a6f5db060e5a4e1d64eacb70632900
[
https://issues.apache.org/jira/browse/FLINK-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4748.
---
> Fix shutdown of automatic watermark context
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4747.
---
> Instability due to pending processing timers on operator close
> ---
[
https://issues.apache.org/jira/browse/FLINK-4749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4749.
---
> Remove redundant processing time timers and futures in the window operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4747.
-
Resolution: Fixed
Fixed via resolution of subtasks
> Instability due to pending processing timers
[
https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4700.
---
> Harden the TimeProvider test
>
>
> Key: FLINK-4700
>
[
https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4700.
-
Resolution: Fixed
Assignee: Stephan Ewen (was: Kostas Kloudas)
Fix Version/s: 1.2.
[
https://issues.apache.org/jira/browse/FLINK-4749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4749.
-
Resolution: Fixed
Fixed via 47e4977442f7045baf29ce7dc772b7f7aff65343
> Remove redundant processin
[
https://issues.apache.org/jira/browse/FLINK-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4748.
-
Resolution: Fixed
Fixed via dd3416fde7b934584d4e18bc54d79ed7858556c2
> Fix shutdown of automatic
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550109#comment-15550109
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2581
---
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-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550110#comment-15550110
]
ASF GitHub Bot commented on FLINK-4739:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550112#comment-15550112
]
ASF GitHub Bot commented on FLINK-4709:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4750.
-
Resolution: Fixed
Fixed in 8aea8c8f427f5511c6064abbc4b85a3ef106743a
> Ensure that active processi
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550108#comment-15550108
]
ASF GitHub Bot commented on FLINK-4718:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4750.
---
> Ensure that active processing time triggers complete before closing operators
>
[
https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550111#comment-15550111
]
ASF GitHub Bot commented on FLINK-4728:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2002
---
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/2578
---
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/2582
---
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/2546
---
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/2591
---
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-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4744.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 56cba7ee9e00ef4b2493845558b614816b837d1b
Mi
[
https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4744.
---
> Introduce usercode class loader to deserialize partitionable operator state
> --
[
https://issues.apache.org/jira/browse/FLINK-4736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549920#comment-15549920
]
ASF GitHub Bot commented on FLINK-4736:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2601
PR looks good to me.
+1 to merge
---
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
enable
[
https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549849#comment-15549849
]
ASF GitHub Bot commented on FLINK-4744:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2598
---
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-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3722:
-
Assignee: Greg Hogan
> The divisions in the InMemorySorters' swap/compare methods hurt performanc
[
https://issues.apache.org/jira/browse/FLINK-4736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549633#comment-15549633
]
ASF GitHub Bot commented on FLINK-4736:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2601
[FLINK-4736] [core] Don't duplicate fields in Ordering
Duplicate fields should not be appended to an ordering. In an ordering each
subsequent field is only used as a comparison when all prior fiel
Github user fhueske commented on the pull request:
https://github.com/apache/flink/commit/eece0dd05bc38b88fcb6cbcef15add7f98eab456#commitcomment-19307176
In
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09F
[
https://issues.apache.org/jira/browse/FLINK-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4740.
-
Resolution: Implemented
Implemented in 7c9bc1e5172f39bd511ca4ed5e23fd8a7f3f33c6
> Upgrade testing librari
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4729.
-
Resolution: Implemented
Implemented in bb34133ed30b2a6c74baa0e5342e278e039cbe2a
> Use optional VertexCent
[
https://issues.apache.org/jira/browse/FLINK-4734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4734.
-
Resolution: Implemented
Implemented in 1577e898d97970ad815b2e431a9cb980bd52b660
> Remove use of Tuple set
[
https://issues.apache.org/jira/browse/FLINK-4734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549388#comment-15549388
]
ASF GitHub Bot commented on FLINK-4734:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549389#comment-15549389
]
ASF GitHub Bot commented on FLINK-4740:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549390#comment-15549390
]
ASF GitHub Bot commented on FLINK-4729:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2597
---
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/2587
---
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/2590
---
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-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vijay Srinivasaraghavan updated FLINK-4637:
---
Description: When service level authorization is enabled (FLINK-3930), the
tra
[
https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549373#comment-15549373
]
ASF GitHub Bot commented on FLINK-3932:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2589
@mxm Can you take a look at 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 your project does not have this feature
enab
[
https://issues.apache.org/jira/browse/FLINK-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549320#comment-15549320
]
ASF GitHub Bot commented on FLINK-4751:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2600
[FLINK-4751] [futures] Add thenCombineAsync function to Flink's futures
The `thenCombineAsync` method allows to combine two futures and apply a
`BiFunction` on
the results of both futures.
Till Rohrmann created FLINK-4751:
Summary: Extend Flink's futures to support combining two futures
Key: FLINK-4751
URL: https://issues.apache.org/jira/browse/FLINK-4751
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549160#comment-15549160
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82009076
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/windowDsl.scala
---
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549152#comment-15549152
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82008309
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/windowDsl.scala
---
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549145#comment-15549145
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user kl0u closed the pull request at
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549142#comment-15549142
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on the issue:
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/2593
---
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 enable
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2593
Thanks! Merged. Could you close the 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 your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549140#comment-15549140
]
Maximilian Michels commented on FLINK-4485:
---
Great to hear! :)
> Finished jobs
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549137#comment-15549137
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82006797
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/WordCountTable.scala
---
@@ -50,6 +50,10 @@ object WordCountTable {
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82006252
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549129#comment-15549129
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549121#comment-15549121
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r82004204
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -214,14 +216,24 @@ public AutomaticWatermarkContex
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549083#comment-15549083
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82002196
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549053#comment-15549053
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81998716
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549043#comment-15549043
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81997213
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549036#comment-15549036
]
Niels Basjes commented on FLINK-4485:
-
I did a run with the latest 'master' and I ran
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81858699
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/table/GroupWindowITCase.scala
---
@@ -0,0 +1,777 @@
+/*
+ * Li
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81851322
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81995575
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -214,14 +216,26 @@ public AutomaticWatermarkConte
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549025#comment-15549025
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user kl0u commented on a diff in the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81862041
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/table/GroupWindowITCase.scala
---
@@ -0,0 +1,777 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548972#comment-15548972
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r81857880
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala
---
@@ -325,33 +337,42 @@ trait ImplicitExpressionO
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548967#comment-15548967
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548977#comment-15548977
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548962#comment-15548962
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548970#comment-15548970
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r81971150
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/Resolvable.scala
---
@@ -0,0 +1,26 @@
+/*
+ * Licensed t
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81852219
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/windows.scala
---
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache So
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81860022
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/table/GroupWindowITCase.scala
---
@@ -0,0 +1,777 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548966#comment-15548966
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548971#comment-15548971
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548994#comment-15548994
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548993#comment-15548993
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81990910
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -250,7 +264,9 @@ public void collectWithTi
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81990874
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -214,14 +216,26 @@ public AutomaticWaterma
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548978#comment-15548978
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
1 - 100 of 219 matches
Mail list logo
