[jira] [Updated] (FLINK-4102) Test failure with checkpoint barriers

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Updated] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Updated] (FLINK-3690) Create documentation on the new ResourceManager component

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Closed] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[jira] [Updated] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[GitHub] flink issue #2334: [FLINK-4310] [build] Selectively run API compatibility ch...

2016-08-05 Thread zentol
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

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409168#comment-15409168 ] ASF GitHub Bot commented on FLINK-4310: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-4265) Add a NoOpOperator

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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:

[jira] [Updated] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ...

2016-08-05 Thread tzulitai
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 --- @@

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409063#comment-15409063 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on a diff in the pull

[jira] [Updated] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[GitHub] flink issue #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0...

2016-08-05 Thread tzulitai
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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409181#comment-15409181 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2282: [FLINK-3940] [table] Add support for ORDER BY OFFSET FETC...

2016-08-05 Thread gallenvara
Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2282 @twalthr PR updated. --- 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

[jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408987#comment-15408987 ] ASF GitHub Bot commented on FLINK-3940: --- Github user gallenvara commented on the issue:

[GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ...

2016-08-05 Thread tzulitai
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 --- @@

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409138#comment-15409138 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on a diff in the pull

[jira] [Updated] (FLINK-3832) flink-streaming-scala

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 > - > >

[jira] [Updated] (FLINK-3834) flink-statebackend-rocksdb

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 > -- > >

[jira] [Updated] (FLINK-3831) flink-streaming-java

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 > > >

[jira] [Updated] (FLINK-3833) flink-test-utils

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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:

[jira] [Updated] (FLINK-4047) Fix documentation about determinism of KeySelectors

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[jira] [Updated] (FLINK-3950) Add Meter Metric Type

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 > - > >

[GitHub] flink pull request #2253: [FLINK-4219] [scripts] Quote PDSH opts in start-cl...

2016-08-05 Thread asfgit
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

[jira] [Commented] (FLINK-4219) Quote PDSH opts in start-cluster.sh

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409164#comment-15409164 ] ASF GitHub Bot commented on FLINK-4219: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408958#comment-15408958 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ...

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2231#discussion_r73646737 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java ---

[jira] [Updated] (FLINK-3830) flink-scala

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Updated] (FLINK-3827) Flink modules include unused dependencies

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Closed] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[jira] [Updated] (FLINK-3829) flink-java

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Updated] (FLINK-3828) flink-runtime

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Closed] (FLINK-4219) Quote PDSH opts in start-cluster.sh

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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

[jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 >

[jira] [Updated] (FLINK-4104) Restructure Gelly docs

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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 > -- > >

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15408993#comment-15408993 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ...

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2231#discussion_r73648473 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java --- @@

[jira] [Created] (FLINK-4321) Initialize TaskExecutions directly with their starting state

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409616#comment-15409616 ] Stephan Ewen commented on FLINK-4318: - I think this idea sounds good. Can we still have a

[jira] [Created] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown

2016-08-05 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4314: -- Summary: Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown Key: FLINK-4314 URL: https://issues.apache.org/jira/browse/FLINK-4314

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409290#comment-15409290 ] Stephan Ewen commented on FLINK-3950: - What kind of Meter do we want to add here? Two possible options

[jira] [Created] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409292#comment-15409292 ] ASF GitHub Bot commented on FLINK-4310: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4308) Allow uploaded jar directory to be configurable

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409266#comment-15409266 ] ASF GitHub Bot commented on FLINK-4308: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409194#comment-15409194 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ...

2016-08-05 Thread tzulitai
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; +

[jira] [Closed] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown

2016-08-05 Thread Ufuk Celebi (JIRA)
[ 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),

[GitHub] flink issue #2335: [FLINK-4308] Allow uploaded jar directory to be configura...

2016-08-05 Thread StephanEwen
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

[GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread StephanEwen
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

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409277#comment-15409277 ] ASF GitHub Bot commented on FLINK-4094: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink issue #2336: FLINK-4094 Off heap memory deallocation might not properl...

2016-08-05 Thread StephanEwen
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

[GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread StephanEwen
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 -

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409278#comment-15409278 ] ASF GitHub Bot commented on FLINK-4094: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2334: [FLINK-4310] [build] Selectively run API compatibility ch...

2016-08-05 Thread StephanEwen
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

[GitHub] flink issue #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0...

2016-08-05 Thread tzulitai
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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409192#comment-15409192 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409276#comment-15409276 ] ASF GitHub Bot commented on FLINK-4094: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409350#comment-15409350 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Updated the PR. Pls check. [~StephanEwen]

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409806#comment-15409806 ] ASF GitHub Bot commented on FLINK-4310: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409807#comment-15409807 ] ASF GitHub Bot commented on FLINK-4297: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4297. - Resolution: Fixed Fixed for - 1.2.0 via c7a85545ba73e93e4a55ef8886362badaa2e2147 - 1.1.1 via

[jira] [Closed] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4323. --- > Checkpoint Coordinator Removes HA Checkpoints in Shutdown >

[jira] [Created] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
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:

[jira] [Closed] (FLINK-4312) Remove Serializabiliy of ExecutionGraph

2016-08-05 Thread Stephan Ewen (JIRA)
[ 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 > --- > >

[jira] [Resolved] (FLINK-4312) Remove Serializabiliy of ExecutionGraph

2016-08-05 Thread Stephan Ewen (JIRA)
[ 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

[jira] [Created] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4323: --- Summary: Checkpoint Coordinator Removes HA Checkpoints in Shutdown Key: FLINK-4323 URL: https://issues.apache.org/jira/browse/FLINK-4323 Project: Flink Issue

[jira] [Resolved] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4323. - Resolution: Invalid Shutdown hook is only installed in "standalone" mode, which in the

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-08-05 Thread Aditi Viswanathan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409770#comment-15409770 ] Aditi Viswanathan commented on FLINK-4282: -- I had to do that because the processing time triggers

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409799#comment-15409799 ] ramkrishna.s.vasudevan commented on FLINK-4322: --- bq.jobs should be able to resume from

[GitHub] flink pull request #2334: [FLINK-4310] [build] Selectively run API compatibi...

2016-08-05 Thread asfgit
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

[GitHub] flink pull request #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-05 Thread asfgit
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

[jira] [Closed] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4297. --- > Yarn client can't determine fat jar location if path contains spaces >

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-08-05 Thread twalthr
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

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409364#comment-15409364 ] ASF GitHub Bot commented on FLINK-3042: --- GitHub user twalthr opened a pull request:

[GitHub] flink issue #2336: FLINK-4094 Off heap memory deallocation might not properl...

2016-08-05 Thread StephanEwen
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

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409435#comment-15409435 ] ASF GitHub Bot commented on FLINK-4316: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2338: [FLINK-4316] [core] [hadoop compatibility] Make flink-cor...

2016-08-05 Thread StephanEwen
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

[jira] [Commented] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409452#comment-15409452 ] ASF GitHub Bot commented on FLINK-4276: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409384#comment-15409384 ] Stephan Ewen commented on FLINK-4316: - An alternative would be to copy the Hadoop {{Writable}} type

[GitHub] flink pull request #2338: [FLINK-4316] [core] [hadoop compatibility] Make fl...

2016-08-05 Thread StephanEwen
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

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409387#comment-15409387 ] ASF GitHub Bot commented on FLINK-4094: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-4318) Make master docs build target version-specific

2016-08-05 Thread Ufuk Celebi (JIRA)
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:

[jira] [Assigned] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ 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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409453#comment-15409453 ] ramkrishna.s.vasudevan commented on FLINK-4253: --- I can take this up. > Rename

[jira] [Created] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409391#comment-15409391 ] ASF GitHub Bot commented on FLINK-4316: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink issue #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead

2016-08-05 Thread StephanEwen
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,

[jira] [Created] (FLINK-4317) Restructure documentation

2016-08-05 Thread Ufuk Celebi (JIRA)
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

[jira] [Updated] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4322: Issue Type: Improvement (was: Bug) > Unify CheckpointCoordinator and SavepointCoordinator >

[jira] [Created] (FLINK-4325) Implement Web UI HTTPS

2016-08-05 Thread Suresh Krishnappa (JIRA)
Suresh Krishnappa created FLINK-4325: Summary: Implement Web UI HTTPS Key: FLINK-4325 URL: https://issues.apache.org/jira/browse/FLINK-4325 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4324) Enable Akka SSL

2016-08-05 Thread Suresh Krishnappa (JIRA)
Suresh Krishnappa created FLINK-4324: Summary: Enable Akka SSL Key: FLINK-4324 URL: https://issues.apache.org/jira/browse/FLINK-4324 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409961#comment-15409961 ] Stephan Ewen commented on FLINK-4322: - I would like to make some more radical changes to the current

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409462#comment-15409462 ] ASF GitHub Bot commented on FLINK-4310: --- Github user uce commented on the issue:

[GitHub] flink issue #2318: [FLINK-4291] Add log entry for scheduled reporters

2016-08-05 Thread StephanEwen
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,

[GitHub] flink pull request #2335: [FLINK-4308] Allow uploaded jar directory to be co...

2016-08-05 Thread asfgit
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

[GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread asfgit
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

[GitHub] flink issue #2333: [FLINK-4282] [streaming] Add Offset Parameter to WindowAs...

2016-08-05 Thread aljoscha
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

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409466#comment-15409466 ] ASF GitHub Bot commented on FLINK-4297: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4291) No log entry for unscheduled reporters

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409483#comment-15409483 ] ASF GitHub Bot commented on FLINK-4291: --- Github user StephanEwen commented on the issue:

  1   2   >