[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663911#comment-15663911
]
ASF GitHub Bot commented on FLINK-5017:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2801
@tzulitai I won't have much time this week so will review this next week.
---
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
GitHub user bitchelov opened a pull request:
https://github.com/apache/flink/pull/2802
Minor fixes
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into
Aljoscha Krettek created FLINK-5061:
---
Summary: Remove ContinuousEventTimeTrigger
Key: FLINK-5061
URL: https://issues.apache.org/jira/browse/FLINK-5061
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15657432#comment-15657432
]
Anton Solovev edited comment on FLINK-3848 at 11/14/16 9:13 AM:
I have a
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2650#discussion_r86991226
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2650#discussion_r87781042
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2650#discussion_r87780687
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663719#comment-15663719
]
ASF GitHub Bot commented on FLINK-5017:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2801
R: @aljoscha, @StephanEwen I think this is in good shape for reviews now.
Any feedback is welcome!
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663953#comment-15663953
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user Renkai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-4177.
-
Resolution: Fixed
Possibly resolved in 62523acbe175cf159fe1b4ab6cf5c0412fc4d232.
>
Github user Renkai commented on the issue:
https://github.com/apache/flink/pull/2729
I'm not very understand why some function need to be cleaned while others
are not in the last version of scala API, but I think all of them need to be
checked, so I add some checks where has no
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2457
Hi @iampeter
I've updated the PR according to you suggestion.
---
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
Github user Renkai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2729#discussion_r87792198
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ScalaObjectChecker.java ---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663807#comment-15663807
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user Renkai commented on a diff in the pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2707
merging
---
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
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663809#comment-15663809
]
ASF GitHub Bot commented on FLINK-4939:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663902#comment-15663902
]
ASF GitHub Bot commented on FLINK-4174:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663901#comment-15663901
]
ASF GitHub Bot commented on FLINK-4174:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2736#discussion_r87798796
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java
---
@@ -18,28 +18,77 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2736#discussion_r87798657
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java
---
@@ -18,28 +18,77 @@
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-4177:
-
> CassandraConnectorTest.testCassandraCommitter causing unstable builds
>
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4177.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Possibly resolved in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2756#discussion_r87801992
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
---
@@ -800,4 +907,39 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663992#comment-15663992
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664010#comment-15664010
]
Aljoscha Krettek commented on FLINK-4460:
-
Yup, this was one of the motivations for this feature.
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5002:
-
Assignee: Roman Maier
> Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers
>
Nico Kruber created FLINK-5059:
--
Summary: only serialise events once in RecordWriter#broadcastEvent
Key: FLINK-5059
URL: https://issues.apache.org/jira/browse/FLINK-5059
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664097#comment-15664097
]
ASF GitHub Bot commented on FLINK-5017:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663824#comment-15663824
]
ASF GitHub Bot commented on FLINK-4939:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2707
---
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 zentol commented on the issue:
https://github.com/apache/flink/pull/2484
merging
---
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
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663885#comment-15663885
]
ASF GitHub Bot commented on FLINK-4177:
---
Github user zentol commented on the issue:
Nico Kruber created FLINK-5060:
--
Summary: only serialise records once in RecordWriter#emit and
RecordWriter#broadcastEmit
Key: FLINK-5060
URL: https://issues.apache.org/jira/browse/FLINK-5060
Project:
[
https://issues.apache.org/jira/browse/FLINK-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2839.
---
Resolution: Invalid
Fix Version/s: 1.2.0
The operator-stats module was removed in
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663970#comment-15663970
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2756#discussion_r87802539
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
---
@@ -459,7 +545,28 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663971#comment-15663971
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2790#discussion_r87804804
--- Diff:
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664059#comment-15664059
]
ASF GitHub Bot commented on FLINK-5061:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2803
[FLINK-5061] Remove ContinuousEventTimeTrigger
R: @StephanEwen for review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4939.
---
Resolution: Fixed
Implemented in 381bf5912237420b8e294c1fd38006a85403fd4f
>
[
https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4177:
---
Assignee: Chesnay Schepler
> CassandraConnectorTest.testCassandraCommitter causing
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2484
---
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-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663944#comment-15663944
]
ASF GitHub Bot commented on FLINK-4177:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663996#comment-15663996
]
ASF GitHub Bot commented on FLINK-3680:
---
Github user mushketyk commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2801
No problem @aljoscha, thank you.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663350#comment-15663350
]
ASF GitHub Bot commented on FLINK-4364:
---
GitHub user wangzhijiang999 opened a pull request:
yangping wu created FLINK-5058:
--
Summary: taskManagerMemory attribute set wrong value in FlinkShell
Key: FLINK-5058
URL: https://issues.apache.org/jira/browse/FLINK-5058
Project: Flink
Issue
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/2798
[FLINK-4364]Implement TaskManager side of heartbeat from JobManager
1. **TaskManagerRunner** creates **HeartbeatManagerImpl** components for
monitoring **JobManager** and
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yangping wu updated FLINK-5058:
---
Description:
In FlinkShell.scala, someone mistakenly set {{slots}} value to
{{taskManagerMemory}}
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yangping wu updated FLINK-5058:
---
Summary: slots attribute set wrong value in FlinkShell (was:
taskManagerMemory attribute set wrong
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663520#comment-15663520
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663522#comment-15663522
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663516#comment-15663516
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663521#comment-15663521
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663752#comment-15663752
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2467
Hi @iampeter
I've updated the PR according to your review.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663368#comment-15663368
]
Anton Solovev commented on FLINK-3848:
--
I suppose we need implement this for streaming too, right?
>
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663368#comment-15663368
]
Anton Solovev edited comment on FLINK-3848 at 11/14/16 10:11 AM:
-
I
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2801
[FLINK-5017] [streaming] Introduce StreamStatus to facilitate idle sources
This PR is the first part of making temporarily idle sources in Flink
possible, by adding a new `StreamStatus` element
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663715#comment-15663715
]
ASF GitHub Bot commented on FLINK-5017:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15662466#comment-15662466
]
sunjincheng edited comment on FLINK-4937 at 11/14/16 9:35 AM:
--
I had thought
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663496#comment-15663496
]
ASF GitHub Bot commented on FLINK-5058:
---
GitHub user 397090770 opened a pull request:
GitHub user bitchelov opened a pull request:
https://github.com/apache/flink/pull/2800
Update README.md
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663160#comment-15663160
]
Xiaogang Shi commented on FLINK-5053:
-
I think it's better to use {{checkpoint}} instead of {{backup}}
[
https://issues.apache.org/jira/browse/FLINK-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663309#comment-15663309
]
Kostas Kloudas commented on FLINK-5054:
---
This is also included in
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yangping wu updated FLINK-5058:
---
Description:
In FlinkShell.scala, someone mistakenly set {{slots}} value to
{{taskManagerMemory}}
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yangping wu updated FLINK-5058:
---
Summary: taskManagerMemory attribute set wrong value in FlinkShell (was:
slots attribute set wrong
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663198#comment-15663198
]
Stefan Richter commented on FLINK-5053:
---
That might very well be, I am still planning to take closer
GitHub user 397090770 opened a pull request:
https://github.com/apache/flink/pull/2799
[FLINK-5058]taskManagerMemory attribute set wrong value
In FlinkShell.scala, someone mistakenly set `slots` value to
`taskManagerMemory` attribute as follow:
```
// set configuration from
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2650
I don't mean the CharacterFilter, it's good that that one is static. I'll
add a few more comments to point to problematic areas. ;)
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663497#comment-15663497
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2650#discussion_r87781446
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2650#discussion_r86765901
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663519#comment-15663519
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663518#comment-15663518
]
ASF GitHub Bot commented on FLINK-4563:
---
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/2650#discussion_r87780651
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663517#comment-15663517
]
ASF GitHub Bot commented on FLINK-4563:
---
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/2650#discussion_r87780439
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java
---
@@ -44,4 +52,132 @@ protected QueryScopeInfo
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2431
@rmetzger @iampeter I've rebased my PR on top of mainline.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663532#comment-15663532
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15665739#comment-15665739
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2703
I'll merge the changes once the comments have been addressed.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15665737#comment-15665737
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2703
It is easier for the review process when you push fixups commits to pull
requests. Usually we fixup the commits when merging to master.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4527.
---
Resolution: Fixed
Assignee: Chesnay Schepler
Fix Version/s: 1.2.0
The
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2787
I agree that we should try to get this into the RC.
+1 to merge
---
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
Github user bitchelov commented on the issue:
https://github.com/apache/flink/pull/2800
Hi @greghogan ! No, there is no Jira ticket for this PR. It made for
convenience and as i said ( to do "README.md" file more informative).
---
If your project is set up for it, you can reply to
Till Rohrmann created FLINK-5063:
Summary: State handles are not properly cleaned up for declined or
expired checkpoints
Key: FLINK-5063
URL: https://issues.apache.org/jira/browse/FLINK-5063
Project:
[
https://issues.apache.org/jira/browse/FLINK-5062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5062:
Summary: Ensure that all created threads have a proper name (was: Ensure
that all create
Chesnay Schepler created FLINK-5062:
---
Summary: Ensure that all create threads have a proper name
Key: FLINK-5062
URL: https://issues.apache.org/jira/browse/FLINK-5062
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5063:
-
Description:
In case that a {{Checkpoint}} is declined or expires, the
{{CheckpointCoordinator}}
[
https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664157#comment-15664157
]
Chesnay Schepler commented on FLINK-4920:
-
Currently, in order to create a Gauge that simply
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2802#discussion_r87820837
--- Diff: docs/_includes/sidenav.html ---
@@ -147,3 +147,4 @@
+
--- End diff --
The div is closed on line 85.
---
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664360#comment-15664360
]
Craig Foster commented on FLINK-5013:
-
I can fix and verify on the EMR side but shouldn't the Maven
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15666015#comment-15666015
]
Renkai Ge commented on FLINK-5031:
--
I want to work on this issue
> Consecutive DataStream.split()
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reassigned FLINK-5031:
Assignee: Renkai Ge
> Consecutive DataStream.split() ignored
>
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2736#discussion_r87862442
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java
---
@@ -18,28 +18,77 @@
1 - 100 of 133 matches
Mail list logo
