[
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
[
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 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
[
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 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
[
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
[
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
[
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 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
[
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:
[
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
>
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
[
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
[
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 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
---
[
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 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
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 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
---
[
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:
[
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
>
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
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 user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5119
---
32 matches
Mail list logo