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

2018-01-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-8428: --- Description: Implement stream-stream non-window left outer join for sql/table-api. A simple design

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

2018-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333405#comment-16333405 ] ASF GitHub Bot commented on FLINK-8428: --- GitHub user hequn8128 opened a pull request:

[GitHub] flink pull request #5327: [FLINK-8428] [table] Implement stream-stream non-w...

2018-01-20 Thread hequn8128
GitHub user hequn8128 opened a pull request: https://github.com/apache/flink/pull/5327 [FLINK-8428] [table] Implement stream-stream non-window left outer join ## What is the purpose of the change Implement stream-stream non-window left outer join for sql/table-api. A

[jira] [Commented] (FLINK-8365) Relax List type in HeapListState and HeapKeyedStateBackend

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

[GitHub] flink pull request #5326: [FLINK-8365] [State Backend] Relax List type in He...

2018-01-20 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5326 [FLINK-8365] [State Backend] Relax List type in HeapListState and HeapKeyedStateBackend ## What is the purpose of the change `stateTable` in `HeapListState` and

[jira] [Updated] (FLINK-8365) Relax List type in HeapListState and HeapKeyedStateBackend

2018-01-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8365: Summary: Relax List type in HeapListState and HeapKeyedStateBackend (was: Consider relax List type in

[jira] [Updated] (FLINK-8365) Consider relax List type in HeapListState and HeapKeyedStateBackend

2018-01-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8365: Affects Version/s: (was: 1.4.0) 1.5.0 > Consider relax List type in

[jira] [Updated] (FLINK-8469) relocate and unify RocksDB option params in RocksDBPerformanceTest

2018-01-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8469: Summary: relocate and unify RocksDB option params in RocksDBPerformanceTest (was: unify RocksDB params in

[GitHub] flink pull request #5325: [FLINK-8469] [State Backend] [RocksDB] unify Rocks...

2018-01-20 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5325 [FLINK-8469] [State Backend] [RocksDB] unify RocksDB params in RocksDBPerformanceTest ## What is the purpose of the change two unit tests in RocksDBPerformanceTest share the same lots of

[jira] [Commented] (FLINK-8469) unify RocksDB params in RocksDBPerformanceTest

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

[jira] [Updated] (FLINK-8469) unify RocksDB params in RocksDBPerformanceTest

2018-01-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8469: Affects Version/s: 1.4.0 > unify RocksDB params in RocksDBPerformanceTest >

[jira] [Created] (FLINK-8469) unify RocksDB params in RocksDBPerformanceTest

2018-01-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8469: --- Summary: unify RocksDB params in RocksDBPerformanceTest Key: FLINK-8469 URL: https://issues.apache.org/jira/browse/FLINK-8469 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-8469) unify RocksDB params in RocksDBPerformanceTest

2018-01-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8469: Fix Version/s: 1.5.0 Component/s: State Backends, Checkpointing > unify RocksDB params in

[jira] [Commented] (FLINK-8325) Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

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

[GitHub] flink issue #5241: [FLINK-8325][table] Add COUNT(*),COUNT(1) supported

2018-01-20 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5241 Thanks for the update and rebasing @sunjincheng121. The PR looks good. Will run final tests and merge it. Best, Fabian ---

[jira] [Commented] (FLINK-6926) Add support for MD5, SHA1 and SHA2

2018-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1638#comment-1638 ] ASF GitHub Bot commented on FLINK-6926: --- GitHub user genged opened a pull request:

[GitHub] flink pull request #5324: [FLINK-6926] [table] Add support for SHA-224, SHA-...

2018-01-20 Thread genged
GitHub user genged opened a pull request: https://github.com/apache/flink/pull/5324 [FLINK-6926] [table] Add support for SHA-224, SHA-384, SHA-512 ## What is the purpose of the change This pull request implements SHA224, SHA384, SHA512 support in Flink SQL as discussed in

[jira] [Created] (FLINK-8468) Allow the sink to be extended

2018-01-20 Thread Ph.Duveau (JIRA)
Ph.Duveau created FLINK-8468: Summary: Allow the sink to be extended Key: FLINK-8468 URL: https://issues.apache.org/jira/browse/FLINK-8468 Project: Flink Issue Type: Improvement

[GitHub] flink issue #5241: [FLINK-8325][table] Add COUNT(*),COUNT(1) supported

2018-01-20 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/5241 Thanks @fhueske, I had rebase the code. I appreciate if you can review the changes. Best, Jincheng ---

[jira] [Commented] (FLINK-8325) Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

2018-01-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333199#comment-16333199 ] ASF GitHub Bot commented on FLINK-8325: --- Github user sunjincheng121 commented on the issue:

[jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps

2018-01-20 Thread Dyana Rose (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333190#comment-16333190 ] Dyana Rose commented on FLINK-8384: --- I rebased on top of master and pushed. The build's green now >

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArchivist holds on to any number of ArchivedExecutionGraph's. These

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArchivist holds on to any number of ArchivedExecutionGraph's. These

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArchivist holds on to any number of ArchivedExecutionGraph's. These

[jira] [Updated] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8467: -- Description: When checkpointing is disabled, the Flink Kafka Consumer relies on the periodic

[jira] [Updated] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8467: -- Description: When checkpointing is disabled, the Flink Kafka Consumer relies on the periodic

[jira] [Created] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-01-20 Thread Jelmer Kuperus (JIRA)
Jelmer Kuperus created FLINK-8467: - Summary: Restoring job that does not use checkpointing from savepoint breaks Key: FLINK-8467 URL: https://issues.apache.org/jira/browse/FLINK-8467 Project: Flink

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArchivist holds on to any number of ArchivedExecutionGraph's these

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArhivist holds on to any number of ArchivedExecutionGraph's these

[jira] [Updated] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jelmer Kuperus updated FLINK-8466: -- Description: MemoryArhivist holds on to any number of ArchivedExecutionGraph's these

[jira] [Created] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected

2018-01-20 Thread Jelmer Kuperus (JIRA)
Jelmer Kuperus created FLINK-8466: - Summary: MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected Key: FLINK-8466 URL:

[GitHub] flink pull request #5119: [FLINK-6590] Integrate automatic docs generation

2018-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5119 ---