[GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f...

2015-10-25 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1289#issuecomment-150900971 Ok, then we should merge it since this is blocking the release. :smile: --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973140#comment-14973140 ] ASF GitHub Bot commented on FLINK-2866: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-25 Thread willmiao
Github user willmiao commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-150919886 Hi rmetzger, I have updated this PR. I generated a flink-conf.yaml in a directory, which I then used as the configuration directory for the test. --- If your

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973216#comment-14973216 ] ASF GitHub Bot commented on FLINK-2591: --- Github user willmiao commented on the pull request:

[jira] [Created] (FLINK-2916) Add more context information for the StateBackend

2015-10-25 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2916: - Summary: Add more context information for the StateBackend Key: FLINK-2916 URL: https://issues.apache.org/jira/browse/FLINK-2916 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973188#comment-14973188 ] ASF GitHub Bot commented on FLINK-2017: --- Github user mliesenberg commented on a diff in the pull

[jira] [Created] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase

2015-10-25 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2915: -- Summary: JobManagerProcessFailureBatchRecoveryITCase Key: FLINK-2915 URL: https://issues.apache.org/jira/browse/FLINK-2915 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

2015-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2866. - Resolution: Fixed Assignee: Ted Yu Fix Version/s: 0.10 Fixed via

[jira] [Resolved] (FLINK-2888) Default state not copied for AbstractHeapKvState

2015-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2888. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.10 Fixed via

[GitHub] flink pull request: [FLINK-2918] Add method to read a file of type...

2015-10-25 Thread smarthi
GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/1299 [FLINK-2918] Add method to read a file of type SequenceFileInputFormat Fixes You can merge this pull request into a Git repository by running: $ git pull https://github.com/smarthi/flink work

[jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973465#comment-14973465 ] ASF GitHub Bot commented on FLINK-2918: --- GitHub user smarthi opened a pull request:

[jira] [Commented] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation

2015-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973463#comment-14973463 ] Stephan Ewen commented on FLINK-2891: - Second part (fast path processing time windows) fixed as of

[jira] [Closed] (FLINK-2888) Default state not copied for AbstractHeapKvState

2015-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2888. --- > Default state not copied for AbstractHeapKvState > > >

[GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f...

2015-10-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1289#issuecomment-150979276 Manually merged into branches `master` and `release-0.10` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973456#comment-14973456 ] ASF GitHub Bot commented on FLINK-2866: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f...

2015-10-25 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1289 --- 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

[GitHub] flink pull request: FLINK-2866 Potential resource leak due to uncl...

2015-10-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1282 --- 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-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle

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

[jira] [Created] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-25 Thread GaoLun (JIRA)
GaoLun created FLINK-2919: - Summary: Apply JMH on FieldAccessMinibenchmark class. Key: FLINK-2919 URL: https://issues.apache.org/jira/browse/FLINK-2919 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973272#comment-14973272 ] Chesnay Schepler commented on FLINK-2901: - What about {{recordJobs}}? Should all of them be ported

[jira] [Created] (FLINK-2917) Make non-copying behaviour default for stream operator

2015-10-25 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2917: - Summary: Make non-copying behaviour default for stream operator Key: FLINK-2917 URL: https://issues.apache.org/jira/browse/FLINK-2917 Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-25 Thread willmiao
Github user willmiao commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-150928188 Sorry for the failed tests, I'll fix them. --- 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

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

2015-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973262#comment-14973262 ] ASF GitHub Bot commented on FLINK-2591: --- Github user willmiao commented on the pull request:

[jira] [Updated] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2901: Description: There are several ITCases and utility classes in {{flink-tests}} that depend

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973286#comment-14973286 ] Fabian Hueske commented on FLINK-2901: -- The jobs can be removed as well. They are mainly used for the

[jira] [Commented] (FLINK-2917) Make non-copying behaviour default for stream operator

2015-10-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973308#comment-14973308 ] Aljoscha Krettek commented on FLINK-2917: - We already have the switch: {{enableObjectReuse()}} >