[jira] [Commented] (FLINK-3799) Graph checksum should execute single job

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257968#comment-15257968 ] ASF GitHub Bot commented on FLINK-3799: --- Github user vasia commented on the pull request:

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258024#comment-15258024 ] ASF GitHub Bot commented on FLINK-3777: --- Github user fpompermaier commented on the pull request:

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread fpompermaier
Github user fpompermaier commented on the pull request: https://github.com/apache/flink/pull/1903#issuecomment-214730690 I added the missing assert, now it should be ok! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1903 --- 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-3777) Add open and close methods to manage IF lifecycle

2016-04-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3777. --- Resolution: Fixed Implemented in ac2137cfa5e63bd4f53a4b7669dc591ab210093f > Add open and

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

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

[jira] [Created] (FLINK-3821) Reduce Guava usage in flink-java

2016-04-26 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-3821: --- Summary: Reduce Guava usage in flink-java Key: FLINK-3821 URL: https://issues.apache.org/jira/browse/FLINK-3821 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1903#discussion_r61078670 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/DataSourceTaskTest.java --- @@ -84,17 +84,26 @@ public void testDataSourceTask() {

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

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

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258026#comment-15258026 ] ASF GitHub Bot commented on FLINK-3777: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1903#issuecomment-214731704 Thanks @fpompermaier. Good 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

[jira] [Created] (FLINK-3822) Document checksum functions

2016-04-26 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3822: - Summary: Document checksum functions Key: FLINK-3822 URL: https://issues.apache.org/jira/browse/FLINK-3822 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-3799] [gelly] Graph checksum should exe...

2016-04-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1922 --- 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-3799) Graph checksum should execute single job

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

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1939 [FLINK-2828] [tableAPI] Add TableSource interfaces for external tables. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1903#issuecomment-214729047 Hi @fpompermaier, thanks for the quick update. I have one last comment. The PR is good to merge once that is resolved. Thanks --- If your project is set up for it,

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258019#comment-15258019 ] ASF GitHub Bot commented on FLINK-3777: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258041#comment-15258041 ] ASF GitHub Bot commented on FLINK-3777: --- Github user zentol commented on the pull request:

[GitHub] flink pull request: [FLINK-3777] Managed closeInputFormat()

2016-04-26 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1903#issuecomment-214734647 Merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258078#comment-15258078 ] ASF GitHub Bot commented on FLINK-2828: --- GitHub user fhueske opened a pull request:

[jira] [Commented] (FLINK-3821) Reduce Guava usage in flink-java

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258015#comment-15258015 ] ASF GitHub Bot commented on FLINK-3821: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request: [FLINK-3799] [gelly] Graph checksum should exe...

2016-04-26 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1922#issuecomment-214732734 I will file a separate ticket for updating the documentation. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-3799) Graph checksum should execute single job

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258044#comment-15258044 ] ASF GitHub Bot commented on FLINK-3799: --- Github user greghogan commented on the pull request:

[jira] [Resolved] (FLINK-3799) Graph checksum should execute single job

2016-04-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-3799. --- Resolution: Implemented Implemented in 06bf4bf3f465b1c019b40dfd7c1662507d7fa2e3 > Graph checksum

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258160#comment-15258160 ] ASF GitHub Bot commented on FLINK-3086: --- Github user vasia commented on the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61101726 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala --- @@ -0,0 +1,139 @@ +/*

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61104611 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchTableSourceScanRule.scala --- @@ -0,0 +1,71 @@ +/*

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258247#comment-15258247 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request:

2016-04-26 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/commit/879bb1bb029ed37e33adc7a655328940135cfcb3#commitcomment-17254978 Could do, but it does not really impact performance very much. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61098440 --- Diff: docs/apis/batch/libs/table.md --- @@ -67,6 +67,165 @@ The central concept of the Table API is a `Table` which represents a table with The

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258199#comment-15258199 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258231#comment-15258231 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61106195 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/TableSourceITCase.scala --- @@ -0,0 +1,123 @@ +/* + *

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258270#comment-15258270 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258271#comment-15258271 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61098044 --- Diff: docs/apis/batch/libs/table.md --- @@ -67,6 +67,165 @@ The central concept of the Table API is a `Table` which represents a table with The

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105638 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableSourceTable.scala --- @@ -0,0 +1,32 @@ +/* + *

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258264#comment-15258264 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105940 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/TableSourceITCase.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258266#comment-15258266 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61106226 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/TableSourceITCase.scala --- @@ -0,0 +1,123 @@ +/* + *

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258192#comment-15258192 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258219#comment-15258219 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61105889 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/TableSourceITCase.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[GitHub] flink pull request:

2016-04-26 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/commit/879bb1bb029ed37e33adc7a655328940135cfcb3#commitcomment-17254739 Should we add this to `release-1.0` as well? --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-3086] [table] ExpressionParser does not...

2016-04-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1912#issuecomment-214762168 I'm not very familiar with the `ExpressionParser`, but I don't see anything suspicious :) --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258258#comment-15258258 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61103432 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamTableSourceScan.scala --- @@ -0,0 +1,126 @@

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

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

[jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode

2016-04-26 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3824: - Summary: ResourceManager may repeatedly connect to outdated JobManager in HA mode Key: FLINK-3824 URL: https://issues.apache.org/jira/browse/FLINK-3824

[jira] [Commented] (FLINK-3708) Scala API for CEP

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

[jira] [Resolved] (FLINK-3708) Scala API for CEP

2016-04-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3708. -- Resolution: Fixed Added via e29ac036a76cc78ea608ffe1f0784ec15e351c60 > Scala API for CEP >

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258451#comment-15258451 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3800] [jobmanager] Terminate ExecutionG...

2016-04-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1923#issuecomment-214812452 Unrelated test case failures. Will be merging this PR to master and the 1.0-release branch. --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [FLINK-3800] [jobmanager] Terminate ExecutionG...

2016-04-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1923 --- 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-3800) ExecutionGraphs can become orphans

2016-04-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3800. Resolution: Fixed Fixed via 28c57c3a57cbd7a02e756ee98c0b1168cec69feb > ExecutionGraphs can become

[jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans

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

[jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source

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

[GitHub] flink pull request: Flink 3750 fixed

2016-04-26 Thread fpompermaier
GitHub user fpompermaier opened a pull request: https://github.com/apache/flink/pull/1941 Flink 3750 fixed Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items

[jira] [Updated] (FLINK-3825) Update CEP documentation to include Scala API

2016-04-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3825: - Assignee: Stefan Richter > Update CEP documentation to include Scala API >

[GitHub] flink pull request: FLINK-3717 - Be able to re-start reading from ...

2016-04-26 Thread kl0u
Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1895#issuecomment-214817636 The problem with this change would be that we do not have yet a way to deserialize a record, so when we are trying to advance readRecords in the block, we have a NULL

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

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

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61120275 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamTableSourceScan.scala --- @@ -0,0 +1,126 @@

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258406#comment-15258406 ] ASF GitHub Bot commented on FLINK-3708: --- Github user tillrohrmann commented on the pull request:

[jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API

2016-04-26 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3825: Summary: Update CEP documentation to include Scala API Key: FLINK-3825 URL: https://issues.apache.org/jira/browse/FLINK-3825 Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61123187 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableSourceTable.scala --- @@ -0,0 +1,32 @@ +/* + *

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258510#comment-15258510 ] ASF GitHub Bot commented on FLINK-3771: --- Github user vasia commented on the pull request:

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258316#comment-15258316 ] ASF GitHub Bot commented on FLINK-3741: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request:

2016-04-26 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/commit/1ccc798914a2bd94157f2a86f7961bc1cc5de490#commitcomment-17256873 Can we add this to release-1.0 as well? --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request:

2016-04-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/1ccc798914a2bd94157f2a86f7961bc1cc5de490#commitcomment-17257298 Yes, will add it right away. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

2016-04-26 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1940 [FLINK-2220] Join on Pojo without hashCode() silently fails Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61120172 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala --- @@ -0,0 +1,139 @@ +/*

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

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

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1905#issuecomment-214806804 Failing test case is unrelated. Really good work @StefanRRichter. Will merge it. As a follow up, we should update the CEP documentation to also include

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

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

[GitHub] flink pull request: [FLINK-2828] [tableAPI] Add TableSource interf...

2016-04-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1939#discussion_r61121181 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchTableSourceScanRule.scala --- @@ -0,0 +1,71 @@

[jira] [Commented] (FLINK-3750) Make JDBCInputFormat a parallel source

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258472#comment-15258472 ] ASF GitHub Bot commented on FLINK-3750: --- Github user fpompermaier commented on the pull request:

[GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750) and othe...

2016-04-26 Thread fpompermaier
Github user fpompermaier commented on the pull request: https://github.com/apache/flink/pull/1885#issuecomment-214813684 Sorry messed up... --- 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

[GitHub] flink pull request: Improved JDBCInputFormat (FLINK-3750) and othe...

2016-04-26 Thread fpompermaier
Github user fpompermaier closed the pull request at: https://github.com/apache/flink/pull/1885 --- 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-3086] [table] ExpressionParser does not...

2016-04-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1912#issuecomment-214814868 Yes, same here ;-) --- 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

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258480#comment-15258480 ] ASF GitHub Bot commented on FLINK-3086: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

2016-04-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258588#comment-15258588 ] Greg Hogan commented on FLINK-2899: --- Is this due to a limitation of {{TypeExtractor.createTypeInfo}} or

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

2016-04-26 Thread markus-h
Github user markus-h closed the pull request at: https://github.com/apache/flink/pull/570 --- 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: [FLINK-3771] [gelly] Methods for translating G...

2016-04-26 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-214825734 By reuse I was referring to needing `MapVertexValueLongToString` and `MapEdgeValueLongToString` since the current `Graph` methods operate at the level of `Vertex` and

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258532#comment-15258532 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull request:

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258598#comment-15258598 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h commented on the pull request:

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

2016-04-26 Thread markus-h
Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-214833775 Sorry for not driving this further. I think this pull request is now way too outdated to have any chance of rebasing it to the current master, therefore I will close

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258599#comment-15258599 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h closed the pull request at:

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

2016-04-26 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-214782976 Hi @vasia, Comparing the APIs, `Translate` processes at the level of label or value whereas `mapVertices/Edges` process vertices and edges. What are use cases for

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258288#comment-15258288 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

2016-04-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1931#issuecomment-214790629 The initial problem still persists :-( Still, I would like to merge this PR to update the `scala-maven-plugin` using in Flink-ML. --- If your project is

[GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

2016-04-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1931#issuecomment-214799876 This PR does not solve the issue FLINK-3741. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-3741] [build] Replace maven-scala-plugi...

2016-04-26 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/1931 --- 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

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258282#comment-15258282 ] ASF GitHub Bot commented on FLINK-2828: --- Github user vasia commented on the pull request:

[jira] [Commented] (FLINK-3199) KafkaITCase.testOneToOneSources

2016-04-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258317#comment-15258317 ] Till Rohrmann commented on FLINK-3199: -- Found another instance:

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

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

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

2016-04-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258361#comment-15258361 ] ASF GitHub Bot commented on FLINK-3741: --- Github user tillrohrmann commented on the pull request:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-04-26 Thread Saumitra Shahapure (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258680#comment-15258680 ] Saumitra Shahapure commented on FLINK-2254: --- Hi [~vkalavri], I started working on this issue,

[jira] [Updated] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-04-26 Thread Saumitra Shahapure (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Saumitra Shahapure updated FLINK-2254: -- Assignee: (was: Saumitra Shahapure) > Add Bipartite Graph Support for Gelly >

[GitHub] flink pull request: Refactoring the File Monitoring Source.

2016-04-26 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1929#issuecomment-214664097 One additional remark. I'd like to get rid of these fields in `FileSplitMonitoringFunctionTest`: ``` private Set hdPaths = new HashSet<>(); private Set

<    1   2   3   >