[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

[GitHub] flink pull request #4488: [FLINK-7337] [table] Refactor internal handling of...

2017-08-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4488#discussion_r131743809 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -245,14 +244,18 @@ abstract class

[jira] [Commented] (FLINK-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled

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

[GitHub] flink pull request #4488: [FLINK-7337] [table] Refactor internal handling of...

2017-08-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4488#discussion_r131750828 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala --- @@ -148,6

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad updated FLINK-5539: --- Release Note: dcos-flink-service https://github.com/mesosphere/dcos-flink-service/pull/37 dcos

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad reassigned FLINK-5539: -- Assignee: Robin Oh (was: Joerg Schad) > CLI: run/info/list/stop/cancel >

[jira] [Commented] (FLINK-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117179#comment-16117179 ] ASF GitHub Bot commented on FLINK-7362: --- Github user aljoscha commented on the issue:

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad reassigned FLINK-5539: -- Assignee: Joerg Schad (was: Robin Oh) > CLI: run/info/list/stop/cancel >

[GitHub] flink pull request #4488: [FLINK-7337] [table] Refactor internal handling of...

2017-08-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4488#discussion_r131764752 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala --- @@ -415,7 +406,13 @@ class

[GitHub] flink pull request #4488: [FLINK-7337] [table] Refactor internal handling of...

2017-08-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4488#discussion_r131761767 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowOutputProcessRunner.scala --- @@ -18,42 +18,54 @@

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will

[jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint

2017-08-07 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117574#comment-16117574 ] Eron Wright commented on FLINK-7072: - Note that 'submit job' refers to job graph submission, not

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

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

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad closed FLINK-5539. -- Resolution: Fixed Release Note: dcos-flink-service

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-07 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 Hi @tzulitai , Let's reach a consensus before I do any more works. 1) I didn't add all KPL's configs in this PR. I only added some configs that I think might be useful to

[jira] [Closed] (FLINK-7221) JDBCOutputFormat swallows errors on last batch

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

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

2017-08-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117500#comment-16117500 ] Haohui Mai commented on FLINK-6429: --- bq. In order to change the default behavior of the rule, the only

[jira] [Commented] (FLINK-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

2017-08-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117498#comment-16117498 ] Bowen Li commented on FLINK-7365: - How about turning off Hadoop logging by default? Is it harmful in any

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

2017-08-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117328#comment-16117328 ] Haohui Mai commented on FLINK-6429: --- It's difficult to say this is a pure Calcite bug. Technically SQL

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

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

[GitHub] flink pull request #4491: [FLINK-7362] [checkpoints] Savepoint property is l...

2017-08-07 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4491#discussion_r13175 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java --- @@ -225,6 +230,7 @@ public String toString() {

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will

[GitHub] flink issue #4491: [FLINK-7362] [checkpoints] Savepoint property is lost aft...

2017-08-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4491 This looks good, modulo the slight copying error! 👍 --- 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

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad reopened FLINK-5539: Added to documentation https://github.com/dcos/examples/pull/199 > CLI: run/info/list/stop/cancel >

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

2017-08-07 Thread Joerg Schad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joerg Schad closed FLINK-5539. -- Resolution: Fixed > CLI: run/info/list/stop/cancel > -- > >

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131628087 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -637,9 +675,23 @@ private boolean

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7376) Cleanup options class and test classes in flink-clients

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116441#comment-16116441 ] ASF GitHub Bot commented on FLINK-7376: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Closed] (FLINK-3378) Consolidate TestingCluster and FokableFlinkMiniCluster

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-3378. -- Resolution: Fixed {{ForkableFlinkMiniCluster}} was replaced by {{LocalFlinkMiniCluster}} which

[jira] [Updated] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-4005: --- Labels: test-stability (was: ) > LocalExecutorITCase.testLocalExecutorWithWordCount fails >

[GitHub] flink issue #4296: [FLINK-7147] [cep] Support greedy quantifier in CEP

2017-08-07 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4296 There is also one more problem. When we have optional after `greedy` it does not work well. E.g. have a look at this test case: @Test public void

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116461#comment-16116461 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dawidwys commented on the issue:

[jira] [Updated] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5671: --- Labels: test-stability (was: ) > Test ClassLoaderITCase#testJobsWithCustomClassLoader fails >

[jira] [Commented] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116478#comment-16116478 ] Nico Kruber commented on FLINK-5671: we may have some more info now in case this returns > Test

[jira] [Created] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7381: Summary: Decouple WebRuntimeMonitor from ActorGateway Key: FLINK-7381 URL: https://issues.apache.org/jira/browse/FLINK-7381 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116509#comment-16116509 ] Nico Kruber commented on FLINK-6997: The issue reported by [~mingleizhang] seems to be caused by

[GitHub] flink pull request #4488: [FLINK-7337] [table] Refactor internal handling of...

2017-08-07 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4488 [FLINK-7337] [table] Refactor internal handling of time indicator attributes. ## What is the purpose of the change Handle time indicators attributes as physical fields in `Row`. -

[jira] [Commented] (FLINK-7383) Remove ConfigurationUtil

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

[jira] [Commented] (FLINK-7310) always use HybridMemorySegment

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

[GitHub] flink issue #4445: [FLINK-7310][core] always use the HybridMemorySegment

2017-08-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4445 I think the implementation of the change is good, but the performance impact seems noticeable, at least in some cases. I think the additional bounds checking in the hybrid case shows. Out of

[jira] [Commented] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116536#comment-16116536 ] Nico Kruber commented on FLINK-4295: this est doesn't seem complete yet since even after changing the

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131628265 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -386,6 +387,19 @@ private void

[GitHub] flink issue #4484: [FLINK-7376][Client] Cleanup options class and test class...

2017-08-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4484 Hi @yew1eb, I'm afraid we should not merge this PR. While I do realise that keeping the code clean is good, I don't think we should just change some parts of the code only to make them look

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131629516 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131629357 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131629581 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

2017-08-07 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131629322 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-5203) YARNHighAvailabilityITCase fails to deploy YARN cluster

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5203: --- Labels: test-stability (was: ) > YARNHighAvailabilityITCase fails to deploy YARN cluster >

[jira] [Updated] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5202: --- Labels: test-stability (was: ) > test timeout (no output for 300s) in YARNHighAvailabilityITCase >

[jira] [Created] (FLINK-7380) Limit usage of Row type

2017-08-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7380: --- Summary: Limit usage of Row type Key: FLINK-7380 URL: https://issues.apache.org/jira/browse/FLINK-7380 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-7379) Remove `HighAvailabilityServices` from QS client constructor.

2017-08-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7379: -- Summary: Remove `HighAvailabilityServices` from QS client constructor. (was: Remove

[jira] [Updated] (FLINK-6645) JobMasterTest failed on Travis

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6645: --- Labels: test-stability (was: ) > JobMasterTest failed on Travis > -- > >

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6997: --- Affects Version/s: 1.3.0 > SavepointITCase fails in master branch sometimes >

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6997: --- Labels: test-stability (was: ) > SavepointITCase fails in master branch sometimes >

[jira] [Commented] (FLINK-7375) Remove ActorGateway from JobClient

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

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116508#comment-16116508 ] Nico Kruber commented on FLINK-6997: For a real-world scenario, I would say if not all tasks were

[GitHub] flink pull request #4486: [FLINK-7375] Replace ActorGateway with JobManagerG...

2017-08-07 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4486 [FLINK-7375] Replace ActorGateway with JobManagerGateway in JobClient ## What is the purpose of the change In order to make the JobClient code independent of Akka, this PR replaces

[GitHub] flink pull request #4487: [FLINK-7379] [qs] Remove HighAvailabilityServices ...

2017-08-07 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/4487 [FLINK-7379] [qs] Remove HighAvailabilityServices from QS client constructor. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink

[jira] [Created] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2017-08-07 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7382: --- Summary: Broken links in `Apache Flink Documentation` page Key: FLINK-7382 URL: https://issues.apache.org/jira/browse/FLINK-7382 Project: Flink Issue Type:

[jira] [Created] (FLINK-7383) Remove ConfigurationUtil

2017-08-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7383: Summary: Remove ConfigurationUtil Key: FLINK-7383 URL: https://issues.apache.org/jira/browse/FLINK-7383 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7354) test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers

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

[jira] [Updated] (FLINK-5411) LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5411: --- Component/s: ResourceManager > LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis >

[GitHub] flink pull request #4464: [FLINK-7354][tests] ignore "initialSeedUniquifierG...

2017-08-07 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4464#discussion_r131633276 --- Diff: flink-tests/src/test/java/org/apache/flink/test/runtime/minicluster/LocalFlinkMiniClusterITCase.java --- @@ -49,7 +49,7 @@ */ public

[jira] [Updated] (FLINK-5411) LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5411: --- Labels: test-stability (was: ) > LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis >

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

2017-08-07 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131634081 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala --- @@ -0,0 +1,95 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

2017-08-07 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131633926 --- Diff: docs/dev/table/sql.md --- @@ -497,6 +497,23 @@ FROM ( {% endhighlight %} + + + +In

[jira] [Commented] (FLINK-7376) Cleanup options class and test classes in flink-clients

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116495#comment-16116495 ] ASF GitHub Bot commented on FLINK-7376: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4484: [FLINK-7376][Client] Cleanup options class and test class...

2017-08-07 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4484 Thank you for your reply.@aljoscha I am sorry for my first PR. I think I need to read this [Contributing Code](http://flink.apache.org/contribute-code.html). --- If your project is set up for

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116501#comment-16116501 ] ASF GitHub Bot commented on FLINK-6442: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

2017-08-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3829 Hi @lincoln-lil, I think we can continue with this PR. Nobody raised concerns on the dev ML. Thank you, Fabian --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-7379) Remove `HighAvailabilityServices` from QS client constructor.

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116516#comment-16116516 ] ASF GitHub Bot commented on FLINK-7379: --- GitHub user kl0u opened a pull request:

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116515#comment-16116515 ] Nico Kruber commented on FLINK-2032: Hi [~heytitle], it would be great if you can work on this and

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116520#comment-16116520 ] ASF GitHub Bot commented on FLINK-7337: --- GitHub user fhueske opened a pull request:

[jira] [Updated] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-4295: --- Summary: CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run (was:

[jira] [Updated] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-4295: --- Description: When running the test you always get an exception; {code} 08/01/2016 15:03:34 Job

[GitHub] flink pull request #4489: [FLINK-7383] Remove ConfigurationUtil

2017-08-07 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4489 [FLINK-7383] Remove ConfigurationUtil ## What is the purpose of the change Remove `ConfigurationUtil` since it is no longer used. ## Verifying this change This change

[GitHub] flink pull request #4485: [FLINK-7378][core]Implement the FixedBufferPool fo...

2017-08-07 Thread zhijiangW
GitHub user zhijiangW opened a pull request: https://github.com/apache/flink/pull/4485 [FLINK-7378][core]Implement the FixedBufferPool for floating buffers of SingleInputGate ## What is the purpose of the change Currently the number of network buffers in `LocalBufferPool`

[jira] [Updated] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5286: --- Labels: test-stability (was: ) > Build instability: WordCountSubclassPOJOITCase fails with

[jira] [Updated] (FLINK-5100) Test testZooKeeperReelection is instable

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5100: --- Labels: test-stability (was: ) > Test testZooKeeperReelection is instable >

[jira] [Updated] (FLINK-5204) Flakey YARNSessionCapacitySchedulerITCase (NullPointerException)

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5204: --- Labels: test-stability (was: ) > Flakey YARNSessionCapacitySchedulerITCase (NullPointerException) >

[jira] [Updated] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space)

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5212: --- Labels: test-stability (was: ) > Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java

[jira] [Updated] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space)

2017-08-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5212: --- Component/s: Tests > Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space) >

[jira] [Assigned] (FLINK-5604) Replace QueryableStateClient constructor

2017-08-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-5604: - Assignee: Kostas Kloudas > Replace QueryableStateClient constructor >

[jira] [Updated] (FLINK-5604) Replace QueryableStateClient constructor

2017-08-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5604: -- Fix Version/s: 1.4.0 > Replace QueryableStateClient constructor >

[jira] [Updated] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-08-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5509: -- Fix Version/s: 1.4.0 > Replace QueryableStateClient keyHashCode argument >

[GitHub] flink issue #4457: [hotfix] [gelly] Explicit type can be replaced with <>

2017-08-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4457 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

[jira] [Closed] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-08-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5509. - Resolution: Fixed > Replace QueryableStateClient keyHashCode argument >

[jira] [Commented] (FLINK-6982) Replace guava dependencies

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

[GitHub] flink issue #4421: [FLINK-7298] [table] Records can be cleared all at once w...

2017-08-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4421 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

[jira] [Commented] (FLINK-7298) Records can be cleared when all data in state is invalid

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116633#comment-16116633 ] ASF GitHub Bot commented on FLINK-7298: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7221) JDBCOutputFormat swallows errors on last batch

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116634#comment-16116634 ] ASF GitHub Bot commented on FLINK-7221: --- Github user fhueske commented on the issue:

<    1   2   3   4   >