[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352332#comment-16352332
]
ASF GitHub Bot commented on FLINK-8503:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352333#comment-16352333
]
ASF GitHub Bot commented on FLINK-8503:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5353#discussion_r165950588
--- Diff:
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java ---
@@ -285,11 +287,22 @@ private static String
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5353#discussion_r165962518
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java
---
@@ -222,7 +221,13 @@ public File getStorageLocation(@Nullable
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6557:
Description:
The {{RocksDBKeyedStateBackend}} cannot be used on Windows. We pass the result
Jürgen Thomann created FLINK-8560:
-
Summary: Access to the current key in ProcessFunction after keyBy()
Key: FLINK-8560
URL: https://issues.apache.org/jira/browse/FLINK-8560
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6557:
Summary: RocksDBKeyedStateBackend broken on Windows (was:
RocksDbStateBackendTest fails on
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6557:
Affects Version/s: 1.5.0
> RocksDbStateBackendTest fails on Windows
>
[
https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8270:
---
Assignee: Shuyi Chen
> TaskManagers do not use correct local path for shipped Keytab
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352310#comment-16352310
]
Kostas Kloudas commented on FLINK-7756:
---
Hi [~shashank734],
Is there any possibility to provide us
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8559:
Affects Version/s: 1.4.0
> Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8559:
---
Assignee: (was: Chesnay Schepler)
> Exceptions in
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8559:
---
Assignee: Chesnay Schepler
> Exceptions in
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Affects Version/s: (was: 1.4.0)
> OperatorSubtaskDescriptionText causes failures on
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Description: File-based state backends that use the description provided by
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Affects Version/s: 1.4.0
> OperatorSubtaskDescriptionText causes failures on Windows
>
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8559:
Description:
In the {{RocksDBKeyedStatebackend#snapshotIncrementally}} we can find this
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8559:
Description:
In the {{RocksDBStatebackend#snapshotIncrementally}} we can find this code
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352280#comment-16352280
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352284#comment-16352284
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352282#comment-16352282
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352283#comment-16352283
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352279#comment-16352279
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352281#comment-16352281
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165943080
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java
---
@@ -131,10 +131,14 @@ public
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165945174
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BufferBlockerTest.java
---
@@ -0,0 +1,322 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352278#comment-16352278
]
ASF GitHub Bot commented on FLINK-8547:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165943880
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BufferBlockerTest.java
---
@@ -0,0 +1,322 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8559:
Summary: Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot
cause job to get
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165933824
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CreditBasedBarrierBuffer.java
---
@@ -0,0 +1,529 @@
+/*
+ *
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165930338
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
---
@@ -184,6 +184,18 @@
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165942614
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CreditBasedBarrierBuffer.java
---
@@ -0,0 +1,529 @@
+/*
+ *
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r165930413
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CreditBasedBarrierBuffer.java
---
@@ -0,0 +1,529 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8559:
Description:
The
[
https://issues.apache.org/jira/browse/FLINK-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352259#comment-16352259
]
ASF GitHub Bot commented on FLINK-8495:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352260#comment-16352260
]
ASF GitHub Bot commented on FLINK-8495:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5341#discussion_r165941154
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java
---
@@ -473,10 +476,55 @@ public WebMonitorEndpoint(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5341#discussion_r165942186
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java
---
@@ -473,10 +476,55 @@ public WebMonitorEndpoint(
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5406
:satisfied: , I addressed your comments.
---
[
https://issues.apache.org/jira/browse/FLINK-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-6260.
---
Resolution: Duplicate
This issue is a duplicate of FLINK-6335 and FLINK-6373.
> Distinct Aggregates
[
https://issues.apache.org/jira/browse/FLINK-8493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352241#comment-16352241
]
ASF GitHub Bot commented on FLINK-8493:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5339#discussion_r165939136
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352233#comment-16352233
]
ASF GitHub Bot commented on FLINK-8243:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352234#comment-16352234
]
ASF GitHub Bot commented on FLINK-8242:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5344
Merging
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5345
Merging
---
Chesnay Schepler created FLINK-8559:
---
Summary: JobManagerHACheckpointRecoveryITCase runs indefinitely on
Windows
Key: FLINK-8559
URL: https://issues.apache.org/jira/browse/FLINK-8559
Project: Flink
Timo Walther created FLINK-8558:
---
Summary: Add unified format interfaces and format discovery
Key: FLINK-8558
URL: https://issues.apache.org/jira/browse/FLINK-8558
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Component/s: Tests
> OperatorSubtaskDescriptionText causes failures on Windows
>
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Description: File-based state backends that use the description provided by
[
https://issues.apache.org/jira/browse/FLINK-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8557:
Description: File-based state backends that use the description provided by
Chesnay Schepler created FLINK-8557:
---
Summary: OperatorSubtaskDescriptionText causes failures on Windows
Key: FLINK-8557
URL: https://issues.apache.org/jira/browse/FLINK-8557
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1635#comment-1635
]
Timo Walther commented on FLINK-8538:
-
[~xccui] thanks for working on this issue. This issue depends
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4809.
-
Resolution: Fixed
Fix Version/s: (was: 1.4.0)
1.5.0
Merged in
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reopened FLINK-4809:
---
> Operators should tolerate checkpoint failures
> -
>
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4809.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Merged in
[
https://issues.apache.org/jira/browse/FLINK-8551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352205#comment-16352205
]
Fabian Hueske commented on FLINK-8551:
--
If I understand the issue correctly, you are suggesting to
[
https://issues.apache.org/jira/browse/FLINK-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352182#comment-16352182
]
ASF GitHub Bot commented on FLINK-8550:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5404
merging.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5408
merging,
---
[
https://issues.apache.org/jira/browse/FLINK-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352176#comment-16352176
]
ASF GitHub Bot commented on FLINK-8550:
---
Github user fhueske commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5407
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8552:
Fix Version/s: (was: 1.4.0)
> CliFrontend don't exit normal after job has been
[
https://issues.apache.org/jira/browse/FLINK-8552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-8552:
-
reopen for fixVersion
> CliFrontend don't exit normal after job has been submitted with
[
https://issues.apache.org/jira/browse/FLINK-8552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8552.
---
Resolution: Not A Problem
By default the client process will continue to run and print status
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5404
Thanks for the PR @hequn8128!
Changes look good, +1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-8552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8552.
---
Resolution: Not A Problem
> CliFrontend don't exit normal after job has been submitted with
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5406#discussion_r165916481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolGateway.java
---
@@ -108,7 +108,7 @@
* individually
[
https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352167#comment-16352167
]
ASF GitHub Bot commented on FLINK-6571:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5394
How about calling `Thread.currentThread().interrupt();` only after having
left the loop?
```
public void run(SourceContext ctx) throws Exception {
boolean setInterruptFlag = false;
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352146#comment-16352146
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user suez1224 commented on the issue:
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5172
@tzulitai thanks a lot for the refactoring, the commit looks good to me.
---
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352118#comment-16352118
]
Bowen Li commented on FLINK-3089:
-
[~srichter] can you elaborate more on "or we could try to correlate
101 - 173 of 173 matches
Mail list logo
