Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/5915
The points is already `rebalance()` in line 131, so it is no need to
`rebalance()` again in line 137?
---
[
https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453569#comment-16453569
]
ASF GitHub Bot commented on FLINK-9243:
---
Github user zhijiangW commented on the issu
Sihua Zhou created FLINK-9260:
-
Summary: Introduce a friendly way to resume the job from
externalized checkpoints automatically
Key: FLINK-9260
URL: https://issues.apache.org/jira/browse/FLINK-9260
Projec
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453430#comment-16453430
]
Bob Lau edited comment on FLINK-9259 at 4/26/18 5:28 AM:
-
[~mingle
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453430#comment-16453430
]
Bob Lau edited comment on FLINK-9259 at 4/26/18 4:39 AM:
-
[~mingle
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453430#comment-16453430
]
Bob Lau commented on FLINK-9259:
[~mingleizhang] I wont use parameter like inputStream ( g
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453414#comment-16453414
]
Bob Lau commented on FLINK-9259:
TableSource with RowTypeInfo, and I wont transform the Da
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453402#comment-16453402
]
yuqi commented on FLINK-9259:
-
More detail are needed, you can paste more about your code [~bo
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453397#comment-16453397
]
ASF GitHub Bot commented on FLINK-9008:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5823
Hi, @zentol I have updated the code and the patch is available to have
another review now.
---
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453379#comment-16453379
]
mingleizhang commented on FLINK-9259:
-
I would not think it is a bug since {{SourceFun
[
https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9259:
Description:
The exception stack is as follows:
{code:java}
//Code placeholder
org.apache.flink.api.
Bob Lau created FLINK-9259:
--
Summary: The implementation of the SourceFunction is not
serializable.
Key: FLINK-9259
URL: https://issues.apache.org/jira/browse/FLINK-9259
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453192#comment-16453192
]
ASF GitHub Bot commented on FLINK-9188:
---
Github user tweise commented on a diff in t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5889#discussion_r184224413
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java
---
@@ -86,4 +86,1
[
https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453174#comment-16453174
]
ASF GitHub Bot commented on FLINK-9188:
---
Github user tweise commented on a diff in t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5889#discussion_r184220854
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -186,7 +186,10
[
https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453164#comment-16453164
]
ASF GitHub Bot commented on FLINK-9188:
---
Github user tweise commented on a diff in t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/flink/pull/5889#discussion_r184218974
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -186,7 +186,10
[
https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453152#comment-16453152
]
ASF GitHub Bot commented on FLINK-9243:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5915
---
[
https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9243.
---
Resolution: Fixed
master: 0113ee2b33e3f86bb6a3de2ecf60d8e7bf554be2
1.5: 687278d791a10b7b8e3eed
[
https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453146#comment-16453146
]
ASF GitHub Bot commented on FLINK-9243:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5915
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453099#comment-16453099
]
ASF GitHub Bot commented on FLINK-8841:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5910
+1
---
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453095#comment-16453095
]
Chesnay Schepler commented on FLINK-9258:
-
This should only be possible if {{getAl
[
https://issues.apache.org/jira/browse/FLINK-9249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453089#comment-16453089
]
ASF GitHub Bot commented on FLINK-9249:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9258:
Fix Version/s: 1.4.3
1.5.0
> ConcurrentModificationException in Component
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9258:
---
Assignee: Chesnay Schepler
> ConcurrentModificationException in ComponentMetricGroup.
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5904
+1
---
Narayanan Arunachalam created FLINK-9258:
Summary: ConcurrentModificationException in
ComponentMetricGroup.getAllVariables
Key: FLINK-9258
URL: https://issues.apache.org/jira/browse/FLINK-9258
[
https://issues.apache.org/jira/browse/FLINK-9243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452840#comment-16452840
]
ASF GitHub Bot commented on FLINK-9243:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5915
[FLINK-9243][tests] fix flaky SuccessAfterNetworkBuffersFailureITCase
this adds some `rebalance()` operations into
`SuccessAfterNetworkBuffersFailureITCase#runKMeans` which should be set up to
fail a
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452681#comment-16452681
]
Chesnay Schepler commented on FLINK-8135:
-
[~Poluliakh] should work now.
> Add de
[
https://issues.apache.org/jira/browse/FLINK-9256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452597#comment-16452597
]
ASF GitHub Bot commented on FLINK-9256:
---
GitHub user NicoK opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452600#comment-16452600
]
Dmitrii Kober commented on FLINK-2435:
--
Excess changes are removed, please review.
>
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5914
[FLINK-9256][network] fix NPE in SingleInputGate#updateInputChannel() for
non-credit based flow control
## What is the purpose of the change
`SingleInputGate#updateInputChannel()` fails to up
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452590#comment-16452590
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452592#comment-16452592
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452591#comment-16452591
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user walterddr commented on a diff i
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184115873
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,36 @@ class Aggregat
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184125030
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala
---
@@ -0,0 +1,106 @@
+/*
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184115947
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,36 @@ class Aggregat
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452584#comment-16452584
]
Andrei commented on FLINK-8135:
---
[~Zentol] seems like I can't :(
> Add description to Messa
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8686:
Description:
This issue describes follow-up issues that should be fixes in order to make the
SQL cl
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8686:
Fix Version/s: (was: 1.5.0)
> Improve basic embedded SQL client
> -
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452520#comment-16452520
]
Timo Walther commented on FLINK-8686:
-
Parts of this issue have been fixed:
in 1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452521#comment-16452521
]
ASF GitHub Bot commented on FLINK-8686:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5867
---
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452492#comment-16452492
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184104126
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -185,36 +188,44 @@ public HeapKeyedStateB
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452457#comment-16452457
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184101616
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452455#comment-16452455
]
ASF GitHub Bot commented on FLINK-8686:
---
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/5867#discussion_r184099775
--- Diff: flink-dist/src/main/resources/flink-conf.yaml ---
@@ -229,17 +229,26 @@ web.port: 8081
# Directory to upload completed jobs to. Add this
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452453#comment-16452453
]
ASF GitHub Bot commented on FLINK-8686:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5867
Thank you for the feedback. I will merge the first 5 commits and will open
a new PR for an additional configuration file.
---
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452451#comment-16452451
]
ASF GitHub Bot commented on FLINK-9138:
---
Github user glaksh100 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452449#comment-16452449
]
ASF GitHub Bot commented on FLINK-8686:
---
Github user twalthr commented on a diff in
Github user glaksh100 commented on the issue:
https://github.com/apache/flink/pull/5860
@fhueske Thank you for reviewing. I have incorporated the changes that
include update to the
[documentation](https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/filesystem_sink.ht
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5867#discussion_r184098778
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -91,6 +92,22 @@ public Deployment getD
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452444#comment-16452444
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452445#comment-16452445
]
ASF GitHub Bot commented on FLINK-8686:
---
Github user twalthr commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184098081
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -185,36 +188,44 @@ public HeapKeyedStateB
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5867#discussion_r184098177
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -91,6 +92,22 @@ public Deployment getD
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452430#comment-16452430
]
ASF GitHub Bot commented on FLINK-8686:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5867#discussion_r184096235
--- Diff: flink-dist/src/main/resources/flink-conf.yaml ---
@@ -229,17 +229,26 @@ web.port: 8081
# Directory to upload completed jobs to. Add this
[
https://issues.apache.org/jira/browse/FLINK-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452424#comment-16452424
]
Timo Walther commented on FLINK-9229:
-
Fixed in 1.4.3: 963f14e266e5347d98388552014c2be
[
https://issues.apache.org/jira/browse/FLINK-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-9229:
Fix Version/s: 1.4.3
> Fix literal handling in code generation
> ---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184041497
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -207,112 +241,164 @@ class Aggrega
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452418#comment-16452418
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452421#comment-16452421
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452419#comment-16452419
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452415#comment-16452415
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184041109
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -207,112 +241,164 @@ class Aggrega
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452412#comment-16452412
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452413#comment-16452413
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452417#comment-16452417
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184040988
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -207,112 +241,164 @@ class Aggrega
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452409#comment-16452409
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452420#comment-16452420
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452408#comment-16452408
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184040192
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala
---
@@ -0,0 +1,106 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184041605
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -207,112 +241,164 @@ class Aggrega
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184093390
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java
---
@@ -103,17 +104,17 @@ public void add(T value) th
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452416#comment-16452416
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184036382
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,36 @@ class Aggregatio
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184075230
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -481,14 +622,34 @@ class Aggregati
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452414#comment-16452414
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184048806
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -417,13 +548,23 @@ class Aggregati
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452411#comment-16452411
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16452410#comment-16452410
]
ASF GitHub Bot commented on FLINK-8689:
---
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/#discussion_r184036079
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,36 @@ class Aggregatio
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184037303
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,36 @@ class Aggregatio
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184092223
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/OverWindowITCase.scala
---
@@ -50,6 +50,155 @@ class OverWind
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184085613
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala
---
@@ -0,0 +1,106 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r184039407
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -207,112 +241,164 @@ class Aggrega
Florian Schmidt created FLINK-9257:
--
Summary: End-to-end tests prints "All tests PASS" even if
individual test-script returns non-zero exit code
Key: FLINK-9257
URL: https://issues.apache.org/jira/browse/FLINK-92
[
https://issues.apache.org/jira/browse/FLINK-9229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9229.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.6.0: 063aeb17d273554949632338d788597617ad
1 - 100 of 314 matches
Mail list logo
