Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5918
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5006
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5952
---
[
https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465485#comment-16465485
]
ASF GitHub Bot commented on FLINK-9287:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5956
---
[
https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465484#comment-16465484
]
ASF GitHub Bot commented on FLINK-9169:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5950
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5836
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465529#comment-16465529
]
ASF GitHub Bot commented on FLINK-9125:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465563#comment-16465563
]
ASF GitHub Bot commented on FLINK-9125:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/5933#discussion_r186347318
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -59,6 +60,8 @@
[
https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8064.
Resolution: Fixed
Fix Version/s: 1.5.0
> Extend dependency section to list
[
https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465508#comment-16465508
]
ASF GitHub Bot commented on FLINK-9141:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5907
merging.
---
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5933
@zentol please review again, if you have time.
---
[
https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465562#comment-16465562
]
ASF GitHub Bot commented on FLINK-9125:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465561#comment-16465561
]
ASF GitHub Bot commented on FLINK-9235:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465486#comment-16465486
]
Tzu-Li (Gordon) Tai commented on FLINK-9287:
Merged.
1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-9169.
Resolution: Fixed
> NPE when restoring from old savepoint and state serializer
[
https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-9287.
Resolution: Fixed
> KafkaProducer011 seems to leak threads when not in exactly-once
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/5933#discussion_r186346559
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -59,6 +60,8 @@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5953#discussion_r186343907
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -85,21 +91,56 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465495#comment-16465495
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186338049
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186337834
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186338002
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186337736
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186337890
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186338721
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186337301
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
@@ -78,6
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186339587
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -25,27 +25,25 @@ under the License.
* ToC
{:toc}
-[Working with
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186342816
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186341293
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186342376
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465566#comment-16465566
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5834
@zentol this PR also reviewed by you, and takes a long time, can you review
this? thanks~
---
[
https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465487#comment-16465487
]
Tzu-Li (Gordon) Tai commented on FLINK-8064:
Merged (updating the QS documentation to list the
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465496#comment-16465496
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465499#comment-16465499
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465497#comment-16465497
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465501#comment-16465501
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465500#comment-16465500
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465498#comment-16465498
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5538
We would have to pass the keyspace via the constructor as the
`Configuration` approach doesn't work for streaming.
Generally speaking it isn't a problem to set the keyspace when creating the
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465505#comment-16465505
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465525#comment-16465525
]
ASF GitHub Bot commented on FLINK-8912:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465548#comment-16465548
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465549#comment-16465549
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465542#comment-16465542
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465545#comment-16465545
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465543#comment-16465543
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465547#comment-16465547
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465544#comment-16465544
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186341972
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465541#comment-16465541
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465546#comment-16465546
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186341885
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186341059
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186340944
--- Diff: docs/dev/stream/state/broadcast_state.md ---
@@ -0,0 +1,279 @@
+---
+title: "The Broadcast State Pattern"
+nav-parent_id:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5922#discussion_r186340110
--- Diff: docs/dev/stream/state/index.md ---
@@ -49,6 +49,7 @@ Where to go next?
-
* [Working with State](state.html): Shows
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5933#discussion_r186345933
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -59,6 +60,8 @@
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/5960
[Flink-8725] Separate state from NFA in CEP library
## What is the purpose of the change
* Separate state from NFA, especially do not serialize user classes like
`Condition`
##
[
https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5763:
Fix Version/s: (was: 1.6.0)
> Make savepoints self-contained and relocatable
>
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9073:
Priority: Blocker (was: Critical)
> Resume from savepoint end-to-end tests should be
[
https://issues.apache.org/jira/browse/FLINK-9074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9074:
Priority: Blocker (was: Major)
> End-to-end test: Resume from retained checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9282:
---
Assignee: Alex Chen
> Update quickstart page
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465694#comment-16465694
]
Chesnay Schepler commented on FLINK-9282:
-
In 1.5 the {{Dispatcher}} runs the web frontend, not
[
https://issues.apache.org/jira/browse/FLINK-9074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9074:
Fix Version/s: 1.6.0
> End-to-end test: Resume from retained checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465709#comment-16465709
]
Stephan Ewen commented on FLINK-7001:
-
Improving windowing performance is something we are also very
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465736#comment-16465736
]
Stephan Ewen commented on FLINK-8933:
-
My first thought would be to incrementally refactor this,
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465798#comment-16465798
]
Chesnay Schepler commented on FLINK-8933:
-
There are only ~100 usages (40 in flink-table alone), i
Github user W4anD0eR96 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5957#discussion_r186373455
--- Diff: docs/quickstart/setup_quickstart.md ---
@@ -233,29 +239,17 @@ window of processing time, as long as words are
floating in.
* First
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8867.
---
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.5.0)
Closing for now because
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5953#discussion_r186350483
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -85,21 +91,56 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465577#comment-16465577
]
ASF GitHub Bot commented on FLINK-9235:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9295:
--
Fix Version/s: 1.5.0
> FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5959
[FLINK-9258][metrics] Thread-safe initialization of variables map
## What is the purpose of the change
This PR fixes a thread-safety issue in `ComponentMetricGroup` where a map
was assigned
Nico Kruber created FLINK-9305:
--
Summary: Register flink-s3-fs-* for the s3a:// scheme as well
Key: FLINK-9305
URL: https://issues.apache.org/jira/browse/FLINK-9305
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-9306:
---
Summary: Execute YARN IT tests for legacy and new mode
Key: FLINK-9306
URL: https://issues.apache.org/jira/browse/FLINK-9306
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-9306:
---
Assignee: Aljoscha Krettek
> Execute YARN IT tests for legacy and new mode
>
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465681#comment-16465681
]
ASF GitHub Bot commented on FLINK-9282:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5957#discussion_r186374883
--- Diff: docs/quickstart/setup_quickstart.md ---
@@ -233,29 +239,17 @@ window of processing time, as long as words are
floating in.
* First of
GitHub user snuyanzin opened a pull request:
https://github.com/apache/flink/pull/5961
[Flink-8255][DataSet API, DataStream API] key expressions on named row
types do not work
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9305:
---
Description: For enhanced user experience, we should also register our
Hadoop S3A-based shaded S3
[
https://issues.apache.org/jira/browse/FLINK-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9250.
---
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.5.0)
Closing for now until we
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465763#comment-16465763
]
Fabian Hueske commented on FLINK-2435:
--
Hi [~dmitry_kober], thanks for the update!
I'm sorry for the
Github user pavel-shvetsov-git commented on the issue:
https://github.com/apache/flink/pull/5927
Message has been improved as suggested.
---
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465628#comment-16465628
]
ASF GitHub Bot commented on FLINK-8237:
---
Github user pavel-shvetsov-git commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5763:
Priority: Critical (was: Blocker)
> Make savepoints self-contained and relocatable
>
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465692#comment-16465692
]
Alex Chen commented on FLINK-9282:
--
[~Zentol] Sorry but what do you mean by "refer to the Dispatcher's
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5902#discussion_r186376796
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
---
@@ -162,7 +166,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465742#comment-16465742
]
ASF GitHub Bot commented on FLINK-8533:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5427
Thanks a lot, looks good, can merge this now.
One quick question: You decided to have empty default implementations for
the new methods in the master hook interface. Given that Pravega
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5917
@hzyuemeng1 The fix looks good. However, it's a bug in the Trigger and I
think therefore the test for this should also go into `EventTimeTriggerTest`.
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5957#discussion_r186351709
--- Diff: docs/quickstart/setup_quickstart.md ---
@@ -233,29 +239,17 @@ window of processing time, as long as words are
floating in.
* First of
Stefan Richter created FLINK-9304:
-
Summary: Timer service shutdown should not be interrupted
Key: FLINK-9304
URL: https://issues.apache.org/jira/browse/FLINK-9304
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465611#comment-16465611
]
ASF GitHub Bot commented on FLINK-9258:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465696#comment-16465696
]
Alex Chen commented on FLINK-9282:
--
Get it.
> Update quickstart page
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9073:
Fix Version/s: (was: 1.5.0)
1.6.0
> Resume from savepoint end-to-end
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8979:
Fix Version/s: (was: 1.5.1)
> Extend Kafka end-to-end tests to run with different
1 - 100 of 275 matches
Mail list logo
