[jira] [Commented] (FLINK-1873) Distributed matrix implementation

2016-05-17 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288533#comment-15288533 ] Simone Robutti commented on FLINK-1873: --- [~till.rohrmann] I have opened two issues a

[GitHub] flink pull request: Support for bz2 compression in flink-core

2016-05-17 Thread mtanski
GitHub user mtanski opened a pull request: https://github.com/apache/flink/pull/2002 Support for bz2 compression in flink-core Add support for bz2 compression to flink. Right now this requires using Hadoop InputFormats. Doesn't require any extra dependencies as flink-core a

[jira] [Closed] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object

2016-05-17 Thread ZhengBowen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhengBowen closed FLINK-3897. - Resolution: Invalid > why does jobmanager process has too many ForkJoinTask object > -

[jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288114#comment-15288114 ] ASF GitHub Bot commented on FLINK-2259: --- Github user rawkintrevo commented on the pu

[GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters

2016-05-17 Thread rawkintrevo
Github user rawkintrevo commented on the pull request: https://github.com/apache/flink/pull/1898#issuecomment-219910631 Thanks for the review @tillrohrmann I need to find a markdown editor with spell check... --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288057#comment-15288057 ] ASF GitHub Bot commented on FLINK-3754: --- Github user yjshen commented on the pull re

[GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-17 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-219902602 @fhueske @twalthr thank you for your reviews and detailed comments through this issue 👍 . I'm quite excited to have it merged :) --- If your project is set up for it,

[GitHub] flink pull request: [script] Simple fix of typo from JobManager to...

2016-05-17 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/2001 [script] Simple fix of typo from JobManager to TaskManager in taskmanager.sh file Very simple fix for typo on comment in the task manager.sh file. From `JobManager` to `TaskManager`. You

[jira] [Closed] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

2016-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3754. Resolution: Implemented Fix Version/s: 1.1.0 Implemented with f0d543f8cf95efecef88c7715545610

[jira] [Closed] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3900. Resolution: Fixed Fix Version/s: 1.1.0 Fixed with f2e605759f77061e76fc7da6a55faeb44c67fc6f T

[jira] [Closed] (FLINK-3913) Clean up documentation typos

2016-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3913. Resolution: Fixed Fix Version/s: 1.1.0 Fixed with 4fbd8eb938cf0f1deee550161cc54f27757411e8 T

[GitHub] flink pull request: [FLINK-3913] [docs] clean up spelling mistakes

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1992 --- 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] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1958 --- 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

[jira] [Commented] (FLINK-3900) Set nullCheck=true as default in TableConfig

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

[jira] [Commented] (FLINK-3913) Clean up documentation typos

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

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

[GitHub] flink pull request: [FLINK-3900] Set nullCheck=true as default in ...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1994 --- 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] flink pull request: [FLINK-1502] [WIP] Basic Metric System

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-219864781 I rebased the branch, waiting for Travis to give a green light... --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287673#comment-15287673 ] ASF GitHub Bot commented on FLINK-1502: --- Github user StephanEwen commented on the pu

[jira] [Closed] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3782. --- > ByteArrayOutputStream and ObjectOutputStream should close >

[jira] [Closed] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3488. --- > Kafka08ITCase.testBigRecordJob fails on Travis > -- > >

[jira] [Resolved] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3488. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed via bd1c245cbffa4781672c63d144277bb4e244d7f6

[jira] [Closed] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3852. --- > Use a StreamExecutionEnvironment in the quickstart job skeleton > --

[jira] [Resolved] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3782. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed via 6c0c0a54a2f47780b338c79023acd0566007e709

[jira] [Resolved] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3852. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed via 3080ea48cf687893b0823f34b1e1716343d72167

[jira] [Closed] (FLINK-3826) Broken test: StreamCheckpointingITCase

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3826. --- > Broken test: StreamCheckpointingITCase > -- > > Key:

[jira] [Resolved] (FLINK-3826) Broken test: StreamCheckpointingITCase

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3826. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed via 91a845d05671ac9d1355e1c548c8e6a229043430

[GitHub] flink pull request: [FLINK-3488] Kafka08ITCase.testBigRecordJob fa...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1998 --- 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

[jira] [Commented] (FLINK-3826) Broken test: StreamCheckpointingITCase

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

[jira] [Commented] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

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

[GitHub] flink pull request: [FLINK-3852] update the quickstart module to i...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1982 --- 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] flink pull request: Build a flink-connector-kafka-0.9 test-jar

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1972 --- 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] flink pull request: [FLINK-3782] ByteArrayOutputStream and ObjectO...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1995 --- 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

[jira] [Commented] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

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

[GitHub] flink pull request: [FLINK-3826] Broken test: StreamCheckpointingI...

2016-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1977 --- 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

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

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

[jira] [Assigned] (FLINK-3805) BloomFilter initialized with no memory available

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-3805: -- Assignee: Rekha Joshi > BloomFilter initialized with no memory available >

[jira] [Assigned] (FLINK-2829) Confusing error message when Flink cannot create enough task threads

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-2829: -- Assignee: Rekha Joshi > Confusing error message when Flink cannot create enough task threads >

[jira] [Assigned] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-3488: -- Assignee: Rekha Joshi > Kafka08ITCase.testBigRecordJob fails on Travis > --

[jira] [Assigned] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-3900: -- Assignee: Rekha Joshi > Set nullCheck=true as default in TableConfig >

[jira] [Assigned] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-3782: -- Assignee: Rekha Joshi > ByteArrayOutputStream and ObjectOutputStream should close > ---

[jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287573#comment-15287573 ] ASF GitHub Bot commented on FLINK-2259: --- Github user rawkintrevo commented on a diff

[GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters

2016-05-17 Thread rawkintrevo
Github user rawkintrevo commented on a diff in the pull request: https://github.com/apache/flink/pull/1898#discussion_r63605367 --- Diff: docs/apis/batch/libs/ml/cross_validation.md --- @@ -0,0 +1,175 @@ +--- +mathjax: include +title: Cross Validation + +# Sub na

[jira] [Commented] (FLINK-3807) FastFailuresITCase deadlocks on Travis

2016-05-17 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287553#comment-15287553 ] Rekha Joshi commented on FLINK-3807: [~till.rohrmann] [~StephanEwen] [~rmetzger] In th

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287529#comment-15287529 ] ASF GitHub Bot commented on FLINK-1502: --- Github user zentol commented on the pull re

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

2016-05-17 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-219849631 The code in this PR is the most up-to-date. --- 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 projec

[jira] [Updated] (FLINK-3921) StringParser not specifying encoding to use

2016-05-17 Thread Tatu Saloranta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tatu Saloranta updated FLINK-3921: -- Priority: Trivial (was: Minor) Description: Class `flink.types.parser.StringParser` has

[jira] [Created] (FLINK-3921) StringParser not specifying encoding to use

2016-05-17 Thread Tatu Saloranta (JIRA)
Tatu Saloranta created FLINK-3921: - Summary: StringParser not specifying encoding to use Key: FLINK-3921 URL: https://issues.apache.org/jira/browse/FLINK-3921 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287454#comment-15287454 ] ASF GitHub Bot commented on FLINK-1502: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-219836974 This looks pretty good now. I would like to get this in soon, now that the test are passing. Let's iterate over it on the master. This needs a rebase

[jira] [Commented] (FLINK-2829) Confusing error message when Flink cannot create enough task threads

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287411#comment-15287411 ] ASF GitHub Bot commented on FLINK-2829: --- Github user rekhajoshm commented on the pul

[GitHub] flink pull request: [FLINK-2829] Confusing error message when Flin...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1993#issuecomment-219833255 makes sense @StephanEwen done --- 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-3914) BlobServer.createTemporaryFilename() has concurrency safety problem

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

[GitHub] flink pull request: [FLINK-3914] [runtime] fixed race when attempt...

2016-05-17 Thread markreddy
GitHub user markreddy opened a pull request: https://github.com/apache/flink/pull/2000 [FLINK-3914] [runtime] fixed race when attempting to create temp dir Flipped logic to prevent race on first few calls. You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (FLINK-2829) Confusing error message when Flink cannot create enough task threads

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287389#comment-15287389 ] ASF GitHub Bot commented on FLINK-2829: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2829] Confusing error message when Flin...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1993#discussion_r63589937 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -405,8 +405,9 @@ public void onComplete(Throwable fai

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287383#comment-15287383 ] Stephan Ewen commented on FLINK-1827: - I think we should restore the test util classes

[jira] [Assigned] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem

2016-05-17 Thread Mark Reddy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Reddy reassigned FLINK-3914: - Assignee: Mark Reddy > BlobServer.createTemporaryFilename() has concurrency safety problem >

[jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287337#comment-15287337 ] ASF GitHub Bot commented on FLINK-3805: --- GitHub user rekhajoshm opened a pull reques

[GitHub] flink pull request: [FLINK-3805] BloomFilter initialized with no m...

2016-05-17 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/flink/pull/1999 [FLINK-3805] BloomFilter initialized with no memory available [FLINK-3805] BloomFilter initialized with no memory available Added both availableMemory and avgNumRecordsPerBucket check to

[jira] [Commented] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287286#comment-15287286 ] ASF GitHub Bot commented on FLINK-3900: --- Github user rekhajoshm commented on the pul

[GitHub] flink pull request: [FLINK-3900] Set nullCheck=true as default in ...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1994#issuecomment-219817982 thanks @fhueske --- 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 fe

[GitHub] flink pull request: Build a flink-connector-kafka-0.9 test-jar

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1972#issuecomment-219817117 I think this is 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 proj

[GitHub] flink pull request: [FLINK-2829] Confusing error message when Flin...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1993#issuecomment-219816708 thanks @StephanEwen @gyfora @rmetzger 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

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287257#comment-15287257 ] ASF GitHub Bot commented on FLINK-3852: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2829) Confusing error message when Flink cannot create enough task threads

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287274#comment-15287274 ] ASF GitHub Bot commented on FLINK-2829: --- Github user rekhajoshm commented on the pul

[GitHub] flink pull request: [FLINK-3826] Broken test: StreamCheckpointingI...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1977#issuecomment-219816358 Will merge this now, the fix is important! There is need for test cleanup, I agree with that. But that should not block this issue... --- If your project i

[jira] [Commented] (FLINK-3826) Broken test: StreamCheckpointingITCase

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287272#comment-15287272 ] ASF GitHub Bot commented on FLINK-3826: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287262#comment-15287262 ] ASF GitHub Bot commented on FLINK-3852: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3852] update the quickstart module to i...

2016-05-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1982#issuecomment-219815351 No, names are OK. Just thought `DataSetJob` / `DataStreamJob` would be more consistent with API and documentation. We can update the names later. --- If your p

[GitHub] flink pull request: [FLINK-3913] [docs] clean up spelling mistakes

2016-05-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1992#issuecomment-219813059 Thanks for fixing the typos! Merging this PR. --- 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] flink pull request: [FLINK-3852] update the quickstart module to i...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1982#issuecomment-219814739 Race condition ;-) @fhueske I have locally merged this already. To me the names are good, I would keep them unless you feel strongly about the names. --- If yo

[GitHub] flink pull request: [FLINK-3852] update the quickstart module to i...

2016-05-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1982#issuecomment-219814341 Thanks for reworking the quickstart jobs @markreddy. Change look good to me. I am not sure about the naming of the jobs. Should we use `DataSetJob` instead of `BatchJ

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287253#comment-15287253 ] ASF GitHub Bot commented on FLINK-3852: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287228#comment-15287228 ] ASF GitHub Bot commented on FLINK-3900: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287250#comment-15287250 ] ASF GitHub Bot commented on FLINK-3852: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3852] update the quickstart module to i...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1982#issuecomment-219814154 Merging 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 fe

[GitHub] flink pull request: [FLINK-2829] Confusing error message when Flin...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1993#issuecomment-219813882 I agree with Gyula, the problem was a different one. There is a chance that the issue is fixed already. From the current code it looks as if the exceptions

[jira] [Commented] (FLINK-2829) Confusing error message when Flink cannot create enough task threads

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287245#comment-15287245 ] ASF GitHub Bot commented on FLINK-2829: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3900] Set nullCheck=true as default in ...

2016-05-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1994#issuecomment-219812235 Merging this PR. --- 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

[GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-219812166 Merging this PR. --- 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

[jira] [Commented] (FLINK-3913) Clean up documentation typos

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287234#comment-15287234 ] ASF GitHub Bot commented on FLINK-3913: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287227#comment-15287227 ] ASF GitHub Bot commented on FLINK-3754: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287186#comment-15287186 ] ASF GitHub Bot commented on FLINK-3782: --- Github user rekhajoshm commented on the pul

[jira] [Commented] (FLINK-3900) Set nullCheck=true as default in TableConfig

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287184#comment-15287184 ] ASF GitHub Bot commented on FLINK-3900: --- Github user rekhajoshm commented on the pul

[GitHub] flink pull request: [FLINK-3782] ByteArrayOutputStream and ObjectO...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1995#issuecomment-219808609 thanks @StephanEwen @rmetzger --- 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 no

[GitHub] flink pull request: [FLINK-3900] Set nullCheck=true as default in ...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1994#issuecomment-219808304 @twalthr updated doc.thanks --- 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 h

[jira] [Commented] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287172#comment-15287172 ] Stephan Ewen commented on FLINK-3782: - Thanks for contributing to Apache Flink! [~rek

[jira] [Commented] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287167#comment-15287167 ] ASF GitHub Bot commented on FLINK-3782: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3782] ByteArrayOutputStream and ObjectO...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1995#issuecomment-219806248 Merging 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 fe

[jira] [Commented] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287146#comment-15287146 ] ASF GitHub Bot commented on FLINK-3488: --- Github user rekhajoshm commented on the pul

[GitHub] flink pull request: [FLINK-3488] Kafka08ITCase.testBigRecordJob fa...

2016-05-17 Thread rekhajoshm
Github user rekhajoshm commented on the pull request: https://github.com/apache/flink/pull/1998#issuecomment-219804137 thanks @StephanEwen --- 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 thi

[GitHub] flink pull request: [FLINK-3488] Kafka08ITCase.testBigRecordJob fa...

2016-05-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1998#issuecomment-219803482 Thanks for catching this, this was clearly an unstable test that failed only sometimes, due to the element of randomness in the message payload size. Merging

[jira] [Commented] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287142#comment-15287142 ] ASF GitHub Bot commented on FLINK-3488: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3488] Kafka08ITCase.testBigRecordJob fa...

2016-05-17 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/flink/pull/1998 [FLINK-3488] Kafka08ITCase.testBigRecordJob fails on Travis [FLINK-3488] Kafka08ITCase.testBigRecordJob fails on Travis The Kafka08ITCase.testBigRecordJob calls runBigRecordTestTopology,

[jira] [Commented] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287123#comment-15287123 ] ASF GitHub Bot commented on FLINK-3488: --- GitHub user rekhajoshm opened a pull reques

[GitHub] flink pull request: [FLINK-3913] [docs] clean up spelling mistakes

2016-05-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1992#issuecomment-219792375 Thanks a lot for fixing these spelling mistakes! +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Commented] (FLINK-3913) Clean up documentation typos

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287057#comment-15287057 ] ASF GitHub Bot commented on FLINK-3913: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1979) Implement Loss Functions

2016-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287019#comment-15287019 ] ASF GitHub Bot commented on FLINK-1979: --- Github user skavulya commented on a diff in

[GitHub] flink pull request: [FLINK-1979] Add logistic loss, hinge loss and...

2016-05-17 Thread skavulya
Github user skavulya commented on a diff in the pull request: https://github.com/apache/flink/pull/1985#discussion_r63562423 --- Diff: flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/optimization/RegularizationPenaltyITSuite.scala --- @@ -0,0 +1,65 @@ +/* + * L

  1   2   3   >