Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4935
Hi @Aitozi, sorry for the long delay in relaying back to this PR.
I'm still not convinced that this is a sane solution. For example, what is
a "good" setting for the `KEY_REGISTER_TIMES`
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5017
Merging ...
---
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270326#comment-16270326
]
ASF GitHub Bot commented on FLINK-8076:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5075
Thanks! Merging this ..
---
[
https://issues.apache.org/jira/browse/FLINK-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270313#comment-16270313
]
ASF GitHub Bot commented on FLINK-8027:
---
Github user shuai-xu commented on a diff in the pull
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4985#discussion_r153708910
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7976.
---
Resolution: Duplicate
> bump japicmp-maven-plugin version in Flink
>
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270227#comment-16270227
]
Bowen Li commented on FLINK-5544:
-
[~xiaogang.shi] [~srichter] what's the status of this story, guys?
>
[
https://issues.apache.org/jira/browse/FLINK-8061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270123#comment-16270123
]
ASF GitHub Bot commented on FLINK-8061:
---
Github user vetriselvan1187 closed the pull request at:
Github user vetriselvan1187 closed the pull request at:
https://github.com/apache/flink/pull/5008
---
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270116#comment-16270116
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5094
Hi @hequn8128, let me try to explain this.
1. In current implementation, the join process just relies on the cached
rows instead of the watermarks. Specifically, when receiving a record, the
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270090#comment-16270090
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user hequn8128 commented on the issue:
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/5094
Hi @xccui , thanks for your reply. Feel free to take it if you wish. I
still have some confusions.
1. Considering the test `testRowTimeJoinWithCommonBounds2` in
`JoinHarnessTest`, do you mean
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269921#comment-16269921
]
Wei-Che Wei commented on FLINK-7692:
[~Zentol]
This idea is much better. I would like to keep working
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269617#comment-16269617
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5076
These should generally be pretty safe changes to make IMO, and well worth
it. In particular the undeclared usage of transitive dependencies (that may be
shaded) frequently caused headaches, and
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4383
---
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6864.
-
Resolution: Implemented
master: 450b4241404055ed6638e354be421b83380827c5
> Remove confusing "invalid
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269526#comment-16269526
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4574
---
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269508#comment-16269508
]
Chesnay Schepler commented on FLINK-6053:
-
We can't properly subsume the existing gauge type until
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269491#comment-16269491
]
ASF GitHub Bot commented on FLINK-6864:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6864:
--
Fix Version/s: 1.5.0
> Remove confusing "invalid POJO type" messages from TypeExtractor
>
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4574
@zjureel am merging this ... thanks for the PR and edits!
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4383
@zentol @fhueske I am merging the change with the extra space since this
looks to have been the original intent. I've looked at both forms without
finding a strong preference.
---
[
https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cristian updated FLINK-8164:
Description:
I'm trying to configure JobManager's archiving mechanism
[
https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cristian updated FLINK-8164:
Description:
I'm trying to configure JobManager's archiving mechanism
Cristian created FLINK-8164:
---
Summary: JobManager's archiving does not work on S3
Key: FLINK-8164
URL: https://issues.apache.org/jira/browse/FLINK-8164
Project: Flink
Issue Type: Bug
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4374
but honestly, the previous approach just looks wrong: adding it and in case
of a conflict reverting that `put` operation.
What if (and I'm walking in the dark here) something already operates on
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269114#comment-16269114
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269116#comment-16269116
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269115#comment-16269115
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269117#comment-16269117
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269118#comment-16269118
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r153564080
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
---
@@ -114,7 +116,7 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r153564859
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
---
@@ -22,32 +22,52 @@
import
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r153563915
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
---
@@ -39,13 +39,15 @@
private
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r153564111
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
---
@@ -174,19 +175,21 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r153564062
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
---
@@ -133,7 +135,7 @@ int
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269092#comment-16269092
]
ASF GitHub Bot commented on FLINK-8151:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269090#comment-16269090
]
ASF GitHub Bot commented on FLINK-8151:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5070#discussion_r153566048
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -188,13 +188,6 @@ object
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5070#discussion_r153566038
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/MapTypeTest.scala
---
@@ -139,13 +139,6 @@ class MapTypeTest
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269082#comment-16269082
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user walterddr commented on the issue:
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/5040
Thanks @twalthr for confirming, I will also add in the documentation today
then.
---
[
https://issues.apache.org/jira/browse/FLINK-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8119:
Assignee: Till Rohrmann
> Cannot submit jobs to YARN Session in FLIP-6 mode
>
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269041#comment-16269041
]
Stephan Ewen commented on FLINK-5789:
-
We may want to add further abstractions to the file system.
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/commit/c940d5eff9897796625a696ed2989aed52c39ebd#commitcomment-25902242
In tools/releasing/create_source_release.sh:
In tools/releasing/create_source_release.sh on line 60:
could, but that's not
[
https://issues.apache.org/jira/browse/FLINK-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269039#comment-16269039
]
ASF GitHub Bot commented on FLINK-7918:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5095
[FLINK-7918] Run AbstractTestBase tests on Flip-6 MiniCluster
## What is the purpose of the change
Extend `MiniClusterResource` to instantiate a Flip-6 `MiniCluster` if the
system
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268970#comment-16268970
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5094
Hi @hequn8128, thanks for looking into this.
I've checked the current implementation and found that it really may emit
late data. However, that was caused by the checkings below:
[
https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268948#comment-16268948
]
Till Rohrmann commented on FLINK-7300:
--
Another instance of instable Kafka end-to-end tests:
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268907#comment-16268907
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268908#comment-16268908
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5093
Thanks for the review @GJL.
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153524341
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/ResourceIDSerializer.java
---
@@ -29,16 +30,16 @@
/**
*
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268905#comment-16268905
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268903#comment-16268903
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153524087
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java
---
@@ -53,8 +53,8 @@
public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153524037
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java
---
@@ -43,7 +43,7 @@
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4374
@RebornHuan although this change looks to be correct and makes good use of
the newer API, there is a trade-off between deleting a line of code called
during an error condition and the risk of such
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268878#comment-16268878
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4826
So here's the thing: The port of the metric itself is good, and exactly
what i want ð . What I'm unsatisfied with is the naming of the metric, but
that isn't the fault of this PR but a limitation
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268863#comment-16268863
]
Chesnay Schepler commented on FLINK-7692:
-
Let me know what you think, and whether you would like
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268861#comment-16268861
]
Chesnay Schepler commented on FLINK-7692:
-
[~tonywei] Those are good points, luckily we can
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268841#comment-16268841
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5076#discussion_r153511839
--- Diff: pom.xml ---
@@ -891,6 +905,41 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268805#comment-16268805
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268804#comment-16268804
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5076#discussion_r153503257
--- Diff: pom.xml ---
@@ -891,6 +905,41 @@ under the License.
+
+
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5076#discussion_r153500167
--- Diff: pom.xml ---
@@ -891,6 +905,41 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268760#comment-16268760
]
ASF GitHub Bot commented on FLINK-7652:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4734
Hi @tillrohrmann, this PR is now rebased to the latest master, and reworked
to incorporate your last comments.
---
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268738#comment-16268738
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153495140
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java
---
@@ -0,0 +1,195 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268733#comment-16268733
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153493925
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CachedCheckpointStreamFactory.java
---
@@ -0,0 +1,195 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268730#comment-16268730
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153493396
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java
---
@@ -190,6 +199,11 @@ public static
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4666
@raymondtay are we still looking to make this change? Defining the mapper
may be just as likely to confuse new Flink users.
Also, when updating future PRs you want to rebase to master
[
https://issues.apache.org/jira/browse/FLINK-7613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268728#comment-16268728
]
ASF GitHub Bot commented on FLINK-7613:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268727#comment-16268727
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153492995
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java
---
@@ -510,6 +512,13 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268724#comment-16268724
]
ASF GitHub Bot commented on FLINK-7873:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5074#discussion_r153492082
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2Serializer.java
---
@@ -510,6 +512,13 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7805:
---
Assignee: Gary Yao
> Add HA capabilities to YarnResourceManager
>
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268686#comment-16268686
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153483875
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/ResourceIDSerializer.java
---
@@ -29,16 +30,16 @@
/**
* Json
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268681#comment-16268681
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153483098
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java
---
@@ -53,8 +53,8 @@
public static final
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153482920
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java
---
@@ -43,7 +43,7 @@
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268680#comment-16268680
]
ASF GitHub Bot commented on FLINK-8150:
---
Github user GJL commented on a diff in the pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4504
@NicoK The byte counting in the ResultPartition class looks unrelated to
the metric system; in fact that field isn't read anywhere. We may want to
remove it, but I wouldn't do that as part of this
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268656#comment-16268656
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268653#comment-16268653
]
ASF GitHub Bot commented on FLINK-8158:
---
GitHub user hequn8128 opened a pull request:
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/5094
[FLINK-8158] [table] Fix rowtime window inner join emits late data bug
## What is the purpose of the change
This pull request fixes rowtime window inner join emits late data bug.
[
https://issues.apache.org/jira/browse/FLINK-8150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268623#comment-16268623
]
ASF GitHub Bot commented on FLINK-8150:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5093
[FLINK-8150] [flip6] Expose TaskExecutor's ResourceID as TaskExecutor id
## What is the purpose of the change
Before, the TaskExecutor's InstanceID was exposed as TaskExecutor id. This
1 - 100 of 185 matches
Mail list logo