[
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-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
[
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
[
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-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-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=15550111#comment-15550111
]
ASF GitHub Bot commented on FLINK-4728:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15550110#comment-15550110
]
ASF GitHub Bot commented on FLINK-4739:
---
Github user asfgit closed the pull request at:
[
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:
[
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
[
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-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-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15550112#comment-15550112
]
ASF GitHub Bot commented on FLINK-4709:
---
Github user asfgit closed the pull request at:
[
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
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15550109#comment-15550109
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15550108#comment-15550108
]
ASF GitHub Bot commented on FLINK-4718:
---
Github user asfgit closed the pull request at:
[
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-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
[
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-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
[
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-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4728.
-
Resolution: Fixed
Fixed via 9206b483b68bb41195bdf2da4f0b9c2de517c031
> Replace reference
[
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-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
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
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
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() {
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
[
https://issues.apache.org/jira/browse/FLINK-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548511#comment-15548511
]
ASF GitHub Bot commented on FLINK-4744:
---
GitHub user StefanRRichter 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
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548219#comment-15548219
]
ASF GitHub Bot commented on FLINK-3656:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548298#comment-15548298
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548392#comment-15548392
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548500#comment-15548500
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548239#comment-15548239
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548348#comment-15548348
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user zentol commented on the issue:
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
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
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
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=15548386#comment-15548386
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548389#comment-15548389
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548388#comment-15548388
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548387#comment-15548387
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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=15548380#comment-15548380
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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() {
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=15548385#comment-15548385
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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=15548383#comment-15548383
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548381#comment-15548381
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548382#comment-15548382
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548384#comment-15548384
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user mxm commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548492#comment-15548492
]
ASF GitHub Bot commented on FLINK-4740:
---
GitHub user greghogan opened a pull request:
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 tzulitai commented on the pull request:
https://github.com/apache/flink/commit/eece0dd05bc38b88fcb6cbcef15add7f98eab456#commitcomment-19300270
In
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
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
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
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548104#comment-15548104
]
ASF GitHub Bot commented on FLINK-4738:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548007#comment-15548007
]
ASF GitHub Bot commented on FLINK-4596:
---
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/2592#discussion_r81918886
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1114,7 +1114,8 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548006#comment-15548006
]
ASF GitHub Bot commented on FLINK-4596:
---
Github user tillrohrmann commented on a diff in the pull
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
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-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15547946#comment-15547946
]
ASF GitHub Bot commented on FLINK-4596:
---
GitHub user nguraja opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548044#comment-15548044
]
ASF GitHub Bot commented on FLINK-4329:
---
GitHub user kl0u opened a pull request:
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548816#comment-15548816
]
ASF GitHub Bot commented on FLINK-4677:
---
Github user asfgit closed the pull request at:
[
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:
Till Rohrmann created FLINK-4746:
Summary: Replace TaskManagerRuntimeInfo by TaskManagerConfiguration
Key: FLINK-4746
URL: https://issues.apache.org/jira/browse/FLINK-4746
Project: Flink
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:
[
https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548618#comment-15548618
]
ASF GitHub Bot commented on FLINK-4746:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15548796#comment-15548796
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
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
1 - 100 of 218 matches
Mail list logo
