[
https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8783.
--
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via
1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396634#comment-16396634
]
ASF GitHub Bot commented on FLINK-8783:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5684
---
Till Rohrmann created FLINK-8934:
Summary: Cancel slot requests for otherwisely fulfilled requests
Key: FLINK-8934
URL: https://issues.apache.org/jira/browse/FLINK-8934
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396625#comment-16396625
]
ASF GitHub Bot commented on FLINK-8783:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: (was: Wei-Che Wei)
> Checkpoint Coordinator should be called to restore state
[
https://issues.apache.org/jira/browse/FLINK-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396644#comment-16396644
]
ASF GitHub Bot commented on FLINK-8934:
---
GitHub user tillrohrmann opened a pull request:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5684
Thanks for the review @GJL. Merging this PR.
---
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5687
[FLINK-8934] [flip6] Properly cancel slot requests of otherwisely fulfilled
requests
## What is the purpose of the change
Cancel slot requests at the ResourceManager if they have been
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8907:
Priority: Minor (was: Blocker)
> Unable to start the process by start-cluster.sh
>
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396707#comment-16396707
]
Chesnay Schepler edited comment on FLINK-8907 at 3/13/18 9:01 AM:
--
I
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396738#comment-16396738
]
mingleizhang commented on FLINK-8907:
-
I think I can try WSL also. What tools you compile flink on
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396790#comment-16396790
]
Chesnay Schepler commented on FLINK-8907:
-
I don't copy anything but directly access the
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/5479
Sure, I've added a test.
---
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396735#comment-16396735
]
mingleizhang commented on FLINK-8907:
-
Hi, [~Zentol] Did you also copy the folder (flink build folder)
[
https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396749#comment-16396749
]
Fabian Hueske commented on FLINK-8828:
--
IMO, the issue of implicit conversions is unrelated to this
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5632
Thanks for the PR @yanghua, I'll take a look asap.
---
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5689
[FLINK-4569][tests] Respect exceptions thrown in thread in
JobRetrievalITCase
## What is the purpose of the change
This PR ensures that exceptions that occur in the submitting thread
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396701#comment-16396701
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5632
hi @tillrohrmann I think you should review this PR and add it to 1.5
version as a hotfix. Because I just download the release-1.5 branch. And
install it as standalone-session mode. But the general
[
https://issues.apache.org/jira/browse/FLINK-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396761#comment-16396761
]
ASF GitHub Bot commented on FLINK-8934:
---
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/5687#discussion_r174060373
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTest.java
---
@@ -505,17 +513,21 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396748#comment-16396748
]
ASF GitHub Bot commented on FLINK-8919:
---
Github user liurenjie1024 commented on the issue:
Github user liurenjie1024 commented on the issue:
https://github.com/apache/flink/pull/5680
Can anyone help to merge this?
---
[
https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396836#comment-16396836
]
Sihua Zhou commented on FLINK-8922:
---
After having some tried (bumping {{rocksdbjni}} to higher version,
[
https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396865#comment-16396865
]
ASF GitHub Bot commented on FLINK-4569:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396707#comment-16396707
]
Chesnay Schepler commented on FLINK-8907:
-
I can't reproduce this. I'm always compile on windows,
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396797#comment-16396797
]
mingleizhang commented on FLINK-8907:
-
Thanks, But It seems that I can not use WSL since I use
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396807#comment-16396807
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396809#comment-16396809
]
mingleizhang commented on FLINK-8907:
-
When I solved this issue, I will ping you. I will set all files
GitHub user liurenjie1024 opened a pull request:
https://github.com/apache/flink/pull/5688
[FLINK-6968][Table API & SQL] Add Queryable table sink.
## What is the purpose of the change
Streaming tables with unique key are continuously updated. For example
queries with a
[
https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396822#comment-16396822
]
ASF GitHub Bot commented on FLINK-6968:
---
GitHub user liurenjie1024 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396856#comment-16396856
]
ASF GitHub Bot commented on FLINK-8649:
---
Github user ggevay commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396909#comment-16396909
]
mingleizhang commented on FLINK-8907:
-
I can use the below to watch , but I can access from another
[
https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396953#comment-16396953
]
ASF GitHub Bot commented on FLINK-4569:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396887#comment-16396887
]
mingleizhang commented on FLINK-8907:
-
Hello guys, There are good news and bad news, good news are I
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396910#comment-16396910
]
ASF GitHub Bot commented on FLINK-8802:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396927#comment-16396927
]
ASF GitHub Bot commented on FLINK-8919:
---
Github user fhueske commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5676
CC @tillrohrmann
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174128377
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396943#comment-16396943
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user zentol 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/5689#discussion_r174135885
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java
---
@@ -119,6 +121,11 @@ public void run() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5689#discussion_r174140412
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java
---
@@ -119,6 +121,11 @@ public void run() {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174145613
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174148331
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/5691
[FLINK-8802] [QS] Fix concurrent access to non-duplicated serializers.
## What is the purpose of the change
This fixes the problem of multiple threads using the same serializer
instance to
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396994#comment-16396994
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user kl0u commented on a diff in the pull request:
Chesnay Schepler created FLINK-8935:
---
Summary: Implement remaining methods in MiniClusterClient
Key: FLINK-8935
URL: https://issues.apache.org/jira/browse/FLINK-8935
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396873#comment-16396873
]
ASF GitHub Bot commented on FLINK-8935:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5690
[FLINK-8935][tests] Extend MiniClusterClient
## What is the purpose of the change
With this PR the `MiniClusterClient` implements `listJobs()`,
`getAccumulators()`, `triggerSavepoint()` and
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396934#comment-16396934
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396968#comment-16396968
]
ASF GitHub Bot commented on FLINK-4569:
---
Github user zentol commented on a diff in the pull request:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5680
The purpose of unit tests is not only to validate that the new feature
works as expected but also to ensure that the functionality is not broken by
future changes.
So even if the code is copied,
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174133415
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
[
https://issues.apache.org/jira/browse/FLINK-8906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396965#comment-16396965
]
ASF GitHub Bot commented on FLINK-8906:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5671#discussion_r174139638
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -567,7 +567,7 @@ public
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5671#discussion_r174142014
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendCancelTest.java
---
@@ -39,13 +47,27 @@
/**
* Tests for the
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396949#comment-16396949
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396971#comment-16396971
]
ASF GitHub Bot commented on FLINK-8906:
---
Github user StefanRRichter commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174144247
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396988#comment-16396988
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397008#comment-16397008
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user zentol commented on a diff in the pull request:
Kailash Hassan Dayanand created FLINK-8936:
--
Summary: Provide only AWS region or endpoint in line with the SDK
Key: FLINK-8936
URL: https://issues.apache.org/jira/browse/FLINK-8936
Project:
[
https://issues.apache.org/jira/browse/FLINK-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397089#comment-16397089
]
Florian Schmidt commented on FLINK-8937:
[~aljoscha] any opinions on this?
> Refactor flink
Florian Schmidt created FLINK-8937:
--
Summary: Refactor flink end-to-end test skeleton
Key: FLINK-8937
URL: https://issues.apache.org/jira/browse/FLINK-8937
Project: Flink
Issue Type:
GitHub user florianschmidt1994 opened a pull request:
https://github.com/apache/flink/pull/5692
[docs] Fix typo in Python API docs
Rename `Tockenizer` to `Tokenizer` in python docs
You can merge this pull request into a Git repository by running:
$ git pull
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174150658
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/server/KvStateServerHandler.java
---
@@ -78,13
Github user florianschmidt1994 commented on the issue:
https://github.com/apache/flink/pull/5692
@zentol I found this browsing through the docs
---
[
https://issues.apache.org/jira/browse/FLINK-8913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397051#comment-16397051
]
Joshua Griffith commented on FLINK-8913:
It seems like the official Flink docker image shouldn't
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397059#comment-16397059
]
ASF GitHub Bot commented on FLINK-8872:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397111#comment-16397111
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r174165460
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,450 @@
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397110#comment-16397110
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397015#comment-16397015
]
ASF GitHub Bot commented on FLINK-8802:
---
Github user kl0u commented on a diff in the pull request:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5672#discussion_r174161228
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/Flip6DefaultCLI.java ---
@@ -40,6 +40,7 @@ public Flip6DefaultCLI(Configuration
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r174175230
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,450 @@
[
https://issues.apache.org/jira/browse/FLINK-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397284#comment-16397284
]
ASF GitHub Bot commented on FLINK-8934:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397194#comment-16397194
]
ASF GitHub Bot commented on FLINK-8872:
---
Github user StefanRRichter commented on a diff in the pull
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5687
Thanks for the review @zentol. I'll make the naming a bit clearer and then
merge the PR.
---
[
https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397830#comment-16397830
]
ASF GitHub Bot commented on FLINK-8862:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5639
Thanks for the PR @neoremind.
At the moment, the community is busy working on the 1.5 release which means
that PRs for 1.5 fixes have priority right now. Also a large contribution such
as this
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397849#comment-16397849
]
Fabian Hueske commented on FLINK-6075:
--
Hi [~yinhua], that is not a limitation of Calcite. In
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5687
---
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397324#comment-16397324
]
ASF GitHub Bot commented on FLINK-8843:
---
Github user GJL commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8934.
Resolution: Fixed
Fixed via
1.6.0: 445cdfd57941c4c888a6e73356558fd5f11d443c
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397309#comment-16397309
]
ASF GitHub Bot commented on FLINK-8934:
---
Github user asfgit closed the pull request at:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5632
I'll verify the changes @yanghua
---
[
https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8891:
---
Assignee: Gary Yao
> RestServerEndpoint can bind on local address only
>
[
https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8843:
---
Assignee: Gary Yao (was: vinoyang)
> Decouple bind REST address from advertised address
>
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397379#comment-16397379
]
ASF GitHub Bot commented on FLINK-7521:
---
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/5685#discussion_r174225988
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FlinkHttpObjectAggregator.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397394#comment-16397394
]
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=16397393#comment-16397393
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8812:
Assignee: Till Rohrmann
> Possible resource leak in Flip6
>
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r174231064
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapperTest.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r174230739
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapperTest.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r174231142
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapperTest.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5650#discussion_r174231173
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapperTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397395#comment-16397395
]
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=16397392#comment-16397392
]
ASF GitHub Bot commented on FLINK-8845:
---
Github user bowenli86 commented on a diff in the pull
1 - 100 of 136 matches
Mail list logo
