[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Thanks for checking this out. Merging to 1.5 and 1.6 then... ---

[jira] [Created] (FLINK-8952) Support setting the parallelism of individual operators of a query

2018-03-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8952: Summary: Support setting the parallelism of individual operators of a query Key: FLINK-8952 URL: https://issues.apache.org/jira/browse/FLINK-8952 Project: Flink

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

2018-03-15 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400215#comment-16400215 ] Truong Duc Kien commented on FLINK-8297: Isn't this also related to 

[jira] [Created] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

2018-03-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8951: Summary: Support OVER windows PARTITION BY (rounded) timestamp Key: FLINK-8951 URL: https://issues.apache.org/jira/browse/FLINK-8951 Project: Flink Issue

[jira] [Created] (FLINK-8950) "Materialize" Tables to avoid recomputation.

2018-03-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8950: Summary: "Materialize" Tables to avoid recomputation. Key: FLINK-8950 URL: https://issues.apache.org/jira/browse/FLINK-8950 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400182#comment-16400182 ] Fernando Díaz commented on FLINK-6895: -- Taking a look at this [MySQL

[jira] [Closed] (FLINK-3497) Add SQL scalar functions to Table API

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3497. Resolution: Fixed Assignee: Timo Walther Closing. All sub issues have been resolved. > Add

[jira] [Closed] (FLINK-6238) support OVER on batch SQL

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6238. Resolution: Duplicate Duplicate of FLINK-6473 > support OVER on batch SQL >

[jira] [Closed] (FLINK-6979) Add documentation for Aggregation Functions in Tables/UDF doc

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6979. Resolution: Fixed Assignee: Shaoxuan Wang Fix Version/s: 1.4.0 Documentation was

[jira] [Assigned] (FLINK-6100) Add documentation for Projectable and Filterable TableSource

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6100: Assignee: Fabian Hueske > Add documentation for Projectable and Filterable TableSource >

[jira] [Closed] (FLINK-6100) Add documentation for Projectable and Filterable TableSource

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6100. Resolution: Fixed Fix Version/s: 1.4.0 > Add documentation for Projectable and Filterable

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400162#comment-16400162 ] ASF GitHub Bot commented on FLINK-8428: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

2018-03-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5327 Thanks @hequn8128! We're pretty busy with the Flink 1.5 release right now. This will be one of the first features to add once 1.5 is out! Best, Fabian ---

[jira] [Updated] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8562: - Priority: Blocker (was: Major) > Fix YARNSessionFIFOSecuredITCase >

[jira] [Updated] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8562: - Affects Version/s: 1.6.0 1.5.0 > Fix YARNSessionFIFOSecuredITCase >

[jira] [Created] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Truong Duc Kien (JIRA)
Truong Duc Kien created FLINK-8949: -- Summary: Rest API failure with long URL Key: FLINK-8949 URL: https://issues.apache.org/jira/browse/FLINK-8949 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400126#comment-16400126 ] vinoyang commented on FLINK-8946: - Hi [~till.rohrmann] , about this issue I think we could : init the

[jira] [Commented] (FLINK-8802) Concurrent serialization without duplicating serializers in state server.

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400115#comment-16400115 ] ASF GitHub Bot commented on FLINK-8802: --- Github user kl0u commented on the issue:

[GitHub] flink issue #5691: [FLINK-8802] [QS] Fix concurrent access to non-duplicated...

2018-03-15 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5691 This is ready for another review @StefanRRichter and @zentol ---

[jira] [Commented] (FLINK-6075) ORDER BY *time ASC

2018-03-15 Thread yinhua.dai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400095#comment-16400095 ] yinhua.dai commented on FLINK-6075: --- Thank you. > ORDER BY *time ASC > -- > >

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400080#comment-16400080 ] ASF GitHub Bot commented on FLINK-8915: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5703: [FLINK-8915] CheckpointingStatisticsHandler fails ...

2018-03-15 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5703 [FLINK-8915] CheckpointingStatisticsHandler fails to return PendingCheckpointStats ## What is the purpose of the change *This pull request fixed a issue : CheckpointingStatisticsHandler

[jira] [Created] (FLINK-8948) RescalingITCase fails on Travis

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8948: --- Summary: RescalingITCase fails on Travis Key: FLINK-8948 URL: https://issues.apache.org/jira/browse/FLINK-8948 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8947) Timeout handler issue

2018-03-15 Thread dhiraj prajapati (JIRA)
dhiraj prajapati created FLINK-8947: --- Summary: Timeout handler issue Key: FLINK-8947 URL: https://issues.apache.org/jira/browse/FLINK-8947 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6075) ORDER BY *time ASC

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400031#comment-16400031 ] Fabian Hueske commented on FLINK-6075: -- The missing {{RANK}} function is not the issue. You could do

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-03-15 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5660 I see, @twalthr. Sorry for my impatience. ---

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400030#comment-16400030 ] ASF GitHub Bot commented on FLINK-8861: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400010#comment-16400010 ] Chesnay Schepler commented on FLINK-8703: - Partially addressed in: master:

[jira] [Closed] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4569. --- Resolution: Fixed master: a04c8a08383e329213bd74c726f9834b7d19762d 1.5:

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Closed] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8904. --- Resolution: Fixed master: 80ee267386a3bc3c27c95a628255031953506128 1.5:

[GitHub] flink pull request #5668: [FLINK-8703][tests] Port StreamingScalabilityAndLa...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5668 ---

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5666: [FLINK-8703][tests] Port KafkaShortRetentionTestBa...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5666 ---

[jira] [Commented] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

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

[jira] [Commented] (FLINK-8916) Checkpointing Mode is always shown to be "At Least Once" in Web UI

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

[jira] [Commented] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

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

[GitHub] flink pull request #5689: [FLINK-4569][tests] Respect exceptions thrown in t...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5689 ---

[GitHub] flink pull request #5670: [FLINK-8904][cli][tests] always restore the previo...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5670 ---

[jira] [Updated] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8904: Affects Version/s: (was: 1.6.0) > Flink-client tests do not restore previous sysout

[GitHub] flink pull request #5667: [FLINK-8703][tests] Port NotSoMiniClusterIteration...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5667 ---

[GitHub] flink pull request #5677: [hotfix] [streaming API] update doc of InternalTim...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5677 ---

[jira] [Updated] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8904: Fix Version/s: (was: 1.6.0) > Flink-client tests do not restore previous sysout after

[GitHub] flink pull request #5679: [FLINK-8916] Checkpointing Mode is always shown to...

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5679 ---

[GitHub] flink pull request #5692: [docs] Fix typo in Python API docs

2018-03-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5692 ---

[jira] [Assigned] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8946: --- Assignee: vinoyang > TaskManager stop sending metrics after JobManager failover >

[jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1630#comment-1630 ] ASF GitHub Bot commented on FLINK-8861: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL...

2018-03-15 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5660 Hi @xccui, I will review this as soon as possible. Right now the priority is the Flink 1.5 release with FLIP-6 support. ---

[jira] [Commented] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

2018-03-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399988#comment-16399988 ] Timo Walther commented on FLINK-8852: - Hi [~liurenjie1024], I'm actively working on this right now:

[jira] [Commented] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399978#comment-16399978 ] ASF GitHub Bot commented on FLINK-8771: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #5702: [FLINK-8771] Upgrade scalastyle to 1.0.0

2018-03-15 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5702 [FLINK-8771] Upgrade scalastyle to 1.0.0 ## What is the purpose of the change Upgrade scalastyle from 0.8.0 to 1.0.0 ## Brief change log - Upgrade scalastyle from 0.8.0

<    1   2