[jira] [Created] (FLINK-5545) remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite

2017-01-17 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-5545: --- Summary: remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite Key: FLINK-5545 URL: https://issues.apache.org/jira/browse/FLINK-5545 Project: Flink

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

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827558#comment-15827558 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the

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

2017-01-17 Thread ex00
Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r96580679 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -46,6 +47,7 @@ class DataSetSin

[GitHub] flink pull request #3148: Remove one of duplicate "their" on the "Basic API ...

2017-01-17 Thread keijiyoshida
GitHub user keijiyoshida opened a pull request: https://github.com/apache/flink/pull/3148 Remove one of duplicate "their" on the "Basic API Concepts" document. This is a trivial fix and there is no related JIRA issue according to http://flink.apache.org/contribute-documentation.html

[GitHub] flink pull request #3147: Fix an invalid return type of sample code on the "...

2017-01-17 Thread keijiyoshida
GitHub user keijiyoshida opened a pull request: https://github.com/apache/flink/pull/3147 Fix an invalid return type of sample code on the "Basic API Concepts" document. This is a trivial fix and there is no related JIRA issue according to http://flink.apache.org/contribute-documen

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

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

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-01-17 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r96572366 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/FlinkAggregateExpandDistinctAggregatesRule.java --- @@ -0,0 +1

[GitHub] flink pull request #3146: Insert necessary closing parentheses into the "Bas...

2017-01-17 Thread keijiyoshida
GitHub user keijiyoshida opened a pull request: https://github.com/apache/flink/pull/3146 Insert necessary closing parentheses into the "Basic API Concepts" document. This is a trivial fix and there is no related JIRA issue according to http://flink.apache.org/contribute-documentati

[GitHub] flink pull request #3145: Fix a wrong function name `groupBy()` to `keyBy()`...

2017-01-17 Thread keijiyoshida
GitHub user keijiyoshida opened a pull request: https://github.com/apache/flink/pull/3145 Fix a wrong function name `groupBy()` to `keyBy()` on the "Basic API Concepts" document. Fix a wrong function name `groupBy()` to `keyBy()` on the "Basic API Concepts" document. This

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827438#comment-15827438 ] ASF GitHub Bot commented on FLINK-3475: --- Github user docete commented on a diff in t

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-01-17 Thread docete
Github user docete commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r96568781 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/FlinkAggregateExpandDistinctAggregatesRule.java --- @@ -0,0 +1,

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-01-17 Thread docete
Github user docete commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r96568191 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/AggregationTest.scala --- @@ -165,9 +165,13 @@ class AggregationTest extends Table

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827429#comment-15827429 ] ASF GitHub Bot commented on FLINK-3475: --- Github user docete commented on a diff in t

[GitHub] flink issue #3141: [FLINK-5520] [table] Disable outer joins with non-equalit...

2017-01-17 Thread shaoxuan-wang
Github user shaoxuan-wang commented on the issue: https://github.com/apache/flink/pull/3141 @wuchong @lincoln-lil , I do not think this is just for 1.2.0. The out join with non equality functionality is broken on master. We should deliver this fix to the master as well as release 1.2.

[jira] [Commented] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827423#comment-15827423 ] ASF GitHub Bot commented on FLINK-5520: --- Github user shaoxuan-wang commented on the

[jira] [Commented] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827414#comment-15827414 ] ASF GitHub Bot commented on FLINK-5520: --- Github user lincoln-lil commented on the is

[GitHub] flink issue #3141: [FLINK-5520] [table] Disable outer joins with non-equalit...

2017-01-17 Thread lincoln-lil
Github user lincoln-lil commented on the issue: https://github.com/apache/flink/pull/3141 Hi, wuchong, thanks for your review. I'll switch the pr based on 1.2.0. I think it's not necessary doing validation repeatedly both in DataSetJoinRule.java and operators.scala, and there alrea

[jira] [Updated] (FLINK-5544) Implement Internal Timer Service in RocksDB

2017-01-17 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi updated FLINK-5544: Issue Type: New Feature (was: Bug) > Implement Internal Timer Service in RocksDB >

[jira] [Created] (FLINK-5544) Implement Internal Timer Service in RocksDB

2017-01-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5544: --- Summary: Implement Internal Timer Service in RocksDB Key: FLINK-5544 URL: https://issues.apache.org/jira/browse/FLINK-5544 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827375#comment-15827375 ] ASF GitHub Bot commented on FLINK-5520: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3141: [FLINK-5520] [table] Disable outer joins with non-equalit...

2017-01-17 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3141 Hi @lincoln-lil , thank your for the PR. I think the issue is only for 1.2.0, so please create a new pull request to commit into `release-1.2`. For `master` we will directly fix the bug. I

[jira] [Comment Edited] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827361#comment-15827361 ] Zhijiang Wang edited comment on FLINK-5501 at 1/18/17 3:16 AM: -

[jira] [Commented] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827361#comment-15827361 ] Zhijiang Wang commented on FLINK-5501: -- Thank you for the quick response! Yeah, you

[jira] [Updated] (FLINK-5498) Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)

2017-01-17 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-5498: --- Description: I found the expected result of a unit test case incorrect compare to that in a RDMBS, s

[jira] [Updated] (FLINK-5498) Add support for left/right outer joins with non-equality predicates (and 1+ equality predicates)

2017-01-17 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-5498: --- Summary: Add support for left/right outer joins with non-equality predicates (and 1+ equality predicat

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2017-01-17 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 #3037 has merged. 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 have this feature enabled and wish

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

2017-01-17 Thread liuyuzhong
Github user liuyuzhong closed the pull request at: https://github.com/apache/flink/pull/2439 --- 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-4450) update storm version to 1.0.0

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827281#comment-15827281 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the iss

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827282#comment-15827282 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong closed the pull requ

[jira] [Commented] (FLINK-5023) Add get() method in State interface

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827234#comment-15827234 ] ASF GitHub Bot commented on FLINK-5023: --- Github user shixiaogang commented on the is

[GitHub] flink issue #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor to cla...

2017-01-17 Thread shixiaogang
Github user shixiaogang commented on the issue: https://github.com/apache/flink/pull/2768 Despite the changes in the state descriptors, the Flink jobs can restore from old versioned snapshots now. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-5543) customCommandLine tips in CliFrontend

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

[GitHub] flink pull request #3144: [FLINK-5543][Client] customCommandLine tips in Cli...

2017-01-17 Thread shijinkui
GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/3144 [FLINK-5543][Client] customCommandLine tips in CliFrontend Only some code annotation in the CliFrontend. You can merge this pull request into a Git repository by running: $ git pull https://g

[jira] [Created] (FLINK-5543) customCommandLine tips in CliFrontend

2017-01-17 Thread shijinkui (JIRA)
shijinkui created FLINK-5543: Summary: customCommandLine tips in CliFrontend Key: FLINK-5543 URL: https://issues.apache.org/jira/browse/FLINK-5543 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827101#comment-15827101 ] ASF GitHub Bot commented on FLINK-5519: --- Github user shijinkui commented on the issu

[GitHub] flink issue #3132: [FLINK-5519] [build] scala-maven-plugin version all chang...

2017-01-17 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/3132 > @rmetzger Any reservations that the upgrade to the Apache Parent POM v18 has implications on release scripts, etc? @StephanEwen There's no effect to the create_release_files.sh in my opin

[jira] [Created] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2017-01-17 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5542: Summary: YARN client incorrectly uses local YARN config to check vcore capacity Key: FLINK-5542 URL: https://issues.apache.org/jira/browse/FLINK-5542 Project: Flink

[jira] [Closed] (FLINK-5461) Remove Superflous TypeInformation Declaration

2017-01-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5461. - Resolution: Implemented Implemented in b408d61f707806d2a188c55065d1187f4f05099a > Remove Superflous TypeI

[jira] [Commented] (FLINK-5461) Remove Superflous TypeInformation Declaration

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

[GitHub] flink pull request #3096: [FLINK-5461] [gelly] Remove Superflous TypeInforma...

2017-01-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3096 --- 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] [Created] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

2017-01-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5541: - Summary: Missing null check for localJar in FlinkSubmitter#submitTopology() Key: FLINK-5541 URL: https://issues.apache.org/jira/browse/FLINK-5541 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826807#comment-15826807 ] ASF GitHub Bot commented on FLINK-4450: --- Github user greghogan commented on the issu

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2017-01-17 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2439 Please close this since there is a newer 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] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5298: Component/s: Mesos > TaskManager crashes when TM log not existant >

[jira] [Closed] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

2017-01-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5518. Resolution: Fixed Fix Version/s: 1.1.5 1.3.0 1.2.0 Fixe

[jira] [Updated] (FLINK-5472) WebUI endpoint not advertised correctly to Mesos

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5472: Component/s: Mesos > WebUI endpoint not advertised correctly to Mesos >

[jira] [Commented] (FLINK-5030) Support hostname verification

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826705#comment-15826705 ] ASF GitHub Bot commented on FLINK-5030: --- Github user EronWright commented on the iss

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

2017-01-17 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3061 @tillrohrmann this PR may address the issue you saw in FLINK-5472. --- 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 d

[jira] [Updated] (FLINK-5472) WebUI endpoint not advertised correctly to Mesos

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5472: Description: When trying to access {{https://jobmanager:port}}, chrome says that the webserver answ

[jira] [Updated] (FLINK-5472) WebUI endpoint not advertised correctly to Mesos

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5472: Summary: WebUI endpoint not advertised correctly to Mesos (was: Flink's web server does not support

[jira] [Commented] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826701#comment-15826701 ] ASF GitHub Bot commented on FLINK-5518: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3133: [FLINK-5518] [input/output formats] Add null value check.

2017-01-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3133 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 enabled and wishes so, or if the fea

[jira] [Created] (FLINK-5539) CLI: info/list/stop/cancel

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5539: --- Summary: CLI: info/list/stop/cancel Key: FLINK-5539 URL: https://issues.apache.org/jira/browse/FLINK-5539 Project: Flink Issue Type: Sub-task Repor

[jira] [Commented] (FLINK-5472) Flink's web server does not support https requests

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826699#comment-15826699 ] Eron Wright commented on FLINK-5472: - Basic support for SSL on the webUI was added in

[jira] [Created] (FLINK-5540) CLI: savepoint

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5540: --- Summary: CLI: savepoint Key: FLINK-5540 URL: https://issues.apache.org/jira/browse/FLINK-5540 Project: Flink Issue Type: Sub-task Reporter: Eron Wr

[jira] [Created] (FLINK-5537) Config option: SSL

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5537: --- Summary: Config option: SSL Key: FLINK-5537 URL: https://issues.apache.org/jira/browse/FLINK-5537 Project: Flink Issue Type: Sub-task Reporter: Ero

[jira] [Created] (FLINK-5538) Config option: Kerberos

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5538: --- Summary: Config option: Kerberos Key: FLINK-5538 URL: https://issues.apache.org/jira/browse/FLINK-5538 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-5535) Config option: HDFS

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5535: --- Summary: Config option: HDFS Key: FLINK-5535 URL: https://issues.apache.org/jira/browse/FLINK-5535 Project: Flink Issue Type: Sub-task Reporter: Er

[jira] [Created] (FLINK-5536) Config option: HA

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5536: --- Summary: Config option: HA Key: FLINK-5536 URL: https://issues.apache.org/jira/browse/FLINK-5536 Project: Flink Issue Type: Sub-task Reporter: Eron

[jira] [Created] (FLINK-5534) Config option: 'flink-options'

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5534: --- Summary: Config option: 'flink-options' Key: FLINK-5534 URL: https://issues.apache.org/jira/browse/FLINK-5534 Project: Flink Issue Type: Sub-task R

[jira] [Closed] (FLINK-1984) Integrate Flink with Apache Mesos

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-1984. --- Resolution: Fixed > Integrate Flink with Apache Mesos > - > >

[jira] [Updated] (FLINK-5533) DCOS Integration

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5533: Description: Umbrella issue for DCOS integration, including production-level features but not futur

[jira] [Assigned] (FLINK-5533) DCOS Integration

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright reassigned FLINK-5533: --- Assignee: Eron Wright (was: Till Rohrmann) > DCOS Integration > > >

[jira] [Updated] (FLINK-5533) DCOS Integration

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5533: Description: Umbrella issue for DCOS integration, including production-level features but not futur

[jira] [Closed] (FLINK-4899) Implement DCOS package

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4899. --- Resolution: Duplicate Closing in favor of sub-tasks in FLINK-5533. > Implement DCOS package > ---

[jira] [Closed] (FLINK-4901) Build DCOS Docker image

2017-01-17 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4901. --- Resolution: Fixed This is done: https://github.com/mesosphere/dcos-flink-service/ > Build DCOS Docke

[jira] [Created] (FLINK-5533) DCOS Integration

2017-01-17 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5533: --- Summary: DCOS Integration Key: FLINK-5533 URL: https://issues.apache.org/jira/browse/FLINK-5533 Project: Flink Issue Type: New Feature Components: Me

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826563#comment-15826563 ] ASF GitHub Bot commented on FLINK-5092: --- Github user zentol commented on the issue:

[GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ...

2017-01-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2836 @BorisOsipov i haven't found time yet to try this out :( The long running time makes it tricky since you devote the machine completely to tests for hours. I could let it run over night though

[GitHub] flink pull request #3143: [FLINK-5530] fix race condition in AbstractRocksDB...

2017-01-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3143#discussion_r96476317 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java --- @@ -132,55 +132,95 @@

[jira] [Commented] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826548#comment-15826548 ] ASF GitHub Bot commented on FLINK-5530: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826534#comment-15826534 ] ASF GitHub Bot commented on FLINK-5092: --- Github user BorisOsipov commented on the is

[GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ...

2017-01-17 Thread BorisOsipov
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2836 @zentol Hi. Any news? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

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

[GitHub] flink pull request #3143: [FLINK-5530] fix race condition in AbstractRocksDB...

2017-01-17 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3143 [FLINK-5530] fix race condition in AbstractRocksDBState#getSerializedValue `AbstractRocksDBState#getSerializedValue()` uses the same key serialisation stream as the ordinary state access methods bu

[jira] [Updated] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable.

2017-01-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5532: -- Description: This issue refers to the {{SlidingAlignedProcessingTimeWindows}} and {{TumblingAli

[jira] [Updated] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable.

2017-01-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5532: -- Description: This issue refers to the [SlidingAlignedProcessingTimeWindows] and `TumblingAligne

[jira] [Assigned] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable.

2017-01-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-5532: - Assignee: Kostas Kloudas > Make the marker windowassignes for the fast aligned windows no

[jira] [Created] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable.

2017-01-17 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5532: - Summary: Make the marker windowassignes for the fast aligned windows non-extendable. Key: FLINK-5532 URL: https://issues.apache.org/jira/browse/FLINK-5532 Project:

[GitHub] flink issue #2974: [FLINK-5298] TM checks that log file exists

2017-01-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2974 @tillrohrmann well it still needs a review. --- 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 e

[jira] [Commented] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

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

[GitHub] flink issue #3132: [FLINK-5519] [build] scala-maven-plugin version all chang...

2017-01-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3132 I think its fine (as long as we are not merging it to the 1.2 release branch) --- 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-5519) scala-maven-plugin version all change to 3.2.2

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

[GitHub] flink issue #3132: [FLINK-5519] [build] scala-maven-plugin version all chang...

2017-01-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3132 Okay, good. Then I think this is probably good to merge. @rmetzger Any reservations that the upgrade to the Apache Parent POM v18 has implications on release scripts, etc? --- If yo

[jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826436#comment-15826436 ] ASF GitHub Bot commented on FLINK-5298: --- Github user zentol commented on the issue:

[GitHub] flink pull request #3142: [FLINK-5527][query] querying a non-existing key do...

2017-01-17 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3142 [FLINK-5527][query] querying a non-existing key does not return the default value Querying for a non-existing key for a state that has a default value set currently results in an UnknownKeyOrNamespac

[jira] [Commented] (FLINK-5527) QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value

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

[GitHub] flink issue #2974: [FLINK-5298] TM checks that log file exists

2017-01-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2974 What is the state of this PR? It would be great to merge this for the next release candidate. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826422#comment-15826422 ] ASF GitHub Bot commented on FLINK-5298: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826381#comment-15826381 ] ASF GitHub Bot commented on FLINK-5519: --- Github user zentol commented on the issue:

[GitHub] flink issue #3132: [FLINK-5519] [build] scala-maven-plugin version all chang...

2017-01-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3132 @StephanEwen There already is an entry for `scala-maven-plugin` in the plugin management section. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826380#comment-15826380 ] Shaoxuan Wang commented on FLINK-5386: -- Yes [~fhueske], we should not support groupby

[jira] [Commented] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826379#comment-15826379 ] ASF GitHub Bot commented on FLINK-5520: --- GitHub user lincoln-lil opened a pull reque

[GitHub] flink pull request #3141: [FLINK-5520] [table] Disable outer joins with non-...

2017-01-17 Thread lincoln-lil
GitHub user lincoln-lil opened a pull request: https://github.com/apache/flink/pull/3141 [FLINK-5520] [table] Disable outer joins with non-equality predicates Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consid

[jira] [Commented] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

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

[GitHub] flink issue #3132: [FLINK-5519] [build] scala-maven-plugin version all chang...

2017-01-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3132 Good idea to upgrade the scala plugin. But with this change, it does not define a version at all. I think it would need to be added to the "plugin management" section. --- If your project is

[GitHub] flink issue #3136: [FLINK-5512] [doc] Improve RabbitMQ documentation

2017-01-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3136 Very nice, +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-5512) RabbitMQ documentation should inform that exactly-once holds for RMQSource only when parallelism is 1

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

[GitHub] flink issue #3138: #Flink-5522 Storm Local Cluster can't work with powermock

2017-01-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3138 I think the correct fix would be not to remove the code, but - either make sure that storm classes are ignored by powermnock (add an ignore pattern) - rework the test such that powermo

[GitHub] flink issue #3010: [minor] Fix String formats in FlinkDistributionOverlay an...

2017-01-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3010 @tillrohrmann does this PR fix FLINK-5493? --- 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 en

  1   2   3   >