GitHub user nguraja opened a pull request:
https://github.com/apache/flink/pull/2592
FLINK-4596: Fallback restart strategy config to let jobs choose restaâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into conside
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15547946#comment-15547946
]
ASF GitHub Bot commented on FLINK-4596:
---
GitHub user nguraja opened a pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2592#discussion_r81918259
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java
---
@@ -173,4 +177,13 @@ public String getDescript
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548007#comment-15548007
]
ASF GitHub Bot commented on FLINK-4596:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548006#comment-15548006
]
ASF GitHub Bot commented on FLINK-4596:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2592#discussion_r81918886
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1114,7 +1114,8 @@ class JobManager(
O
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2593
[FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling
This is a quick fix for the [FLINK-4329] issue. The fix on the master is
different but it contains more changes that are not easy t
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548044#comment-15548044
]
ASF GitHub Bot commented on FLINK-4329:
---
GitHub user kl0u opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2594
[FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager
The ported logic contains the task lifecycle management methods, JobManager
association and
setup of TaskManager
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548104#comment-15548104
]
ASF GitHub Bot commented on FLINK-4738:
---
GitHub user tillrohrmann opened a pull requ
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2595
[FLINK-3656] [table] Test base for logical unit testing
This PR introduces a test base for logical unit testing. It could replace
most of current ITCases as it checks if the API is correctly transla
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548219#comment-15548219
]
ASF GitHub Bot commented on FLINK-3656:
---
GitHub user twalthr opened a pull request:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2094
@mbalassi any news on this PR? Would you like to review it again and merge
it?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548239#comment-15548239
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on the issue:
Github user tzulitai commented on the pull request:
https://github.com/apache/flink/commit/eece0dd05bc38b88fcb6cbcef15add7f98eab456#commitcomment-19300270
In
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548291#comment-15548291
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user ggevay commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2094
I have rebased now to the current 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
ena
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
Hello, zentol.
>but, i just realized that without this you would end up with concurrency
issues since multiple register calls can be active at the same time...I'll have
to think about this for a bit
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548298#comment-15548298
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
GitHub user chakravarthyvp opened a pull request:
https://github.com/apache/flink/pull/2596
Release 1.1
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2596
Looks like something went wrong with this PR. It proposes to merge changes
from the `release-1.1` branch into `master`.
Did you try to open a PR against the release-1.1 branch?
---
If your proj
Github user chakravarthyvp commented on the issue:
https://github.com/apache/flink/pull/2596
Hi Fabian,
Sorry about that, it was my fault.
Please discard it.
Best Regards
Varaga
On Wed, Oct 5, 2016 at 11:22 AM, Fabian Hueske
wrote:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2596
No worries :-)
Could you please close the PR then? Thanks!
---
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
Github user chakravarthyvp closed the pull request at:
https://github.com/apache/flink/pull/2596
---
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
Anton Mushin created FLINK-4743:
---
Summary: The sqrt/power function not accept the real data types.
Key: FLINK-4743
URL: https://issues.apache.org/jira/browse/FLINK-4743
Project: Flink
Issue Typ
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2517
that wouldn't solve the concurrency issues. If you have 2 concurrent
notifies going on you would pass the same FrontMetricGroup to the reporter,
hence for both calls the reporter would work on the sam
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548348#comment-15548348
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user zentol commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81944020
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81946646
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81945670
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548381#comment-15548381
]
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_r81944676
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81944308
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548386#comment-15548386
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548389#comment-15548389
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548382#comment-15548382
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548384#comment-15548384
]
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_r81944479
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2593#discussion_r81944268
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548385#comment-15548385
]
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_r81944208
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548383#comment-15548383
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548388#comment-15548388
]
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_r81947121
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -299,7 +319,7 @@ public void trigger(long timestam
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548387#comment-15548387
]
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_r81947893
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548380#comment-15548380
]
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_r81944138
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -106,6 +107,155 @@ public static void destroyHDFS() {
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548392#comment-15548392
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2597
[FLINK-4740] [tests] Upgrade testing libraries
Upgrades
JUnit from 4.11 to 4.12
Mockito from 1.9.5 to 1.10.19
PowerMock from 1.5.5 to 1.6.5
You can merge this pull request into a
[
https://issues.apache.org/jira/browse/FLINK-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548492#comment-15548492
]
ASF GitHub Bot commented on FLINK-4740:
---
GitHub user greghogan opened a pull request
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2430
@mushketyk thanks. I will merge this.
---
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-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548500#comment-15548500
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user twalthr commented on the issue:
Stefan Richter created FLINK-4744:
-
Summary: Introduce usercode class loader to deserialize
partitionable operator state
Key: FLINK-4744
URL: https://issues.apache.org/jira/browse/FLINK-4744
Project:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2598
FLINK-4744 - Introduce usercode class loader to deserialize partitionable
operator state
With this PR, deserialization of partitionable operator state respects user
class loader. This fixes
[
https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548511#comment-15548511
]
ASF GitHub Bot commented on FLINK-4744:
---
GitHub user StefanRRichter opened a pull re
Till Rohrmann created FLINK-4746:
Summary: Replace TaskManagerRuntimeInfo by TaskManagerConfiguration
Key: FLINK-4746
URL: https://issues.apache.org/jira/browse/FLINK-4746
Project: Flink
Issu
Timo Walther created FLINK-4745:
---
Summary: Convert KafkaTableSource test to unit tests
Key: FLINK-4745
URL: https://issues.apache.org/jira/browse/FLINK-4745
Project: Flink
Issue Type: Improveme
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2430
---
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-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548581#comment-15548581
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3874.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 825ef3be35ec9a85e800c5db5b8d3bbf5fa188a0.
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2599
[FLINK-4746] Make TaskManagerRuntimeInfo an interface
This PR is based on #2594.
Let the `TaskManagerConfiguration` implement the `TaskManagerRuntimeInfo`
interface to make some of the
[
https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548618#comment-15548618
]
ASF GitHub Bot commented on FLINK-4746:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548643#comment-15548643
]
Nikolay Vasilishin commented on FLINK-3204:
---
[~rmetzger], could you provide some
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548780#comment-15548780
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548796#comment-15548796
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2571
As discussed in this PR, I've pushed the following changes:
1. Move the slot registration and allocation report to the registration
of the TaskExecutor
2. Let the TaskExecutor immedia
Stephan Ewen created FLINK-4747:
---
Summary: Instability due to pending processing timers on operator
close
Key: FLINK-4747
URL: https://issues.apache.org/jira/browse/FLINK-4747
Project: Flink
I
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2593
Thanks @mxm and @StephanEwen for the comments. I have updated 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
Stephan Ewen created FLINK-4748:
---
Summary: Fix shutdown of automatic watermark context
Key: FLINK-4748
URL: https://issues.apache.org/jira/browse/FLINK-4748
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4749:
---
Summary: Remove redundant processing time timers and futures in
the window operator
Key: FLINK-4749
URL: https://issues.apache.org/jira/browse/FLINK-4749
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2548
---
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-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548816#comment-15548816
]
ASF GitHub Bot commented on FLINK-4677:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4677.
-
Resolution: Fixed
master: 8c7c42f0e91aa3fa2016650e541bbb668e6b79db
release-1.1: fddd89bcd5
[
https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548824#comment-15548824
]
Stephan Ewen commented on FLINK-4742:
-
This was just fixed concurrently. It is a "race
Stephan Ewen created FLINK-4750:
---
Summary: Ensure that active processing time triggers complete
before closing operators
Key: FLINK-4750
URL: https://issues.apache.org/jira/browse/FLINK-4750
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548827#comment-15548827
]
Stephan Ewen commented on FLINK-4742:
-
CI verification is pending for FLINK-4747, shou
[
https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4742.
-
Resolution: Duplicate
Duplicate of FLINK-4747
> NPE in WindowOperator.trigger() on shutdown
> ---
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
Thanks.
I pushed new changes.
---
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 w
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548873#comment-15548873
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2545#discussion_r81987517
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -675,38 +673,6 @@ else if (isClassType(t) &&
Tuple.class.
[
https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548914#comment-15548914
]
ASF GitHub Bot commented on FLINK-4673:
---
Github user greghogan commented on a diff i
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r81854254
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/examples/scala/WordCountTable.scala
---
@@ -50,6 +50,10 @@ object WordCountTable {
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548969#comment-15548969
]
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_r81976580
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/groupWindows.scala
---
@@ -0,0 +1,242 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548974#comment-15548974
]
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_r81859596
--- 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=15548981#comment-15548981
]
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_r81852306
--- 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=15548979#comment-15548979
]
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_r81970778
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/LogicalWindow.scala
---
@@ -0,0 +1,35 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548983#comment-15548983
]
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=15548961#comment-15548961
]
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_r81860061
--- 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=15548960#comment-15548960
]
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=15548959#comment-15548959
]
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=15548968#comment-15548968
]
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=15548963#comment-15548963
]
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_r81861356
--- 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=15548964#comment-15548964
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in
1 - 100 of 219 matches
Mail list logo
