GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5660
[FLINK-8861] [table] Add support for batch queries in SQL Client
## What is the purpose of the change
This PR added support for batch queries in SQL Client.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389906#comment-16389906
]
ASF GitHub Bot commented on FLINK-8861:
---
GitHub user xccui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8892.
---
Resolution: Duplicate
Fix Version/s: (was: 1.6.0)
> Travis Build: Failed to
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r172934683
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390155#comment-16390155
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390157#comment-16390157
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390152#comment-16390152
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390156#comment-16390156
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390154#comment-16390154
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172972120
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8877.
---
> Configure Kryo's log level based on Flink's log level
>
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8876.
-
Resolution: Fixed
Fixed by resolving all sub-issues
> Improve concurrent access handling in
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8876.
---
> Improve concurrent access handling in stateful serializers
>
[
https://issues.apache.org/jira/browse/FLINK-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8878.
-
Resolution: Fixed
Fixed in
- 1.5.0 via 8a77dbf16febea72d389b2dc497e63cb768a3d2d
- 1.6.0 via
[
https://issues.apache.org/jira/browse/FLINK-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8877.
-
Resolution: Fixed
Fixed in
- 1.5.0 via b0418b41f8fa02d3217b760c5bdfcdd7efdc1eac
- 1.6.0 via
[
https://issues.apache.org/jira/browse/FLINK-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8878.
---
> Check for concurrent access to Kryo Serializer
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389934#comment-16389934
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5645
Merging this after fixing the comment...
---
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389933#comment-16389933
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5645#discussion_r172939401
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
---
@@ -163,8 +224,9 @@ public T copy(T
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172963487
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172972943
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172972678
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172972454
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172972736
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390175#comment-16390175
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390204#comment-16390204
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390206#comment-16390206
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5656#discussion_r172980021
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,333 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5656#discussion_r172980585
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,333 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5656#discussion_r172979459
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -223,6 +224,81 @@
}
}
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5656#discussion_r172978813
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/time/Deadline.java ---
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5656#discussion_r172978556
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/time/Deadline.java ---
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5634
@tweise @tzulitai
I would suggest to solve this the following way, which should be both
simple and cover our cases:
- We extend the current periodic watermark generators for
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5620
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5643
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5646
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5614
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5655
This code is (except for lambdas) identical to #5654
Please apply the same changes here as to the other PR (with regard to the
review comments).
---
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390207#comment-16390207
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390205#comment-16390205
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390208#comment-16390208
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390163#comment-16390163
]
ASF GitHub Bot commented on FLINK-8824:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390162#comment-16390162
]
ASF GitHub Bot commented on FLINK-8827:
---
Github user asfgit closed the pull request at:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5654#discussion_r172977111
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,387 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390174#comment-16390174
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8879.
---
> Add concurrent access check to AvroSerializer
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-8879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8879.
-
Resolution: Fixed
Fixed in
- 1.5.0 via 6ec1b784e5fea4d9d5208d44caf6fefde14f4aa8
- 1.6.0 via
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-8863:
--
Assignee: Xingcan Cui
> Add user-defined function support in SQL Client
>
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5634
@tzulitai @StephanEwen the current idleness detection in the source context
isn't a replacement for what is required to deal with an inactive partition (or
Kinesis shard). When a connector subtask
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389940#comment-16389940
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user tweise commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390201#comment-16390201
]
ASF GitHub Bot commented on FLINK-8799:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8824.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in
- 1.5.0 via
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390245#comment-16390245
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user StephanEwen commented on the issue:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5659
[FLINK-8661] [table] Add support for batch queries in SQL Client
## What is the purpose of the change
This PR added support for batch queries in SQL Client.
## Brief change log
Bowen Li created FLINK-8892:
---
Summary: Travis Build: Failed to execute goal
org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test (integration-tests)
on project flink-tests_2.11
Key: FLINK-8892
URL:
[
https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389898#comment-16389898
]
ASF GitHub Bot commented on FLINK-8661:
---
GitHub user xccui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390153#comment-16390153
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff in the pull
Github user xccui closed the pull request at:
https://github.com/apache/flink/pull/5659
---
[
https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389900#comment-16389900
]
ASF GitHub Bot commented on FLINK-8661:
---
Github user xccui closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390026#comment-16390026
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390024#comment-16390024
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390025#comment-16390025
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r172935414
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r172935214
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5617#discussion_r172979651
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -172,6 +181,88 @@ public AbstractYarnClusterDescriptor(
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8827.
-
Resolution: Fixed
Fix Version/s: 1.6.0
1.5.0
Fixed in
- 1.5.0 via
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8824.
---
> In Kafka Consumers, replace 'getCanonicalName()' with 'getClassName()'
>
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8827.
---
> When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed
>
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390255#comment-16390255
]
Stephan Ewen commented on FLINK-8867:
-
I would suggest that the fact that these follow-up exceptions
[
https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390365#comment-16390365
]
Thomas Weise commented on FLINK-5697:
-
For idleness detection see:
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390326#comment-16390326
]
Che Lui Shum commented on FLINK-7129:
-
Hi [~fhueske] and [~dawidwys], may I ask if there is any update
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390467#comment-16390467
]
Rong Rong commented on FLINK-8690:
--
I created one of the initial (not at all perfect) support trying to
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5634
This is a good proposal, it should also survive a general connector
refactor that will be necessary to address other code duplication. The Kinesis
ticket is
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390362#comment-16390362
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user tweise commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390632#comment-16390632
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r173048697
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390689#comment-16390689
]
Sihua Zhou commented on FLINK-4811:
---
This jira's state is still Unresolved, I think this has been
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r173048763
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390623#comment-16390623
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390622#comment-16390622
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8790:
--
Fix Version/s: (was: 1.5.0)
1.6.0
> Improve performance for recovery from
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390847#comment-16390847
]
Shashank Agarwal commented on FLINK-8867:
-
[~StephanEwen] [~srichter] You can check full logs at
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390813#comment-16390813
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5573
@zentol it seems the Travis CI has some problem, always build failed.
Please review my latest change.
---
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r173049537
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
---
@@
aitozi created FLINK-8893:
-
Summary: NPE when netty try to allocate directBuffer
Key: FLINK-8893
URL: https://issues.apache.org/jira/browse/FLINK-8893
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389832#comment-16389832
]
Stephan Ewen commented on FLINK-8828:
-
[~fhueske] and [~twalthr] Please have a look at [~jelmer]'s
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5645#discussion_r172922843
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
---
@@ -163,8 +224,9 @@ public T copy(T from, T
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389855#comment-16389855
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user zentol commented on a diff in the pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5658
[FLINK-8856] [TaskManager] Move all cancellation interrupt calls to
TaskCanceller thread
## What is the purpose of the change
This cleans up the code and guards against a JVM bug
[
https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389860#comment-16389860
]
ASF GitHub Bot commented on FLINK-8856:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8845:
--
Summary: Use WriteBatch to improve performance for recovery in RocksDB
backend (was: Introduce
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5652
yup. But one profile is already scratching the 50m limit as is :/
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5648#discussion_r172775779
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -404,16 +404,25 @@ public void start() throws Exception {
Chesnay Schepler created FLINK-8889:
---
Summary: Do not override config values in
TestBaseUtils#startCluster
Key: FLINK-8889
URL: https://issues.apache.org/jira/browse/FLINK-8889
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8890:
Summary: Compare checkpoints with order in
CompletedCheckpoint.checkpointsMatch() (was:
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389228#comment-16389228
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user yanghua commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5652
All legacy tests going through the `MiniClusterResource` will take longer.
I don't know by how much, but we now have to start multiple actor systems and
the JM<->TM communication is no longer local.
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5632
hi @zentol , it seems @tillrohrmann has no free time recently. Would you
please review this?
---
1 - 100 of 211 matches
Mail list logo
