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
Compone
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390847#comment-16390847
]
Shashank Agarwal commented on FLINK-8867:
-
[~StephanEwen] [~srichter] You can chec
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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.
---
[
https://issues.apache.org/jira/browse/FLINK-4811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390689#comment-16390689
]
Sihua Zhou commented on FLINK-4811:
---
This jira's state is still Unresolved, I think this
[
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 increme
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390632#comment-16390632
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff i
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
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390623#comment-16390623
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390622#comment-16390622
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user sihuazhou commented on a diff i
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
---
@@ -0,0
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
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390467#comment-16390467
]
Rong Rong commented on FLINK-8690:
--
I created one of the initial (not at all perfect) sup
[
https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390365#comment-16390365
]
Thomas Weise commented on FLINK-5697:
-
For idleness detection see: [https://github.com
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390362#comment-16390362
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user tweise commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390326#comment-16390326
]
Che Lui Shum commented on FLINK-7129:
-
Hi [~fhueske] and [~dawidwys], may I ask if the
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390255#comment-16390255
]
Stephan Ewen commented on FLINK-8867:
-
I would suggest that the fact that these follow
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390245#comment-16390245
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user StephanEwen commented on the is
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 i
[
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-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 resolved FLINK-8827.
-
Resolution: Fixed
Fix Version/s: 1.6.0
1.5.0
Fixed in
- 1.5.0 via af9a
[
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 70347bcc788dea1d4f64539701e60
[
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-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 state
[
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 57
[
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 06
[
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-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-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 be
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390208#comment-16390208
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390207#comment-16390207
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390205#comment-16390205
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390206#comment-16390206
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390204#comment-16390204
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
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 @@
+/*
+ * Licen
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_r172980021
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java
---
@@ -0,0 +1,333 @@
+/*
+ * Licen
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 Fo
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 Fo
[
https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390201#comment-16390201
]
ASF GitHub Bot commented on FLINK-8799:
---
Github user GJL commented on a diff in the
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-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390175#comment-16390175
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390174#comment-16390174
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on the is
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 @@
+/*
+ * Licen
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-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 execute
[
https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390163#comment-16390163
]
ASF GitHub Bot commented on FLINK-8824:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390162#comment-16390162
]
ASF GitHub Bot commented on FLINK-8827:
---
Github user asfgit closed the pull request
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 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
---
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390153#comment-16390153
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390154#comment-16390154
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390152#comment-16390152
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390156#comment-16390156
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390155#comment-16390155
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390157#comment-16390157
]
ASF GitHub Bot commented on FLINK-8487:
---
Github user StephanEwen commented on a diff
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
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 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390025#comment-16390025
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390026#comment-16390026
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390024#comment-16390024
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff i
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
---
@@ -0,0
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
---
@@ -0,0
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
---
@@ -0,0
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 con
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389940#comment-16389940
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user tweise commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389934#comment-16389934
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on the is
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&focusedCommentId=16389933#comment-16389933
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on a diff
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 fro
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389906#comment-16389906
]
ASF GitHub Bot commented on FLINK-8861:
---
GitHub user xccui opened a pull request:
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-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389900#comment-16389900
]
ASF GitHub Bot commented on FLINK-8661:
---
Github user xccui closed the pull request a
Github user xccui closed the pull request at:
https://github.com/apache/flink/pull/5659
---
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
[
https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389898#comment-16389898
]
ASF GitHub Bot commented on FLINK-8661:
---
GitHub user xccui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389860#comment-16389860
]
ASF GitHub Bot commented on FLINK-8856:
---
GitHub user StephanEwen opened a pull reque
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 where
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389855#comment-16389855
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user zentol commented on a diff in t
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-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389832#comment-16389832
]
Stephan Ewen commented on FLINK-8828:
-
[~fhueske] and [~twalthr] Please have a look at
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5646
Thanks for catching this.
Merging...
---
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389793#comment-16389793
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5645#discussion_r172911926
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
---
@@ -163,8 +224,19 @@ public T copy(T fr
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389779#comment-16389779
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5645
@zentol Have a look at the way I solved that above, see if you agree that
we covered our bases now.
---
[
https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389778#comment-16389778
]
ASF GitHub Bot commented on FLINK-8101:
---
Github user jdewald commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389777#comment-16389777
]
ASF GitHub Bot commented on FLINK-8876:
---
Github user StephanEwen commented on a diff
Github user jdewald commented on the issue:
https://github.com/apache/flink/pull/5374
We were in the process of testing the Flink integration with the ES High
Level Rest client in order to perform upgrades to ES6 and stumbled on some
issues related to the bulk rejection retry handling
1 - 100 of 211 matches
Mail list logo
