[
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=16148293#comment-16148293
]
ASF GitHub Bot commented on FLINK-7558:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-7430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148230#comment-16148230
]
Peter Ertl edited comment on FLINK-7430 at 8/30/17 11:53 PM:
-
The current
[
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=16148230#comment-16148230
]
Peter Ertl commented on FLINK-7430:
---
The current behavior can lead to the streaming task terminating
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
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148229#comment-16148229
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16147941#comment-16147941
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147922#comment-16147922
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147936#comment-16147936
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147934#comment-16147934
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147933#comment-16147933
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147927#comment-16147927
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147921#comment-16147921
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147929#comment-16147929
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147932#comment-16147932
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147938#comment-16147938
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147924#comment-16147924
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147920#comment-16147920
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147918#comment-16147918
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147939#comment-16147939
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147913#comment-16147913
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147917#comment-16147917
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147928#comment-16147928
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147937#comment-16147937
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147931#comment-16147931
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147925#comment-16147925
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147935#comment-16147935
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147930#comment-16147930
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147923#comment-16147923
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147926#comment-16147926
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147916#comment-16147916
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147919#comment-16147919
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147940#comment-16147940
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147914#comment-16147914
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147915#comment-16147915
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in the pull
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
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
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
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
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
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
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_r136104550
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -106,6 +106,43 @@ abstract class
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
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
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
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
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
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
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_r136124917
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSinkTable.scala
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed
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
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147903#comment-16147903
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on the issue:
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
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=16147900#comment-16147900
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147793#comment-16147793
]
ASF GitHub Bot commented on FLINK-7199:
---
Github user greghogan commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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=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://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147552#comment-16147552
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issue:
[
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
[
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://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
[
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=16147538#comment-16147538
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user greghogan commented on the issue:
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`.
[
https://issues.apache.org/jira/browse/FLINK-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
https://issues.apache.org/jira/browse/FLINK-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-7556:
---
Assignee: Nycholas de Oliveira e Oliveira
> Fix fetch size configurable in
[
https://issues.apache.org/jira/browse/FLINK-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147366#comment-16147366
]
ASF GitHub Bot commented on FLINK-7556:
---
Github user asfgit closed the pull request at:
1 - 100 of 199 matches
Mail list logo
