[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148496#comment-16148496
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4574
@ggevay @greghogan Thank you for your suggestions, I tried to add some
notice about performance loss in the log, what do you think? Thanks
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7393:
Fix Version/s: (was: 1.3.3)
> Refactor FlinkKinesisConsumerTest
> -
>
>
Hai Zhou created FLINK-7562:
---
Summary: uploaded jars sort by upload-time on dashboard page
Key: FLINK-7562
URL: https://issues.apache.org/jira/browse/FLINK-7562
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148293#comment-16148293
]
ASF GitHub Bot commented on FLINK-7558:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4620
---
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 feature is enab
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Ertl updated FLINK-7430:
--
Priority: Critical (was: Major)
> ContinuousFileReaderOperator swallows exceptions
> --
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148230#comment-16148230
]
Peter Ertl edited comment on FLINK-7430 at 8/30/17 11:53 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148230#comment-16148230
]
Peter Ertl commented on FLINK-7430:
---
The current behavior can lead to the streaming task
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r136217663
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -36,10 +36,8 @@ import or
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148229#comment-16148229
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147947#comment-16147947
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
[KeyedProcessOperator](https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java)
would be one of those.
---
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147922#comment-16147922
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147936#comment-16147936
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147941#comment-16147941
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147927#comment-16147927
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147921#comment-16147921
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147929#comment-16147929
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147934#comment-16147934
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147933#comment-16147933
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147938#comment-16147938
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147924#comment-16147924
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147932#comment-16147932
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147920#comment-16147920
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147918#comment-16147918
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147939#comment-16147939
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147917#comment-16147917
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147913#comment-16147913
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147928#comment-16147928
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147937#comment-16147937
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147931#comment-16147931
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147925#comment-16147925
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147935#comment-16147935
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147930#comment-16147930
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147923#comment-16147923
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147926#comment-16147926
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147916#comment-16147916
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147919#comment-16147919
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147940#comment-16147940
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147914#comment-16147914
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147915#comment-16147915
]
ASF GitHub Bot commented on FLINK-6442:
---
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/3829#discussion_r136163965
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136125340
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -1002,4 +1124,28 @@ object TableEnvironment {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136118894
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136130122
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -19,9 +19,21 @@
package org.apache.flink.table
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136156910
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136154973
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136118574
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136156100
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136123743
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -1002,4 +1124,28 @@ object TableEnvironment {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136115720
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136158979
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136113499
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136116361
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136163943
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136110559
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -106,6 +106,43 @@ abstract class BatchTab
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136112180
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136163423
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136104550
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -106,6 +106,43 @@ abstract class BatchTab
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136109255
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -106,6 +106,43 @@ abstract class BatchTab
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136114635
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136117769
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136115991
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136124917
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSinkTable.scala
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed t
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136110776
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -132,6 +132,46 @@ abstract class StreamT
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136166359
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/MemoryTableSinkUtil.scala
---
@@ -0,0 +1,89 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136156414
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -800,6 +794,66 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136116568
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136114764
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,133 @@ abstract class TableEnviro
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136111695
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -417,6 +418,15 @@ abstract class TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147903#comment-16147903
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on the iss
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4331
@dawidwys Thanks for the reviews and comments, please change the
documentation during merge.
And @kl0u , thanks for the reviews!
---
If your project is set up for it, you can reply to this em
Github user yestinchen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r136169035
--- Diff: docs/dev/libs/cep.md ---
@@ -1250,6 +1250,104 @@ pattern.within(Time.seconds(10))
+### After Match Skip Strategy
+
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147900#comment-16147900
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147793#comment-16147793
]
ASF GitHub Bot commented on FLINK-7199:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4346
@NicoK I have fixed the noted issues and will merge.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147616#comment-16147616
]
ASF GitHub Bot commented on FLINK-7486:
---
GitHub user bbayani opened a pull request:
GitHub user bbayani opened a pull request:
https://github.com/apache/flink/pull/4628
[FLINK-7486]:[flink-mesos]:Support for adding unique attribute / grouâ¦
â¦p_by attribute constraints
JIRA issue: FLINK-7486
## What is the purpose of the change
- To be able to add
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li resolved FLINK-7524.
-
Resolution: Not A Bug
> Task "xxx" did not react to cancelling signal, but is stuck in method
> --
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147589#comment-16147589
]
ASF GitHub Bot commented on FLINK-7422:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4627
[FLINK-7422][kinesis] Upgrade Kinesis Client Library (KCL) and AWS SDK in
flink-connector-kinesis
## What is the purpose of the change
Upgrade KCL from 1.6.2 to 1.8.1
(https://mvnreposit
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147552#comment-16147552
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7422:
Summary: Upgrade Kinesis Client Library (KCL) and AWS SDK in
flink-connector-kinesis (was: Upgrade Kinesis
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
@aljoscha No worries. Dropping compatibility with Flink 1.2 Kinesis
consumer is great news! I reopened
(Flink-7422)[https://issues.apache.org/jira/browse/FLINK-7422] to upgrade KCL
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
We need to upgrade KPL and KCL to pick up the enhanced performance and
stability for Flink to
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7422:
Description:
Upgrade KCL from 1.6.2 to 1.8.1
(https://mvnrepository.com/artifact/com.amazonaws/amazon-kines
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7422:
Fix Version/s: (was: 1.3.3)
> Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reopened FLINK-7422:
-
> Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2 to
> 1.8.1
> ---
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147538#comment-16147538
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4574
I also agree that these messages have been personally useful. I think this
PR is an improvement but that we could do better to note and/or emphasize the
performance implications of `GenericType`. I
[
https://issues.apache.org/jira/browse/FLINK-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147491#comment-16147491
]
ASF GitHub Bot commented on FLINK-7561:
---
GitHub user pnowojski opened a pull request
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4626
[FLINK-7561][streaming] Implement PreAggregationOperator
## What is the purpose of the change
To improve performance in certain situations this PR adds basic
implementation of pre-aggrega
[
https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-7547:
---
Assignee: Hai Zhou
> o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable
> ---
Piotr Nowojski created FLINK-7561:
-
Summary: Add support for pre-aggregation in DataStream API
Key: FLINK-7561
URL: https://issues.apache.org/jira/browse/FLINK-7561
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147470#comment-16147470
]
ASF GitHub Bot commented on FLINK-6233:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/4625
[FLINK-6233] [table] Support time-bounded stream inner join in the SQL API
## What is the purpose of the change
This PR aims add an implementation of the time-bounded stream inner join
for bo
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147389#comment-16147389
]
ASF GitHub Bot commented on FLINK-7410:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/4624
[FLINK-7410] [table] Use toString method to display operator names for
UserDefinedFunction
## What is the purpose of the change
*Use toString method to display operator names for Use
[
https://issues.apache.org/jira/browse/FLINK-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7556.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: e753db8411debfc573ffc330355a0f24c0afbfb5
>
1 - 100 of 196 matches
Mail list logo
