[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159598#comment-16159598
]
ASF GitHub Bot commented on FLINK-6563:
---
Github user haohui commented on a diff in t
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4638#discussion_r137913506
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -106,8 +240,191
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159312#comment-16159312
]
Hai Zhou commented on FLINK-7608:
-
Hi [~rmetzger],
in org.apache.flink.streaming.api.opera
[
https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159307#comment-16159307
]
ASF GitHub Bot commented on FLINK-7609:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4662
[FLINK-7609][examples] WindowWordCount example doesn't print countWindow
output with default configs
## What is the purpose of the change
When running WindowWordCount example with no para
[
https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7609:
Description:
When running WindowWordCount example with no params (using default params), no
output is gener
[
https://issues.apache.org/jira/browse/FLINK-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7609:
Description:
When running WindowWordCount example with no params (using default params), no
output is print
Bowen Li created FLINK-7609:
---
Summary: WindowWordCount example doesn't print countWindow output
with default configs
Key: FLINK-7609
URL: https://issues.apache.org/jira/browse/FLINK-7609
Project: Flink
Hai Zhou created FLINK-7608:
---
Summary: LatencyGauge change to histogram metric
Key: FLINK-7608
URL: https://issues.apache.org/jira/browse/FLINK-7608
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-7608:
Description:
I used slf4jReporter[https://issues.apache.org/jira/browse/FLINK-4831] to
export metrics the
[
https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6838:
--
Description:
{code}
Tests in error:
RescalingITCase.testSavepointRescalingInKeyedState[1] ยป JobExecution Job
[
https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069086#comment-16069086
]
Ted Yu edited comment on FLINK-7049 at 9/8/17 7:19 PM:
---
Stack trace
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7402:
--
Description:
Here is the null check in finally block:
{code}
finally {
if (buffer != null) {
[
https://issues.apache.org/jira/browse/FLINK-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7432:
--
Description:
{code}
public QueryableStateClient(Configuration config) throws Exception {
this(config, High
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16159094#comment-16159094
]
ASF GitHub Bot commented on FLINK-4831:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4661
[FLINK-4831] Implement a slf4j metric reporter
## What is the purpose of the change
Implement a slf4j metric reporter For debugging.
## Brief change log
## Verifying this ch
Joshua Griffith created FLINK-7607:
--
Summary: Web Frontend Hangs with Large Numbers of Tasks
Key: FLINK-7607
URL: https://issues.apache.org/jira/browse/FLINK-7607
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158910#comment-16158910
]
Fabian Hueske commented on FLINK-7446:
--
Hi [~jark], did you start to work on this iss
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matteo Ferrario updated FLINK-7606:
---
Description:
The NestedMapsStateTable grows up continuously without free the heap memory.
We c
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matteo Ferrario updated FLINK-7606:
---
Description:
The NestedMapsStateTable grows up continuously without free the heap memory.
We c
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-2646:
-
Assignee: (was: Kostas Kloudas)
> Rich functions should provide a method "closeAfterF
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matteo Ferrario updated FLINK-7606:
---
Description:
The NestedMapsStateTable grows up continuously without free the heap memory.
We c
Matteo Ferrario created FLINK-7606:
--
Summary: Memory leak on NestedMapsStateTable
Key: FLINK-7606
URL: https://issues.apache.org/jira/browse/FLINK-7606
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158613#comment-16158613
]
ASF GitHub Bot commented on FLINK-7050:
---
GitHub user uybhatti opened a pull request:
GitHub user uybhatti opened a pull request:
https://github.com/apache/flink/pull/4660
[FLINK-7050][table] Add support of RFC compliant CSV parser for Table Source
## What is the purpose of the change
Currently CsvInputFormat is not compliant with RFC 4180 standards and we
c
[
https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flavio Pompermaier updated FLINK-7605:
--
Description:
Currently, if a connection is not created with autoCommit = true by default
[
https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flavio Pompermaier updated FLINK-7605:
--
Description:
Currently, if a connection is not created with autoCommit = true by default
[
https://issues.apache.org/jira/browse/FLINK-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flavio Pompermaier updated FLINK-7605:
--
Description:
Currently, if a connection is not created with autoCommit = true by default
Flavio Pompermaier created FLINK-7605:
-
Summary: JDBCOutputFormat autoCommit
Key: FLINK-7605
URL: https://issues.apache.org/jira/browse/FLINK-7605
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158421#comment-16158421
]
ASF GitHub Bot commented on FLINK-4047:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4659
[FLINK-4047] Fix documentation about determinism of KeySelectors
## What is the purpose of the change
This PR fixes the incorrect description for `KeySelectors`.
## Brief chang
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Summary: fix bug when Set Operation handles ANY type (was: Fix bug during
Set Operation (Union, Minus .
Hai Zhou created FLINK-7604:
---
Summary: Add OpenTSDB metrics reporter
Key: FLINK-7604
URL: https://issues.apache.org/jira/browse/FLINK-7604
Project: Flink
Issue Type: Bug
Components: Metri
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/4658#discussion_r137746521
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/type/SqlTypeFactoryImpl.java
---
@@ -0,0 +1,575 @@
+/*
+ * Licensed to the
Dian Fu created FLINK-7603:
--
Summary: Support within clause in MatchRecognize
Key: FLINK-7603
URL: https://issues.apache.org/jira/browse/FLINK-7603
Project: Flink
Issue Type: Sub-task
Re
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/4658
Flink 7596
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best possible way, please
Till Rohrmann created FLINK-7602:
Summary: Create sub tasks for porting the remaining rest handlers
Key: FLINK-7602
URL: https://issues.apache.org/jira/browse/FLINK-7602
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158303#comment-16158303
]
ASF GitHub Bot commented on FLINK-6563:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4638#discussion_r137737055
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -106,8 +240,191
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158295#comment-16158295
]
Mikhail Lipkovich commented on FLINK-5944:
--
[~aljoscha], [~Zentol] sorry if I'm b
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158285#comment-16158285
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user jameslafa commented on the issu
Github user jameslafa commented on the issue:
https://github.com/apache/flink/pull/4647
@zentol I pushed the changes we talk about yesterday. Let me know if it's
fine for you :)
Thanks for your help.
---
[
https://issues.apache.org/jira/browse/FLINK-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-7601:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support classifier in MatchRecognize
> -
Dian Fu created FLINK-7601:
--
Summary: Support classifier in MatchRecognize
Key: FLINK-7601
URL: https://issues.apache.org/jira/browse/FLINK-7601
Project: Flink
Issue Type: Bug
Components:
44 matches
Mail list logo
