[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929489#comment-15929489
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3386
@hongyuhong , IMO, all the function should have detail doc
---
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
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929476#comment-15929476
]
Yuhong Hong commented on FLINK-5725:
In this issue, i mostly want to support join like
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4354:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring heartbea
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring heartbea
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
It is part of work for FLIP-6.
The {{HeartbeatManager}} is mainly used for monitoring heartbea
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4354:
Summary: Implement heartbeat logic between TaskManager and ResourceManager
(was: Implement TaskManager si
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
The {{HeartbeatManager}} is mainly used for monitoring heartbeat target and
reporting payloads
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Description:
The {{HeartbeatManager}} is mainly used for monitoring heartbeat target and
reporting payloads
[
https://issues.apache.org/jira/browse/FLINK-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-6047:
-
Description:
[Design doc]:
https://docs.google.com/document/d/18XlGPcfsGbnPSApRipJDLPg5IFNGTQjnz7e
Shaoxuan Wang created FLINK-6094:
Summary: Implement and turn on retraction for stream-stream inner
join
Key: FLINK-6094
URL: https://issues.apache.org/jira/browse/FLINK-6094
Project: Flink
Shaoxuan Wang created FLINK-6093:
Summary: Implement and turn on retraction for table sink
Key: FLINK-6093
URL: https://issues.apache.org/jira/browse/FLINK-6093
Project: Flink
Issue Type: Su
Shaoxuan Wang created FLINK-6092:
Summary: Implement and turn on retraction for table source
Key: FLINK-6092
URL: https://issues.apache.org/jira/browse/FLINK-6092
Project: Flink
Issue Type:
Shaoxuan Wang created FLINK-6091:
Summary: Implement and turn on the retraction for grouping window
aggregate
Key: FLINK-6091
URL: https://issues.apache.org/jira/browse/FLINK-6091
Project: Flink
Shaoxuan Wang created FLINK-6090:
Summary: Implement optimizer for retraction and turn on retraction
for over window aggregate
Key: FLINK-6090
URL: https://issues.apache.org/jira/browse/FLINK-6090
Pro
Shaoxuan Wang created FLINK-6089:
Summary: Implement decoration phase for rewriting predicated
logical plan after volcano optimization phase
Key: FLINK-6089
URL: https://issues.apache.org/jira/browse/FLINK-6089
Github user hongyuhong commented on the issue:
https://github.com/apache/flink/pull/3386
Hi @fhueske @sunjincheng121 @rtudoran @shijinkui , i have update the pr,
hope you can take a look. Thanks advance.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929376#comment-15929376
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user hongyuhong commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
Summary: Implement heartbeat logic between TaskManager and JobManager
(was: Implement TaskManager side of h
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5860:
-
Labels: starter (was: )
> Replace all the file creating from java.io.tmpdir with TemporaryFolder
> --
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929365#comment-15929365
]
shijinkui commented on FLINK-5754:
--
[~greghogan] I had checkout a branch from tag 1.2 in
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929345#comment-15929345
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user shijinkui commented on a diff i
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106411203
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala
---
@@ -0,0 +1,138 @@
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929314#comment-15929314
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3520
Hi @fhueske, thanks for the review. I addressed all your comments and will
rebase to master to let travis check. Will merge this after build success.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929298#comment-15929298
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106568641
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/TableSourceTest.scala
---
@@ -0,0 +1,382 @@
+/*
+ * Licensed to the Ap
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3503
HI,guys, Welcome anyone to review this PR.
@StephanEwen Can you continue review this PR.
Bestï¼
SunJIncheng
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929290#comment-15929290
]
ASF GitHub Bot commented on FLINK-5995:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929280#comment-15929280
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106566787
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/util/RexProgramTestBase.scala
---
@@ -16,106 +16,96 @@
* limitation
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929276#comment-15929276
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929277#comment-15929277
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106566599
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/util/RexProgramExtractorTest.scala
---
@@ -0,0 +1,347 @@
+/*
+ *
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106566606
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/util/RexProgramExtractorTest.scala
---
@@ -0,0 +1,347 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6074:
---
Component/s: Table API & SQL
DataStream API
> Fix processFunction with watermark not
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929268#comment-15929268
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106566112
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/BoundedProcessingOverWindowFunction.scala
---
@@ -0,0 +
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929267#comment-15929267
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106566042
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TestFilterableTableSource.scala
---
@@ -0,0 +1,142 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929261#comment-15929261
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929262#comment-15929262
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106565668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/PushFilterIntoTableSourceScanRuleBase.scala
---
@@ -36,36 +4
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3520#discussion_r106565688
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FilterableTableSource.scala
---
@@ -20,47 +20,40 @@ package org.apache
prabhat kumar created FLINK-6088:
Summary: java.lang.NoSuchFieldError: INSTANCE Issue with
classloading
Key: FLINK-6088
URL: https://issues.apache.org/jira/browse/FLINK-6088
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-6087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yassine Marzougui updated FLINK-6087:
-
Component/s: filesystem-connector
> The file-filter is only applied to directories in
> C
[
https://issues.apache.org/jira/browse/FLINK-6087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929134#comment-15929134
]
ASF GitHub Bot commented on FLINK-6087:
---
GitHub user ymarzougui opened a pull reques
GitHub user ymarzougui opened a pull request:
https://github.com/apache/flink/pull/3557
[FLINK-6087] Fix file-path filtering in ContinuousFileMonitoringFunction
The Files Filter is only applied to directories, so there is no way to
filter individual files. This fixes it.
You can me
Yassine Marzougui created FLINK-6087:
Summary: The file-filter is only applied to directories in
ContinuousFileMonitoringFunction
Key: FLINK-6087
URL: https://issues.apache.org/jira/browse/FLINK-6087
Chesnay Schepler created FLINK-6086:
---
Summary: Rework PythonSender/-Streamer generics
Key: FLINK-6086
URL: https://issues.apache.org/jira/browse/FLINK-6086
Project: Flink
Issue Type: Improv
Github user EronWright commented on the pull request:
https://github.com/apache/flink/commit/e2f01b81e801a5ae6610d06fb9e2e3f54bbf34d9#commitcomment-21361837
In
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java:
In
flink-mesos/src
Github user EronWright commented on the pull request:
https://github.com/apache/flink/commit/601a94802ceb81eb17aa6977eb7a35baef929c02#commitcomment-21361863
In
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java:
In
flink-core/src/main/java/org/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928990#comment-15928990
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3547
One more thing. The PR includes a merge commit which makes squashing the
commits and merging the PR a lot more difficult (see also the [contribution
guidelines](http://flink.apache.org/contribute-cod
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106519205
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -130,32 +142,76 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106519460
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -130,32 +142,77 @@ cl
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928975#comment-15928975
]
Haohui Mai commented on FLINK-5570:
---
Thanks for the ping, [~fhueske]. Please allow me fo
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928973#comment-15928973
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2460
Thanks for the reminder @shijinkui!
I'll put this one on my list for next week.
Thanks, Fabian
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928967#comment-15928967
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928969#comment-15928969
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928964#comment-15928964
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928958#comment-15928958
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928959#comment-15928959
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928963#comment-15928963
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928956#comment-15928956
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928965#comment-15928965
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928957#comment-15928957
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928961#comment-15928961
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928968#comment-15928968
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928966#comment-15928966
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928960#comment-15928960
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928955#comment-15928955
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928962#comment-15928962
]
ASF GitHub Bot commented on FLINK-5653:
---
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/3547#discussion_r106525346
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106517060
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106523715
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106534604
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/ProcTimeRowBoundedAggregationTest.scala
---
@@ -0,0 +1,311
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106516596
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -17,35 +17,62 @@
*/
pack
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106520755
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106517628
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -130,32 +142,77 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106532760
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/ProcTimeRowBoundedAggregationTest.scala
---
@@ -0,0 +1,311
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106528174
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/BoundedProcessingOverAllWindowFunction.scala
---
@@ -0,0 +1,97
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106526547
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106513895
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -17,34 +17,41 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106517261
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +116,58 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3547#discussion_r106538072
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -106,9 +113,14 @@ cla
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3534
@aljoscha Can you share
https://github.com/aljoscha/flink/tree/jira-6018-state-init-fixups with
@tzulitai who is looking into serializer upgrade paths?
---
If your project is set up for it, you
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3534
This change is probably uncritical:
- It seems this code path was never executed (by chance) because the
`RuntimeContext` pre-initializes state descriptors, and all the operators
directly s
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3478
This change currently fails all CI build. The main reason is assuming that
checkpointing is always active.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928777#comment-15928777
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928775#comment-15928775
]
ASF GitHub Bot commented on FLINK-6018:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928756#comment-15928756
]
ASF GitHub Bot commented on FLINK-5810:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3394
I have some suggested edits on top of this (not strictly tied to the
changes here) in that commit:
https://github.com/StephanEwen/incubator-flink/commit/910de21972992d0ed80f232f3a64bf107c6819f2
[
https://issues.apache.org/jira/browse/FLINK-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928750#comment-15928750
]
ASF GitHub Bot commented on FLINK-5810:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3394#discussion_r106507099
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -21,519 +21,897 @@
import org.ap
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3394#discussion_r106514810
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -21,519 +21,897 @@
import org.ap
[
https://issues.apache.org/jira/browse/FLINK-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928751#comment-15928751
]
ASF GitHub Bot commented on FLINK-5810:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928748#comment-15928748
]
ASF GitHub Bot commented on FLINK-5810:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3394#discussion_r106515494
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -21,519 +21,897 @@
import org.ap
1 - 100 of 410 matches
Mail list logo
