[
https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999673#comment-15999673
]
yanghua commented on FLINK-5967:
hi [~aljoscha] where to add the document?
> Document AggregatingState
>
[
https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yanghua reassigned FLINK-5967:
--
Assignee: (was: yanghua)
> Document AggregatingState
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yanghua reassigned FLINK-5967:
--
Assignee: yanghua
> Document AggregatingState
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999661#comment-15999661
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user ifndef-SleePy commented on the issue:
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3810
I think Till has implemented a static unsetAsContext method in
TestEnvironment recently. I rebased the implementation from master, and
recommit the pull request.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999660#comment-15999660
]
ASF GitHub Bot commented on FLINK-6397:
---
Github user ifndef-SleePy commented on a diff in the pull
Github user ifndef-SleePy commented on a diff in the pull request:
https://github.com/apache/flink/pull/3810#discussion_r115133175
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java
---
@@ -80,29 +80,36 @@
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3793
Thanks for the update @suez1224!
Looks good to me. Will do some minor refactoring and merge this PR.
Best, Fabian
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999615#comment-15999615
]
Stavros Kontopoulos edited comment on FLINK-5536 at 5/6/17 10:31 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999615#comment-15999615
]
Stavros Kontopoulos commented on FLINK-5536:
I tested it, i seems to work fine. You need to
Github user heytitle commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r115130267
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NormalizedKeySorter.java
---
@@ -47,61 +47,61 @@
public
[
https://issues.apache.org/jira/browse/FLINK-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999589#comment-15999589
]
ASF GitHub Bot commented on FLINK-5867:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3773
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999521#comment-15999521
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user mbode commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999520#comment-15999520
]
ASF GitHub Bot commented on FLINK-6438:
---
Github user alpinegizmo commented on the issue:
Github user mbode commented on the issue:
https://github.com/apache/flink/pull/3833
Thanks for looking at it so quickly! I somewhat had the same instinct as
far as your first point is concerned and thought about pulling out a
`DropwizardReporter` without Scheduling but decided
Github user alpinegizmo commented on the issue:
https://github.com/apache/flink/pull/3823
@greghogan I'd be happy to list other blogs; any suggestions? I've
considered at a few, but the problem with the ones I've examined is that the
proportion of Flink-related posts is rather small,
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3823#discussion_r115125659
--- Diff: docs/index.md ---
@@ -33,9 +33,13 @@ Apache Flink is an open source platform for distributed
stream and batch data pr
-
[
https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999512#comment-15999512
]
ASF GitHub Bot commented on FLINK-6438:
---
Github user alpinegizmo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4545.
-
Resolution: Fixed
Finalized in 0bb49e538c118b8265377355a9667789a3971966
> Flink automatically
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4545.
---
> Flink automatically manages TM network buffer
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6401.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 1.3.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-6401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6401.
---
> RocksDBPerformanceTest.testRocksDbRangeGetPerformance fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-6470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6470.
---
> Add a utility to parse memory sizes with units
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6447.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed via 6c48f9bb0e27b86f57b940aac67db12c17b4f5bc
[
https://issues.apache.org/jira/browse/FLINK-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6443.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in b01d737ae1452dbfafd4696ff14d52dce5b60efd
[
https://issues.apache.org/jira/browse/FLINK-6470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6470.
-
Resolution: Fixed
Fixed via 50b8dda37d5194297e4a6e41460fbc13e67a393b
> Add a utility to parse
[
https://issues.apache.org/jira/browse/FLINK-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6443.
---
> Add more doc links in concepts sections
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-6447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6447.
---
> AWS/EMR docs are out-of-date
>
>
> Key: FLINK-6447
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3828
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3822
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-6447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999501#comment-15999501
]
ASF GitHub Bot commented on FLINK-6447:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3721
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999503#comment-15999503
]
ASF GitHub Bot commented on FLINK-6443:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999502#comment-15999502
]
ASF GitHub Bot commented on FLINK-4545:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999494#comment-15999494
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3833
I've glanced over this for now but it looks pretty good.
If possible though i would like to not use the DropwizardExports class, for
2 reasons:
1) We now introduce this odd pattern
[
https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999482#comment-15999482
]
Ted Yu commented on FLINK-6471:
---
Running RocksDBStateBackendTest under
[
https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6471:
--
Summary: RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails
(was:
Elias Levy created FLINK-6472:
-
Summary: BoundedOutOfOrdernessTimestampExtractor does not bound
out of orderliness
Key: FLINK-6472
URL: https://issues.apache.org/jira/browse/FLINK-6472
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6471:
--
Description:
I got the following test failure based on commit
f37988c19adc30d324cde83c54f2fa5d36efb9e7 :
Ted Yu created FLINK-6471:
-
Summary: RocksDBStateBackendTest#testCancelRunningSnapshot fails
Key: FLINK-6471
URL: https://issues.apache.org/jira/browse/FLINK-6471
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999461#comment-15999461
]
ASF GitHub Bot commented on FLINK-6425:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3834
[FLINK-6425] [runtime] Activate serializer upgrades in state backends
This is a follow-up PR that finalizes serializer upgrades, and is based on
#3804 (therefore, only the 2nd and 3rd commits,
[
https://issues.apache.org/jira/browse/FLINK-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999455#comment-15999455
]
ASF GitHub Bot commented on FLINK-5867:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3773
Thanks you @shuai-xu for checking this. Merging this for 1.3, together with
the updates proposed by you.
I think we need to initially make a small change that non-pipelined
exchanges
[
https://issues.apache.org/jira/browse/FLINK-5869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999454#comment-15999454
]
ASF GitHub Bot commented on FLINK-5869:
---
Github user StephanEwen closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999453#comment-15999453
]
ASF GitHub Bot commented on FLINK-5869:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3772
Manually merged in 8ed85fe49b7595546a8f968e0faa1fa7d4da47ec
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/3772
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999430#comment-15999430
]
ASF GitHub Bot commented on FLINK-4545:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3721
Merging this.
I filed a follow-up JIRA to address the "configuration with units" to make
sure all memory-related parameters behave the same way, without loss of byte
precision where needed:
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-6469:
Summary: Configure Memory Sizes with units (was: Configure Memory Sizes
via units)
> Configure
Stephan Ewen created FLINK-6470:
---
Summary: Add a utility to parse memory sizes with units
Key: FLINK-6470
URL: https://issues.apache.org/jira/browse/FLINK-6470
Project: Flink
Issue Type:
Stephan Ewen created FLINK-6469:
---
Summary: Configure Memory Sizes via units
Key: FLINK-6469
URL: https://issues.apache.org/jira/browse/FLINK-6469
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999405#comment-15999405
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3525
@WangTaoTheTonic I have debugged a bit further in this issue, and it seems
there is a bit more to do.
For non-HA blob servers, the atomic rename fix would do it.
For HA cases, we
[
https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999404#comment-15999404
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3525
Yes, @netguy204 - that is definitely one possible way for class loaders to
leak over...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Petr Novotnik created FLINK-6468:
Summary: release 1.2.1 tag in git
Key: FLINK-6468
URL: https://issues.apache.org/jira/browse/FLINK-6468
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15999386#comment-15999386
]
ASF GitHub Bot commented on FLINK-6221:
---
GitHub user mbode opened a pull request:
GitHub user mbode opened a pull request:
https://github.com/apache/flink/pull/3833
[FLINK-6221] Add PrometheusReporter
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbode/flink PrometheusReporter
Alternatively you can review
62 matches
Mail list logo
