Deepak Sharma created FLINK-9503:
Summary: Migrate integration tests for iterative aggregators
Key: FLINK-9503
URL: https://issues.apache.org/jira/browse/FLINK-9503
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9484:
-
Description:
User-defined function has been a great extension for Flink SQL API to support
much complex
[
https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9502:
-
Description:
This ticket is to enable generic Object type as element type by using SQL ANY
in parameter
Rong Rong created FLINK-9502:
Summary: Use generic parameter search for user-define functions
when argument contains Object type
Key: FLINK-9502
URL: https://issues.apache.org/jira/browse/FLINK-9502
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Description:
Idea here is to treat every Java parameter objects type as SQL ANY type. While
[
https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9501:
-
Summary: Allow Object or Wildcard type in user-define functions as
parameter types but not result types
Rong Rong created FLINK-9501:
Summary: Allow Object.class type in user-define functions as
parameter types but not result types
Key: FLINK-9501
URL: https://issues.apache.org/jira/browse/FLINK-9501
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498691#comment-16498691
]
ASF GitHub Bot commented on FLINK-9483:
---
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/6109#discussion_r192535262
--- Diff: docs/start/building.md ---
@@ -50,7 +50,11 @@ mvn clean install -DskipTests
This instructs [Maven](http://maven.apache.org) (`mvn`) to
Chesnay Schepler created FLINK-9500:
---
Summary: FileUploadHandler does not handle EmptyLastHttpContent
Key: FLINK-9500
URL: https://issues.apache.org/jira/browse/FLINK-9500
Project: Flink
Esteban Serrano created FLINK-9499:
--
Summary: Allow REST API for running a job to provide job
configuration as body of POST request
Key: FLINK-9499
URL: https://issues.apache.org/jira/browse/FLINK-9499
[
https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498511#comment-16498511
]
Deepak Sharma edited comment on FLINK-2032 at 6/1/18 8:26 PM:
--
Hi [~NicoK],
[
https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498511#comment-16498511
]
Deepak Sharma commented on FLINK-2032:
--
Hi [~NicoK],
Is this issue still valid? I would like to
Hai Zhou created FLINK-9498:
---
Summary: Disable dependency convergence for
"flink-end-to-end-tests"
Key: FLINK-9498
URL: https://issues.apache.org/jira/browse/FLINK-9498
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinay updated FLINK-9497:
-
Component/s: Webfrontend
> Job Configuration showing the password in plain text
>
Vinay created FLINK-9497:
Summary: Job Configuration showing the password in plain text
Key: FLINK-9497
URL: https://issues.apache.org/jira/browse/FLINK-9497
Project: Flink
Issue Type: Bug
Abhinav Bajaj created FLINK-9496:
Summary: Job created time is reset after restart
Key: FLINK-9496
URL: https://issues.apache.org/jira/browse/FLINK-9496
Project: Flink
Issue Type: Bug
Elias Levy created FLINK-9495:
-
Summary: Implement ResourceManager for Kubernetes
Key: FLINK-9495
URL: https://issues.apache.org/jira/browse/FLINK-9495
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9493:
---
Assignee: vinoyang
> Forward exception when releasing a TaskManager at the SlotPool
>
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498114#comment-16498114
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user Aitozi commented on a diff in the pull
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192428502
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -383,6 +386,100 @@ public String select(Map>
pattern) {
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498112#comment-16498112
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user Aitozi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498113#comment-16498113
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user Aitozi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498111#comment-16498111
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user Aitozi commented on a diff in the pull
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192428178
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java
---
@@ -54,6 +54,12 @@
// comparator to sort events
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192428106
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192428038
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To
[
https://issues.apache.org/jira/browse/FLINK-9491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-9491:
--
Summary: Implement timer data structure based on RocksDB (was: Implement
timer service based
[
https://issues.apache.org/jira/browse/FLINK-6087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498037#comment-16498037
]
ASF GitHub Bot commented on FLINK-6087:
---
Github user ymarzougui closed the pull request at:
Github user ymarzougui closed the pull request at:
https://github.com/apache/flink/pull/3557
---
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498035#comment-16498035
]
ASF GitHub Bot commented on FLINK-7866:
---
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/4949#discussion_r192407287
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498034#comment-16498034
]
ASF GitHub Bot commented on FLINK-7866:
---
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/4949#discussion_r192406775
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/6059
Hi @dawidwys! Thanks for the work.
The changes seem really good. As we discussed privately I did a review and
the comments you can find them in the branch I sent you.
The only things
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16498020#comment-16498020
]
ASF GitHub Bot commented on FLINK-7866:
---
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/4949#discussion_r192402396
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9494:
Assignee: Till Rohrmann
> Race condition in Dispatcher with concurrent granting and
Till Rohrmann created FLINK-9494:
Summary: Race condition in Dispatcher with concurrent granting and
revoking of leaderhship
Key: FLINK-9494
URL: https://issues.apache.org/jira/browse/FLINK-9494
[
https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuqi closed FLINK-9492.
---
Resolution: Not A Bug
> Failed to build RexCall with SqlDatetimeSubtractionOperator
>
Till Rohrmann created FLINK-9493:
Summary: Forward exception when releasing a TaskManager at the
SlotPool
Key: FLINK-9493
URL: https://issues.apache.org/jira/browse/FLINK-9493
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuqi updated FLINK-9492:
Description:
When use RexBuilder to build RexCall with SqlDatetimeSubtractionOperator, it
will throw exception.
[
https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuqi updated FLINK-9492:
Environment: (was:
{code:java}
public static void main(String[] args) {
try {
yuqi created FLINK-9492:
---
Summary: Failed to build RexCall with
SqlDatetimeSubtractionOperator
Key: FLINK-9492
URL: https://issues.apache.org/jira/browse/FLINK-9492
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-9491:
-
Summary: Implement timer service based on RocksDB
Key: FLINK-9491
URL: https://issues.apache.org/jira/browse/FLINK-9491
Project: Flink
Issue Type:
Stefan Richter created FLINK-9490:
-
Summary: Provide backwards compatibility for timer state of Flink
1.5
Key: FLINK-9490
URL: https://issues.apache.org/jira/browse/FLINK-9490
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-9490:
--
Fix Version/s: 1.6.0
Component/s: State Backends, Checkpointing
> Provide backwards
Stefan Richter created FLINK-9489:
-
Summary: Checkpoint timers as part of managed keyed state instead
of raw keyed state
Key: FLINK-9489
URL: https://issues.apache.org/jira/browse/FLINK-9489
Project:
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497956#comment-16497956
]
Sihua Zhou commented on FLINK-9486:
---
[~srichter] Thanks for your reply, looking forward your PR! ;)
>
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497952#comment-16497952
]
Stefan Richter commented on FLINK-9486:
---
Hi, I am already creating the issues for planning, but I
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497946#comment-16497946
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5983
This PR superseded by https://github.com/apache/flink/pull/6091
---
Till Rohrmann created FLINK-9488:
Summary: Create common entry point for master and workers
Key: FLINK-9488
URL: https://issues.apache.org/jira/browse/FLINK-9488
Project: Flink
Issue Type:
Stefan Richter created FLINK-9487:
-
Summary: Prepare InternalTimerHeap for asynchronous snapshots
Key: FLINK-9487
URL: https://issues.apache.org/jira/browse/FLINK-9487
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-9486:
-
Assignee: Stefan Richter
> Introduce TimerState in keyed state backend
>
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/4949#discussion_r192384844
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497943#comment-16497943
]
ASF GitHub Bot commented on FLINK-7866:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497940#comment-16497940
]
Sihua Zhou commented on FLINK-9486:
---
Hi [~srichter] Do you already work on this? If not, I'd like to
[
https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7087:
-
Issue Type: Improvement (was: Bug)
> Implement Flip-6 container entry point
>
[
https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7087:
-
Fix Version/s: 1.6.0
> Implement Flip-6 container entry point
>
Stefan Richter created FLINK-9486:
-
Summary: Introduce TimerState in keyed state backend
Key: FLINK-9486
URL: https://issues.apache.org/jira/browse/FLINK-9486
Project: Flink
Issue Type:
Stefan Richter created FLINK-9485:
-
Summary: Improving Flink’s timer management for large state
Key: FLINK-9485
URL: https://issues.apache.org/jira/browse/FLINK-9485
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497923#comment-16497923
]
ASF GitHub Bot commented on FLINK-7866:
---
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/4949#discussion_r192378853
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497922#comment-16497922
]
ASF GitHub Bot commented on FLINK-7866:
---
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/4949#discussion_r192378473
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497913#comment-16497913
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497911#comment-16497911
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497912#comment-16497912
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497914#comment-16497914
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192376031
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -383,6 +386,100 @@ public String select(Map>
pattern) {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192340278
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192340339
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r192340516
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java
---
@@ -54,6 +54,12 @@
// comparator to sort events
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4949#discussion_r192376303
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java
---
@@ -203,68 +206,104 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497910#comment-16497910
]
ASF GitHub Bot commented on FLINK-7866:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497900#comment-16497900
]
ASF GitHub Bot commented on FLINK-9325:
---
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/5982#discussion_r192374992
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/ClosingAtomicCreatingFSDataOutputStream.java
---
@@ -0,0 +1,129 @@
+/*
+ * Licensed
GitHub user makeyang opened a pull request:
https://github.com/apache/flink/pull/6110
[hotfix] fix EXECUTION_FAILOVER_STRATEGY's comments error and its infâ¦
## What is the purpose of the change
fix EXECUTION_FAILOVER_STRATEGY's comments error and its info message error
##
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497882#comment-16497882
]
ASF GitHub Bot commented on FLINK-9325:
---
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/5982#discussion_r192371034
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/TwoPhaseFSDataOutputStream.java
---
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497879#comment-16497879
]
ASF GitHub Bot commented on FLINK-9325:
---
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/5982#discussion_r192370481
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/ClosingAtomicCreatingFSDataOutputStream.java
---
@@ -0,0 +1,129 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497819#comment-16497819
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5582
@StefanRRichter Thanks for your nice review and preventing this PR to fall
into a sick way, I will change the code according to your comments and ping you
again when I finish this.
---
[
https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-9482:
Assignee: Viktor Vlasov
> Not applicable functions for TIME
>
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5582#discussion_r192352087
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497810#comment-16497810
]
ASF GitHub Bot commented on FLINK-8790:
---
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:comment-tabpanel=16497804#comment-16497804
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497802#comment-16497802
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user sihuazhou commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5582#discussion_r192350881
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5582#discussion_r192350746
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497800#comment-16497800
]
ASF GitHub Bot commented on FLINK-8790:
---
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/5582#discussion_r192350121
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497794#comment-16497794
]
ASF GitHub Bot commented on FLINK-8790:
---
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/5582#discussion_r192348975
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497790#comment-16497790
]
ASF GitHub Bot commented on FLINK-9483:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16497789#comment-16497789
]
ASF GitHub Bot commented on FLINK-9483:
---
Github user zentol commented on a diff in the pull
1 - 100 of 146 matches
Mail list logo
