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

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

[GitHub] flink pull request #1121: [FLINK-2591] Add configuration parameter for defau...

2017-05-12 Thread willmiao
Github user willmiao closed the pull request at: https://github.com/apache/flink/pull/1121 --- 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-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16009102#comment-16009102 ] ASF GitHub Bot commented on FLINK-6397: --- Github user ifndef-SleePy commented on the issue:

[GitHub] flink issue #3810: [FLINK-6397] MultipleProgramsTestBase does not reset Cont...

2017-05-12 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/3810 Nice work! I have rebased master. --- 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-6529) Rework the shading model in Flink

2017-05-12 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008891#comment-16008891 ] Haohui Mai commented on FLINK-6529: --- Will do. Thanks! > Rework the shading model in Flink >

[jira] [Commented] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008889#comment-16008889 ] ASF GitHub Bot commented on FLINK-6569: --- GitHub user haohui opened a pull request:

[GitHub] flink pull request #3890: [FLINK-6569] flink-table KafkaJsonTableSource exam...

2017-05-12 Thread haohui
GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/3890 [FLINK-6569] flink-table KafkaJsonTableSource example doesn't work. This PR makes the proposed changes on the document and changes the Java unit tests to reflect the suggested usages of the API.

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

2017-05-12 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008853#comment-16008853 ] Greg Hogan commented on FLINK-6573: --- [~naagachowdary] glad to hear of your success and thank you for

[jira] [Created] (FLINK-6574) External catalog should support a single level catalog

2017-05-12 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6574: - Summary: External catalog should support a single level catalog Key: FLINK-6574 URL: https://issues.apache.org/jira/browse/FLINK-6574 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

2017-05-12 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008821#comment-16008821 ] Haohui Mai commented on FLINK-6568: --- Hit the same issue multiple times when testing out 1.3. Are we good

[jira] [Assigned] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

2017-05-12 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6569: - Assignee: Haohui Mai > flink-table KafkaJsonTableSource example doesn't work >

[jira] [Assigned] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

2017-05-12 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6568: - Assignee: Haohui Mai > flink-table doesn't work without flink-streaming-scala dependency >

[jira] [Commented] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

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

[jira] [Commented] (FLINK-6548) AvroOutputFormatTest fails on Windows

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

[jira] [Commented] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

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

[jira] [Commented] (FLINK-6558) Yarn tests fail on Windows

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

[GitHub] flink issue #3810: [FLINK-6397] MultipleProgramsTestBase does not reset Cont...

2017-05-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3810 I've fixed the cassandra tests, would be great if you could rebase this PR. You should be able to discard all changes to the cassandra tests in this PR. --- If your project is set up for it, you can

[GitHub] flink pull request #3878: [FLINK-6561] Disable glob test on Windows

2017-05-12 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3878 --- 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 #3874: [FLINK-6558] Disable yarn tests on Windows

2017-05-12 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3874 --- 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 #3871: [FLINK-6548] Fix AvroOutputFormatTest#testCompress...

2017-05-12 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3871 --- 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-4500) Cassandra sink can lose messages

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008756#comment-16008756 ] Chesnay Schepler commented on FLINK-4500: - The second part of this issue (tracking in-flight

[jira] [Closed] (FLINK-5101) Test CassandraConnectorITCase instable

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5101. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Closed] (FLINK-6548) AvroOutputFormatTest fails on Windows

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6548. --- Resolution: Fixed 1.3: c743f14ecb08f39a3f7278340a89d1a035749aa7 1.4:

[jira] [Closed] (FLINK-6558) Yarn tests fail on Windows

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6558. --- Resolution: Fixed 1.3: f0ff5046901c507d34675375c85a1f17e6d4ecdb 1.4:

[jira] [Reopened] (FLINK-6558) Yarn tests fail on Windows

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-6558: - > Yarn tests fail on Windows > -- > > Key: FLINK-6558

[jira] [Closed] (FLINK-6558) Yarn tests fail on Windows

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6558. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 > Yarn tests fail on

[jira] [Commented] (FLINK-5101) Test CassandraConnectorITCase instable

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

[jira] [Closed] (FLINK-6561) GlobFilePathFilterTest#testExcludeFilenameWithStart fails on Windows

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6561. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[GitHub] flink pull request #2866: [FLINK-5101] Refactor CassandraConnectorITCase

2017-05-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2866 --- 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-6013) Add Datadog HTTP metrics reporter

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6013. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3: 625da00a5797c29969b947f69ccda91ef87eb5c4

[jira] [Created] (FLINK-6573) Flink MongoDB Connector

2017-05-12 Thread Nagamallikarjuna (JIRA)
Nagamallikarjuna created FLINK-6573: --- Summary: Flink MongoDB Connector Key: FLINK-6573 URL: https://issues.apache.org/jira/browse/FLINK-6573 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008545#comment-16008545 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on the issue:

[GitHub] flink issue #3714: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-05-12 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3714 @fhueske Please refer to #3889 which contains the same code updated to the new interfaces --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008546#comment-16008546 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on the issue:

[GitHub] flink issue #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-05-12 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3889 @fhueske I updated the code to work with 1.3 (CRow, FlinkLogicalSort) and all the implied changes. We can close #3714 after we merge this i guess ..that one is the same logical code only

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008544#comment-16008544 ] ASF GitHub Bot commented on FLINK-6075: --- GitHub user rtudoran opened a pull request:

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-12 Thread rtudoran
GitHub user rtudoran opened a pull request: https://github.com/apache/flink/pull/3889 [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL Order by time and optionally other fields is supported Thanks for contributing to Apache Flink. Before you open your pull request,

[jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008536#comment-16008536 ] Robert Metzger commented on FLINK-6116: --- I'm fine with leaving this open for the 1.3 release. Its

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-05-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008517#comment-16008517 ] Chesnay Schepler commented on FLINK-5095: - The following is what is sketched out a while ago when

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-05-12 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008430#comment-16008430 ] Bowen Li commented on FLINK-5095: - [~Zentol] Can you list your proposed interfaces here? Want to make sure

[jira] [Closed] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-05-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5256. Implemented for 1.3 with 01171e821699a4c1e5f7a73f878d696552354ab4 Implemented for 1.4 with

[jira] [Closed] (FLINK-6562) Support implicit table references for nested fields in SQL

2017-05-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6562. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3 with

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008382#comment-16008382 ] ASF GitHub Bot commented on FLINK-6020: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #3888: [FLINK-6020] Introduce BlobServer#readWriteLock to...

2017-05-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3888 [FLINK-6020] Introduce BlobServer#readWriteLock to synchronize file creation and deletion This PR is based on #3873 and #3864. This commit introduces a BlobServer#readWriteLock in

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3673 --- 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-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3879: [FLINK-6562] Support implicit table references for...

2017-05-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3879 --- 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-6562) Support implicit table references for nested fields in SQL

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116272631 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -0,0 +1,323 @@ +/* + *

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116269111 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -159,9 +172,9 @@ class

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116268688 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -0,0 +1,180 @@ +/* +

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116272041 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -44,12 +48,18 @@ import

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116270545 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -199,31 +157,38 @@ object JoinUtil {

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116273281 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -298,16 +289,17 @@ class

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116261121 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -37,14 +39,18 @@ import

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116261221 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -37,14 +39,18 @@ import

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116260594 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -698,14 +698,7 @@ class CodeGenerator(

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116269180 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala --- @@ -159,9 +172,9 @@ class

[jira] [Commented] (FLINK-6462) Add requiresOver interface for AggregateFunction

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008350#comment-16008350 ] ASF GitHub Bot commented on FLINK-6462: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #3851: [FLINK-6462] [table] Add requiresOver interface for Aggre...

2017-05-12 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3851 Hi @fhueske, Thanks for the reviewing. I forgot to run the `mvn verify` at the first time. Sorry for that.:( I had update the PR. according your comments. Except one,i.e.: Move

[GitHub] flink pull request #3887: [hotfix] [docs] Fix link to docker-compose.yml

2017-05-12 Thread patricklucas
GitHub user patricklucas opened a pull request: https://github.com/apache/flink/pull/3887 [hotfix] [docs] Fix link to docker-compose.yml You can merge this pull request into a Git repository by running: $ git pull https://github.com/patricklucas/flink

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008336#comment-16008336 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

2017-05-12 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/3736 Cool! 1.3 here we go! --- 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] [Updated] (FLINK-6572) Make configuration properties available as env vars in Docker image

2017-05-12 Thread Joshua Griffith (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joshua Griffith updated FLINK-6572: --- Summary: Make configuration properties available as env vars in Docker image (was: Make

[jira] [Created] (FLINK-6572) Make Flink configuration properties available as env vars in Docker image

2017-05-12 Thread Joshua Griffith (JIRA)
Joshua Griffith created FLINK-6572: -- Summary: Make Flink configuration properties available as env vars in Docker image Key: FLINK-6572 URL: https://issues.apache.org/jira/browse/FLINK-6572 Project:

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-12 Thread DmytroShkvyra
Github user DmytroShkvyra commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r116255981 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala --- @@ -77,7 +77,9 @@ private

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[jira] [Commented] (FLINK-5363) Fire timers when window state is currently empty

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008264#comment-16008264 ] ASF GitHub Bot commented on FLINK-5363: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3034: [FLINK-5363] Fire timers when window state is currently e...

2017-05-12 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3034 @aljoscha can the new behavior be demonstrated by a test? --- 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-6043) Display time when exceptions/root cause of failure happened

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

[jira] [Commented] (FLINK-6043) Display time when exceptions/root cause of failure happened

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

[GitHub] flink pull request #3583: [FLINK-6043] [web] Display exception timestamp

2017-05-12 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3583#discussion_r116251216 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -955,14 +950,33 @@ public void stop() throws

[GitHub] flink pull request #3583: [FLINK-6043] [web] Display exception timestamp

2017-05-12 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3583#discussion_r116250328 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ErrorInfo.java --- @@ -0,0 +1,84 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

2017-05-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6571: --- Summary: InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Key: FLINK-6571 URL: https://issues.apache.org/jira/browse/FLINK-6571

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-12 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r116250994 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalJoin.scala --- @@ -77,7 +77,9 @@ private class

[jira] [Commented] (FLINK-6565) Improve error messages for state restore failures

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008254#comment-16008254 ] ASF GitHub Bot commented on FLINK-6565: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #3882: [FLINK-6565] Fail memory-backed state restores with meani...

2017-05-12 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3882 LGTM +1 --- 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

[GitHub] flink pull request #:

2017-05-12 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/commit/423f4d65e3dd35482fdbc2fb7e34ec8f11243609#commitcomment-22120213 In flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorTest.java: In

[jira] [Commented] (FLINK-6554) CompatibilityResult should contain a notCompatible() option

2017-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008245#comment-16008245 ] ASF GitHub Bot commented on FLINK-6554: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #3886: [FLINK-6554] [core] Make CompatibilityResult options more...

2017-05-12 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3886 LGTM +1 --- 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

[jira] [Commented] (FLINK-6566) Narrow down interface for compatibility hook method in VersionedIOReadableWritable

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

[GitHub] flink pull request #3883: [FLINK-6566] [core] More restricted interface for ...

2017-05-12 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3883#discussion_r116249086 --- Diff: flink-core/src/main/java/org/apache/flink/core/io/VersionedIOReadableWritable.java --- @@ -18,55 +18,66 @@ package

[jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008234#comment-16008234 ] Aljoscha Krettek commented on FLINK-6116: - Unfortunately, I don't see an easy solution for this.

[GitHub] flink issue #3870: [Flink 6537] Fixes and improvements for incremental check...

2017-05-12 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3870 Updated and enhanced. --- 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

[GitHub] flink issue #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

2017-05-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3736 Merging to 1.3 now. --- 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] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

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

[jira] [Updated] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

2017-05-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6568: - Fix Version/s: 1.3.0 > flink-table doesn't work without flink-streaming-scala dependency >

[jira] [Updated] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

2017-05-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6569: - Fix Version/s: 1.3.0 > flink-table KafkaJsonTableSource example doesn't work >

[jira] [Created] (FLINK-6570) QueryableStateClient constructor in documentation doesn't match actual signature

2017-05-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-6570: - Summary: QueryableStateClient constructor in documentation doesn't match actual signature Key: FLINK-6570 URL: https://issues.apache.org/jira/browse/FLINK-6570

  1   2   3   >