Till Rohrmann created FLINK-8621:
Summary:
PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on
Travis
Key: FLINK-8621
URL: https://issues.apache.org/jira/browse/FLINK-8621
Dawid Wysakowicz created FLINK-8620:
---
Summary: Enable shipping custom artifacts to BlobStore and
accessing them through DistributedCache
Key: FLINK-8620
URL: https://issues.apache.org/jira/browse/FLINK-8620
Till Rohrmann created FLINK-8623:
Summary:
ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis
Key: FLINK-8623
URL: https://issues.apache.org/jira/browse/FLINK-8623
Bhumika Bayani created FLINK-8622:
-
Summary: flink-mesos: High memory usage of scheduler + job
manager. GC never kicks in.
Key: FLINK-8622
URL: https://issues.apache.org/jira/browse/FLINK-8622
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8621:
-
Component/s: Tests
> PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable
[
https://issues.apache.org/jira/browse/FLINK-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8622:
-
Component/s: Mesos
> flink-mesos: High memory usage of scheduler + job manager. GC never kicks
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/5439
[FLINK-8571] [DataStream] [Backport] Introduce utility function that
reinterprets a data stream as keyed stream
This PR is a backport of #5424 to Flink 1.4.
You can merge this pull request
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358214#comment-16358214
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5439
CC @aljoscha @tzulitai
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358212#comment-16358212
]
ASF GitHub Bot commented on FLINK-8571:
---
GitHub user StefanRRichter opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358222#comment-16358222
]
Fabian Hueske commented on FLINK-8601:
--
Thanks for the detailed design document [~sihuazhou]!
Now I
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358238#comment-16358238
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5439#discussion_r167196102
--- Diff:
flink-contrib/flink-streaming-contrib/src/test/java/org/apache/flink/contrib/streaming/ReinterpretAsKeyedStreamITCase.java
---
@@ -0,0 +1,235 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5439#discussion_r167197709
--- Diff:
flink-contrib/flink-streaming-contrib/src/test/java/org/apache/flink/contrib/streaming/ReinterpretAsKeyedStreamITCase.java
---
@@ -0,0 +1,235 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5424#discussion_r167198202
--- Diff: docs/dev/api_concepts.md ---
@@ -896,11 +896,16 @@ result type ```R``` for the final result. E.g. for a
histogram, ```V``` is a num
{%
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358255#comment-16358255
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358261#comment-16358261
]
ASF GitHub Bot commented on FLINK-8556:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5411
Thanks for the contribution @pduveau.
I'll try to take a look at this soon.
---
chris snow created FLINK-8618:
-
Summary: Add S3 to the list of sinks on the delivery guarantees
page
Key: FLINK-8618
URL: https://issues.apache.org/jira/browse/FLINK-8618
Project: Flink
Issue
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5400#discussion_r167162743
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTestBase.java
---
@@ -0,0 +1,194 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lynch Lee updated FLINK-8619:
-
Description:
I do some test about distinct on mysql below:
mysql> CREATE TABLE `rpt_tt` (
->
[
https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358201#comment-16358201
]
Fabian Hueske commented on FLINK-6428:
--
Hi [~lynchlee]
The query {{SELECT DISTINCT a, b, c FROM t
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8500:
Fix Version/s: (was: 1.4.2)
> Get the timestamp of the Kafka message from kafka
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358249#comment-16358249
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5439
The changes look good! But as @tzulitai mentioned the missing Scala tests
seem strange.
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358254#comment-16358254
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user aljoscha commented on the issue:
Bhumika Bayani created FLINK-8624:
-
Summary: flink-mesos: The flink rest-api sometimes becomes
unresponsive
Key: FLINK-8624
URL: https://issues.apache.org/jira/browse/FLINK-8624
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358257#comment-16358257
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5424
Still looks good, except that I'd like to see the new doc in a completely
separate section of the doc.
---
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/5438
I've removed the ITCase and add some tests to
```org.apache.flink.table.expressions.MapTypeTest ```
---
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358499#comment-16358499
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358500#comment-16358500
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167249371
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadResponseBody.java
---
@@ -0,0 +1,58 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167250379
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ * Licensed
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5425
I think this looks good now.
---
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5424
Thanks for the review @aljoscha. Will merge.
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358699#comment-16358699
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-8571.
-
Resolution: Fixed
Fix Version/s: 1.4.1
1.5.0
Merged in 91eea376ee.
dejan miljkovic created FLINK-8628:
--
Summary: BucketingSink does not work wit S3
Key: FLINK-8628
URL: https://issues.apache.org/jira/browse/FLINK-8628
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dejan miljkovic updated FLINK-8628:
---
Description:
BucketingSink does not work wit S3. Followed instructions provided on
Till Rohrmann created FLINK-8627:
Summary: Introduce SUSPENDING state
Key: FLINK-8627
URL: https://issues.apache.org/jira/browse/FLINK-8627
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358780#comment-16358780
]
ASF GitHub Bot commented on FLINK-8627:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5445
[FLINK-8627] Introduce new JobStatus#SUSPENDING
## What is the purpose of the change
The new JobStatus#SUSPENDING says that an ExecutionGraph has been suspended
but its
clean up
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358472#comment-16358472
]
ASF GitHub Bot commented on FLINK-8607:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358503#comment-16358503
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167249729
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167249950
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5444
[FLINK-8546] [flip6] Respect savepoints and restore from latest checkpoints
## What is the purpose of the change
Let the JobMaster respect checkpoints and savepoints. The JobMaster
[
https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358582#comment-16358582
]
ASF GitHub Bot commented on FLINK-8456:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358624#comment-16358624
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5439
Thanks for the reviews! Will merge.
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358730#comment-16358730
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user StefanRRichter closed the pull request at:
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/5424
---
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358504#comment-16358504
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358511#comment-16358511
]
ASF GitHub Bot commented on FLINK-8573:
---
Github user zhangminglei commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5439
LGTM once Travis is green.
We should also remove the redundant mention of FLINK-8571 in
`ReinterpretAsKeyedStreamITCase` while merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358559#comment-16358559
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8456.
-
Resolution: Fixed
Merged on master at 9628dc8917b2f69bb04119c1d41932076632de01
> Add Scala API
[
https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ken Krugler updated FLINK-8625:
---
Summary: Move OutputFlusher thread to Netty scheduled executor (was: Move
OutputFlasherThread to
Till Rohrmann created FLINK-8626:
Summary: Introduce BackPressureStatsTracker interface
Key: FLINK-8626
URL: https://issues.apache.org/jira/browse/FLINK-8626
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358518#comment-16358518
]
ASF GitHub Bot commented on FLINK-8546:
---
GitHub user tillrohrmann opened a pull request:
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/5439
---
[
https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358641#comment-16358641
]
ASF GitHub Bot commented on FLINK-8571:
---
Github user StefanRRichter closed the pull request at:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5441
[FLINK-8607] [table] Add a basic embedded SQL CLI client
## What is the purpose of the change
This PR implements the first part of the implementation plan described in
FLIP-24.
[
https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358470#comment-16358470
]
ASF GitHub Bot commented on FLINK-8617:
---
Github user Xpray commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358494#comment-16358494
]
Xingcan Cui commented on FLINK-8538:
Thanks for the comments [~twalthr] and [~fhueske]. Actually, I've
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358506#comment-16358506
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358509#comment-16358509
]
ASF GitHub Bot commented on FLINK-8626:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5443
[FLINK-8626] Introduce BackPressureStatsTracker interface
## What is the purpose of the change
Renames BackPressureStatsTracker into BackPressureStatsTrackerImpl and
introduce
a
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/5048
Hi @tillrohrmann , I just updated the PR, sorry for delaying so long.
---
[
https://issues.apache.org/jira/browse/FLINK-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8597.
-
Resolution: Fixed
Merged on master at dea4172604126fc40fc8fbf7f83a632733bd0dfb
> Add examples
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5425
---
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5442
[FLINK-7713][flip6] Implement JarUploadHandler
## What is the purpose of the change
*Allow uploading jars through HTTP to enable job submissions from the web
ui.*
cc: @tillrohrmann
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167249285
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358498#comment-16358498
]
ASF GitHub Bot commented on FLINK-7713:
---
GitHub user GJL opened a pull request:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5421
The CI error does not relevant to this PR.
```BackPressureStatsTrackerITCase``` test failed.
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5443#discussion_r167267838
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java
---
@@ -143,7 +143,7 @@
private final
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358589#comment-16358589
]
ASF GitHub Bot commented on FLINK-8626:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358588#comment-16358588
]
ASF GitHub Bot commented on FLINK-8626:
---
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/5443#discussion_r167268048
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/VoidBackPressureStatsTracker.java
---
@@ -0,0 +1,36 @@
[
https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358724#comment-16358724
]
ASF GitHub Bot commented on FLINK-8456:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358897#comment-16358897
]
ASF GitHub Bot commented on FLINK-8629:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5446
[FLINK-8629] [flip6] Allow JobMaster to rescale jobs
## What is the purpose of the change
This commit adds the functionality to rescale a job or parts of it to
the JobMaster. In
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167357375
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167356732
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167354757
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167357486
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359257#comment-16359257
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359253#comment-16359253
]
ASF GitHub Bot commented on FLINK-8360:
---
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/5239#discussion_r167354956
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167355583
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167356561
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167356422
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167389638
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167357164
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167356160
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r167355160
--- Diff: docs/ops/state/large_state_tuning.md ---
@@ -234,4 +234,97 @@ Compression can be activated through the
`ExecutionConfig`:
**Notice:** The
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359259#comment-16359259
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359262#comment-16359262
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16359251#comment-16359251
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user bowenli86 commented on a diff in the pull
1 - 100 of 166 matches
Mail list logo