Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73652372
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409063#comment-15409063
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73656446
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409138#comment-15409138
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4039.
--
Resolution: Won't Fix
Fix Version/s: (was: 1.1.0)
> G1 garbage collector only set if no custo
[
https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3690:
---
Fix Version/s: (was: 1.1.0)
> Create documentation on the new ResourceManager component
>
[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4102:
---
Fix Version/s: (was: 1.1.0)
> Test failure with checkpoint barriers
>
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4094:
---
Fix Version/s: (was: 1.1.0)
> Off heap memory deallocation might not properly work
> -
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3710:
---
Fix Version/s: (was: 1.1.0)
> ScalaDocs for org.apache.flink.streaming.scala are missing from the
[
https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3829:
---
Fix Version/s: (was: 1.1.0)
> flink-java
> --
>
> Key: FLINK-3829
>
[
https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3828:
---
Fix Version/s: (was: 1.1.0)
> flink-runtime
> -
>
> Key: FLINK-3828
>
[
https://issues.apache.org/jira/browse/FLINK-3796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3796.
--
Resolution: Fixed
Fixed in d353895ba512a5e30fb08a25643fd93f085e8456 (FLINK-2314)
> FileSourceFunction d
[
https://issues.apache.org/jira/browse/FLINK-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3830:
---
Fix Version/s: (was: 1.1.0)
> flink-scala
> ---
>
> Key: FLINK-3830
>
[
https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3827:
---
Fix Version/s: (was: 1.1.0)
> Flink modules include unused dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3832:
---
Fix Version/s: (was: 1.1.0)
> flink-streaming-scala
> -
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3834:
---
Fix Version/s: (was: 1.1.0)
> flink-statebackend-rocksdb
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3831:
---
Fix Version/s: (was: 1.1.0)
> flink-streaming-java
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-3833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3833:
---
Fix Version/s: (was: 1.1.0)
> flink-test-utils
>
>
> Key: FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3950:
---
Fix Version/s: (was: 1.1.0)
> Add Meter Metric Type
> -
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4047:
---
Fix Version/s: (was: 1.0.3)
(was: 1.1.0)
> Fix documentation about determin
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2253
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409164#comment-15409164
]
ASF GitHub Bot commented on FLINK-4219:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4236:
---
Fix Version/s: (was: 1.1.0)
> Flink Dashboard stops showing list of uploaded jars if main method c
[
https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4219.
--
Resolution: Fixed
Fix Version/s: (was: 1.1.0)
1.1.1
1.2.
[
https://issues.apache.org/jira/browse/FLINK-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4257:
---
Fix Version/s: (was: 1.1.0)
> Handle delegating algorithm change of class
> --
[
https://issues.apache.org/jira/browse/FLINK-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4104:
---
Fix Version/s: (was: 1.1.0)
> Restructure Gelly docs
> --
>
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2334
`flink-metrics-core` does not contain any annotations, so the plugin will
never fail here, right?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409168#comment-15409168
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4297:
---
Fix Version/s: (was: 1.1.0)
1.1.1
> Yarn client can't determine fat jar locatio
[
https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4265:
---
Fix Version/s: (was: 1.1.0)
> Add a NoOpOperator
> --
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-4173:
---
Fix Version/s: (was: 1.1.0)
> Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
Finished first review of the code.
Let me summarize parts of the Kafka 0.10 API that requires us to have a
separate module:
1. `ConsumerRecord` in 0.10 has a new `ConsumerRecord#ti
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409181#comment-15409181
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
@radekg One thing that's missing is update to the docs. You can find the
Kafka connector documentation at
`flink/docs/apis/streaming/connectors/kafka.md`. We'lll probably only need to
update the Ma
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409192#comment-15409192
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409194#comment-15409194
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2231#discussion_r73662520
--- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/pom.xml ---
@@ -0,0 +1,179 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
Ufuk Celebi created FLINK-4314:
--
Summary: Test instability in
JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown
Key: FLINK-4314
URL: https://issues.apache.org/jira/browse/FLINK-4314
[
https://issues.apache.org/jira/browse/FLINK-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4314.
--
Resolution: Fixed
Fix Version/s: 1.1.1
1.2.0
Fixed in 0870007 (master), 5184d0
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2335
Looks good to me.
+1, will merge this
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409266#comment-15409266
]
ASF GitHub Bot commented on FLINK-4308:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409276#comment-15409276
]
ASF GitHub Bot commented on FLINK-4094:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2336#discussion_r73670834
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
---
@@ -53,6 +55,7 @@
*/
public class MemoryManager {
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2336
Two small comments, otherwise this looks good.
---
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 f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2336#discussion_r73670793
--- Diff: docs/setup/config.md ---
@@ -83,7 +83,8 @@ The default fraction for managed memory can be adjusted
using the `taskmanager.m
- `taskma
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409278#comment-15409278
]
ASF GitHub Bot commented on FLINK-4094:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409277#comment-15409277
]
ASF GitHub Bot commented on FLINK-4094:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409290#comment-15409290
]
Stephan Ewen commented on FLINK-3950:
-
What kind of Meter do we want to add here?
Two
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2334
True, the `flink-metrics-core` would not need it right now. I added it
because it is somehow part of the public API.
We would need to re-add the annotations dependency - for that, let's c
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409292#comment-15409292
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user StephanEwen commented on the is
Stephan Ewen created FLINK-4315:
---
Summary: Remove Hadoop Dependency from flink-java
Key: FLINK-4315
URL: https://issues.apache.org/jira/browse/FLINK-4315
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409350#comment-15409350
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
Updated the PR. Pls check.
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2337
[FLINK-3042] [FLINK-3060] [types] Define a way to let types create their
own TypeInformation
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following ch
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409364#comment-15409364
]
ASF GitHub Bot commented on FLINK-3042:
---
GitHub user twalthr opened a pull request:
Stephan Ewen created FLINK-4316:
---
Summary: Make flink-core independent of Hadoop
Key: FLINK-4316
URL: https://issues.apache.org/jira/browse/FLINK-4316
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409384#comment-15409384
]
Stephan Ewen commented on FLINK-4316:
-
An alternative would be to copy the Hadoop {{Wr
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2336
Looks good, will merge this...
---
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 a
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409387#comment-15409387
]
ASF GitHub Bot commented on FLINK-4094:
---
Github user StephanEwen commented on the is
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2338
[FLINK-4316] [core] [hadoop compatibility] Make flink-core independent of
Hadoop
This pull request moves all 'Writable' related code to the
'flink-hadoop-compatibility' project
and uses ref
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409391#comment-15409391
]
ASF GitHub Bot commented on FLINK-4316:
---
GitHub user StephanEwen opened a pull reque
Ufuk Celebi created FLINK-4317:
--
Summary: Restructure documentation
Key: FLINK-4317
URL: https://issues.apache.org/jira/browse/FLINK-4317
Project: Flink
Issue Type: Improvement
Compone
Ufuk Celebi created FLINK-4318:
--
Summary: Make master docs build target version-specific
Key: FLINK-4318
URL: https://issues.apache.org/jira/browse/FLINK-4318
Project: Flink
Issue Type: Improvem
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2338
The Scala type extraction has now also 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 hav
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409435#comment-15409435
]
ASF GitHub Bot commented on FLINK-4316:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2312
+1 to merge this
---
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,
[
https://issues.apache.org/jira/browse/FLINK-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409452#comment-15409452
]
ASF GitHub Bot commented on FLINK-4276:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409453#comment-15409453
]
ramkrishna.s.vasudevan commented on FLINK-4253:
---
I can take this up.
> Ren
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-4253:
-
Assignee: ramkrishna.s.vasudevan
> Rename "recovery.mode" config key to "
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2334
Changes look good and make sense. +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 does not have this feature
e
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409462#comment-15409462
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user uce commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2329
Looks good to me. Has nice tests and the Travis CI failures are cache/jar
file issues, i.e., unrelated.
+1 to merge this
---
If your project is set up for it, you can reply to this emai
[
https://issues.apache.org/jira/browse/FLINK-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409464#comment-15409464
]
ASF GitHub Bot commented on FLINK-3138:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2320
Will address the comment and merge this...
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409466#comment-15409466
]
ASF GitHub Bot commented on FLINK-4297:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2318
+1 to merge this
---
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,
[
https://issues.apache.org/jira/browse/FLINK-4291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409483#comment-15409483
]
ASF GitHub Bot commented on FLINK-4291:
---
Github user StephanEwen commented on the is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2336
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2335
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4308.
---
> Allow uploaded jar directory to be configurable
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409488#comment-15409488
]
ASF GitHub Bot commented on FLINK-4308:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409487#comment-15409487
]
ASF GitHub Bot commented on FLINK-4094:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4308.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 8d4a64d7afd33bfe56135c06501adffd241348bd
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409491#comment-15409491
]
Stephan Ewen commented on FLINK-4094:
-
The warning has been added in 119364c6e38aedf7e
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409493#comment-15409493
]
ASF GitHub Bot commented on FLINK-4316:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2338
@StephanEwen that's exactly what I was just going to suggest for Scala.
ð
---
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 aljoscha commented on the issue:
https://github.com/apache/flink/pull/2333
IMHO, the offset should not be added to `TimeWindow`. It is only the
assigners that would shift the start time/end time of a window. This way, other
parts of the code don't need to be aware of offse
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409504#comment-15409504
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aljoscha commented on the issue
Stephan Ewen created FLINK-4319:
---
Summary: Rework Cluster Management (FLIP-6)
Key: FLINK-4319
URL: https://issues.apache.org/jira/browse/FLINK-4319
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4320:
---
Summary: Fix misleading ScheduleMode names
Key: FLINK-4320
URL: https://issues.apache.org/jira/browse/FLINK-4320
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409616#comment-15409616
]
Stephan Ewen commented on FLINK-4318:
-
I think this idea sounds good.
Can we still hav
Stephan Ewen created FLINK-4321:
---
Summary: Initialize TaskExecutions directly with their starting
state
Key: FLINK-4321
URL: https://issues.apache.org/jira/browse/FLINK-4321
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409770#comment-15409770
]
Aditi Viswanathan commented on FLINK-4282:
--
I had to do that because the processi
Stephan Ewen created FLINK-4322:
---
Summary: Unify CheckpointCoordinator and SavepointCoordinator
Key: FLINK-4322
URL: https://issues.apache.org/jira/browse/FLINK-4322
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409799#comment-15409799
]
ramkrishna.s.vasudevan commented on FLINK-4322:
---
bq.jobs should be able to r
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2334
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2320
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409807#comment-15409807
]
ASF GitHub Bot commented on FLINK-4297:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15409806#comment-15409806
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4312.
---
> Remove Serializabiliy of ExecutionGraph
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4312.
-
Resolution: Fixed
Fixed via c9b0dad89b79f11ce13fe78f8a0823b8266f930f
(Commit has JIRA issue tag o
1 - 100 of 138 matches
Mail list logo
