[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416907#comment-16416907
]
ASF GitHub Bot commented on FLINK-8979:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5778
[FLINK-8979] (part 1) Make Kafka end-to-end tests not embarrassingly
parallel
## What is the purpose of the change
This PR improves the behaviour test coverage of Kafka end-to-end tests by
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8941.
--
Resolution: Fixed
Fixed via
master:
39be1996e461bbeec148bf34a2f92cedeccf59ab
a148492e142c7f62cbd
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9057.
--
Resolution: Fixed
Fixed via
master: f486a3fd6ed80b67e8eeed9245ad37b6b0be740b
1.5.0: f1df310814b6
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416867#comment-16416867
]
ASF GitHub Bot commented on FLINK-9057:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416868#comment-16416868
]
ASF GitHub Bot commented on FLINK-8941:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416869#comment-16416869
]
ASF GitHub Bot commented on FLINK-8415:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8415.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
master: dc0f344f3c345765a59fcce60841fa56
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5724
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5747
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5709
---
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5776
cc @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416807#comment-16416807
]
ASF GitHub Bot commented on FLINK-7897:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5777
cc @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-8708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416808#comment-16416808
]
ASF GitHub Bot commented on FLINK-8708:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416734#comment-16416734
]
yanxiaobin commented on FLINK-8794:
---
thanks! indeed so. Enable consistent-view can caus
[
https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu updated FLINK-9077:
--
Priority: Blocker (was: Major)
> flip6 cluster framework doesn't work on mesos
> --
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416625#comment-16416625
]
ASF GitHub Bot commented on FLINK-7897:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5777
[FLINK-7897] Consider using nio.Files for file deletion in
TransientBlobCleanupTask
## What is the purpose of the change
*This pull request use `nio.Files.delete` method to make the delete
[
https://issues.apache.org/jira/browse/FLINK-8708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416585#comment-16416585
]
ASF GitHub Bot commented on FLINK-8708:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5776
[FLINK-8708] Unintended integer division in StandaloneThreadedGenerator
## What is the purpose of the change
*This pull request fixed unintended integer division in
StandaloneThreadedGenera
[
https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416550#comment-16416550
]
ASF GitHub Bot commented on FLINK-9033:
---
Github user yew1eb commented on a diff in t
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5731#discussion_r177616520
--- Diff:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
---
@@ -23,7 +23,7 @@ import java.io._
import akka.actor.Ac
Szymon Szczypiński created FLINK-9100:
-
Summary: Shadow/Hide password from configuration that is logged to
log file
Key: FLINK-9100
URL: https://issues.apache.org/jira/browse/FLINK-9100
Project: F
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416271#comment-16416271
]
Jamie Grier commented on FLINK-9061:
[~StephanEwen] I don't know if the s3a-based conn
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416254#comment-16416254
]
Jamie Grier edited comment on FLINK-9061 at 3/27/18 9:13 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416254#comment-16416254
]
Jamie Grier commented on FLINK-9061:
Yeah, so I completely agree that should be a 503
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-9090.
---
Resolution: Later
I did a quick search but haven't found one on the hot path.
> Replace UUID.randomUUID with
[
https://issues.apache.org/jira/browse/FLINK-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416225#comment-16416225
]
Kirill A. Korinskiy commented on FLINK-8809:
[~greghogan] yes, I discovered th
[
https://issues.apache.org/jira/browse/FLINK-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416137#comment-16416137
]
Greg Hogan commented on FLINK-8809:
---
Will a restricted {{MaxDirectMemorySize}} prevent a
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416128#comment-16416128
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177544954
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
---
@@ -465,6 +464,58 @@ public void
testSchedu
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416126#comment-16416126
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177544459
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
---
@@ -465,6 +464,58 @@ public void
testSchedu
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177544274
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
---
@@ -465,6 +464,58 @@ public void
testSchedu
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416124#comment-16416124
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416123#comment-16416123
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177543886
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -659,7 +660,7 @@ public void disconnectResourceManager()
[
https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416104#comment-16416104
]
ASF GitHub Bot commented on FLINK-9033:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5731#discussion_r177536243
--- Diff:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
---
@@ -23,7 +23,7 @@ import java.io._
import akka.actor
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416063#comment-16416063
]
Greg Hogan commented on FLINK-9090:
---
Could you point to a case where use of {{UUID.rando
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415910#comment-16415910
]
Greg Hogan edited comment on FLINK-9090 at 3/27/18 6:30 PM:
Wh
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9090:
--
Summary: Replace UUID.randomUUID with more efficient PRNG (was: Replace
UUID.randomUUID with deterministic PRNG
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16416034#comment-16416034
]
Ted Yu commented on FLINK-9090:
---
The main goal is to avoid single JVM wide lock, rather than
[
https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415990#comment-16415990
]
ASF GitHub Bot commented on FLINK-8620:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5580
@zentol I've rebased this PR. Feel free to review whenever you find a while.
---
[
https://issues.apache.org/jira/browse/FLINK-9082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9082:
-
Assignee: Sihua Zhou
> Submission with higher parallelism than task slots fails with TimeoutExcep
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415934#comment-16415934
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5755#discussion_r177497889
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -165,7 +166,7 @@
private final BlobServer blobServer;
[
https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415910#comment-16415910
]
Greg Hogan commented on FLINK-9090:
---
Why the need to be deterministic (and user configur
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415826#comment-16415826
]
Christopher Ng edited comment on FLINK-8836 at 3/27/18 3:51 PM:
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415826#comment-16415826
]
Christopher Ng commented on FLINK-8836:
---
[~StephanEwen] i asked on the Kryo mailing
[
https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415818#comment-16415818
]
ASF GitHub Bot commented on FLINK-8973:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5750
Hi @walterddr, I addressed most of your comments. Feel free to have another
look.
---
Github user uce commented on the pull request:
https://github.com/apache/flink/commit/3a61ea47922280e15f462ca3cdc0c367047bde24#commitcomment-28293221
@twalthr I think this broke the build. At least locally, I get a RAT
license failure.
```
1 Unknown Licenses
***
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415806#comment-16415806
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r177468202
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-8980:
---
Assignee: Timo Walther (was: Florian Schmidt)
> End-to-end test: BucketingSink
> ---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5755#discussion_r177466102
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/factories/DefaultJobManagerJobMetricGroupFactory.java
---
@@ -0,0 +1,46 @@
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415799#comment-16415799
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415794#comment-16415794
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5755
@zentol, I've addressed your comments and updated the PR accordingly.
---
[
https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8968:
--
Priority: Blocker (was: Major)
> Fix native resource leak caused by ReadOptions
>
[
https://issues.apache.org/jira/browse/FLINK-9064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415789#comment-16415789
]
ASF GitHub Bot commented on FLINK-9064:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5773
cc @tillrohrmann , it seems the travis build failed is not unrelated with
this PR's change.
---
[
https://issues.apache.org/jira/browse/FLINK-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-9062.
---
Resolution: Fixed
> As the Chinese government closed its visit to Google（GFW），the drop-down menu
> ab
[
https://issues.apache.org/jira/browse/FLINK-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415786#comment-16415786
]
Timo Walther commented on FLINK-9062:
-
Fixed in flink-web: f0107ae87834f40a2a9ce025df6
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415784#comment-16415784
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5488
@zhangminglei You are right, the dependencies should have been excluded
back then. But better to fix later than never ;-)
For the dependencies to exclude, it is hard to find that out. I w
[
https://issues.apache.org/jira/browse/FLINK-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-9062:
---
Assignee: Timo Walther
> As the Chinese government closed its visit to Google（GFW），the drop-d
[
https://issues.apache.org/jira/browse/FLINK-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9093.
-
Resolution: Fixed
Fix Version/s: 1.3.4
1.4.3
1.5.0
Fi
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415740#comment-16415740
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5488
I haven't looked at the changelog but HBase 1.4.2 was released a few weeks
ago.
---
[
https://issues.apache.org/jira/browse/FLINK-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415729#comment-16415729
]
ASF GitHub Bot commented on FLINK-9093:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5770
---
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415692#comment-16415692
]
ASF GitHub Bot commented on FLINK-8415:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5724
Changes look good to me @yanghua. Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415684#comment-16415684
]
ASF GitHub Bot commented on FLINK-9093:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415688#comment-16415688
]
ASF GitHub Bot commented on FLINK-8941:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5709
Alright. Thanks for your contribution @NicoK and the review @pnowojski.
Merging this PR.
---
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5770
Thank you @Matrix42. I will merge this to the recent release branches.
---
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9067.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.6.0: 6c37b15721af3a84fb3ac0de14486a9e9843
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415665#comment-16415665
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5755#discussion_r177436964
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/factories/DefaultJobManagerJobMetricGroupFactory.java
---
@@ -0,0 +1,46 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415664#comment-16415664
]
ASF GitHub Bot commented on FLINK-8973:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5750#discussion_r177436350
--- Diff: flink-end-to-end-tests/test-scripts/common.sh ---
@@ -59,9 +162,42 @@ function start_cluster {
done
}
+function jm_watchdog() {
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415657#comment-16415657
]
ASF GitHub Bot commented on FLINK-9067:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5759
---
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415655#comment-16415655
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415653#comment-16415653
]
ASF GitHub Bot commented on FLINK-9067:
---
Github user zhangminglei commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5755#discussion_r17742
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/factories/DefaultJobManagerJobMetricGroupFactory.java
---
@@ -0,0 +1,46 @@
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5759#discussion_r177433238
--- Diff: flink-end-to-end-tests/test-scripts/test_streaming_sql.sh ---
@@ -0,0 +1,43 @@
+#!/usr/bin/env bash
+#
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5775
[FLINK-9099] Assign Execution to LogicalSlot when slot is assigned to
Execution
## What is the purpose of the change
In order to fail fast if an allocated slot is released by the SlotP
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415640#comment-16415640
]
ASF GitHub Bot commented on FLINK-9099:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415609#comment-16415609
]
Truong Duc Kien commented on FLINK-9070:
So here's my idea for RocksDBMapState.cle
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415583#comment-16415583
]
ASF GitHub Bot commented on FLINK-9067:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415581#comment-16415581
]
ASF GitHub Bot commented on FLINK-9067:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415582#comment-16415582
]
ASF GitHub Bot commented on FLINK-9067:
---
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/5759#discussion_r177416467
--- Diff: flink-end-to-end-tests/test-scripts/test_streaming_sql.sh ---
@@ -0,0 +1,43 @@
+#!/usr/bin/env bash
+##
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5759#discussion_r177416632
--- Diff: flink-end-to-end-tests/flink-stream-sql-test/pom.xml ---
@@ -0,0 +1,126 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xml
1 - 100 of 193 matches
Mail list logo
