[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447586#comment-16447586
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5881
Ah, failed on travis, but it is not related to this PR, it's a bug that
should be addressed and there is already a PR for it
https://github.com/apache/flink/pull/5886
---
[
https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447584#comment-16447584
]
Sihua Zhou edited comment on FLINK-9230 at 4/23/18 5:34 AM:
Pu
[
https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447584#comment-16447584
]
Sihua Zhou commented on FLINK-9230:
---
Pull this to blocks because it happen a bit frequen
[
https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9230:
--
Priority: Blocker (was: Critical)
> WebFrontendITCase.testStopYarn is unstable
> --
[
https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447581#comment-16447581
]
ASF GitHub Bot commented on FLINK-9230:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5886
another instance https://travis-ci.org/apache/flink/jobs/369925642...
---
[
https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7289:
--
Comment: was deleted
(was: Hi [~srichter], I think it's quite hard to tell what is the best
configurati
[
https://issues.apache.org/jira/browse/FLINK-9197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9197.
---
> Improve error message for TypyInformation and TypeHint with generics
> -
[
https://issues.apache.org/jira/browse/FLINK-9197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9197.
-
Resolution: Fixed
Fixed in
- 1.5.0 via c202e13bb7c8b9ada24de991ed4f143daa5f490e
- 1.6.0 via 04
[
https://issues.apache.org/jira/browse/FLINK-9223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9223.
---
> bufferConsumers should be closed in
> SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBefor
[
https://issues.apache.org/jira/browse/FLINK-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9198.
-
Resolution: Fixed
Fixed in
- 1.5.0 via e0e94b6afebcb94719dac2510eadf5085fa464e7
- 1.6.0 via 3e
[
https://issues.apache.org/jira/browse/FLINK-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9198.
---
> Improve error messages in AbstractDeserializationSchema for type extraction
> --
[
https://issues.apache.org/jira/browse/FLINK-9223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9223.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in
- 1.5.0 via 1b3059ec30233dc245ac2eb97deee
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9053.
-
Resolution: Fixed
Fixed in
- 1.5.0 via 814d9ea7674cdc4ff32f04807f1c4e8375064425
- 1.6.0 via 53
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8402.
-
Resolution: Fixed
Fix Version/s: (was: 1.4.3)
Fixed in
- 1.5.0 via d36498f3915c303ec2
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8402.
---
> HadoopS3FileSystemITCase.testDirectoryListing fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9076.
---
> Make credit-based floating buffers optional
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447569#comment-16447569
]
Stephan Ewen edited comment on FLINK-9158 at 4/23/18 4:55 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9158.
---
> Set default FixedRestartDelayStrategy delay to 0s
> -
>
[
https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9076.
-
Resolution: Fixed
Fixed in
- 1.5.0 via d178e3f98507c0b2b4e3ce2abd0f2490a16d708a
- 1.6.0 via c4
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8335.
---
Fixed in
- 1.5.0 via 7ae8e41d80932b49beb58e3bee627765cfe5b4f7
- 1.6.0 via d519eb78eae4507aa777a401c9f7
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9158.
-
Resolution: Fixed
Fixed in
- 1.5.0 via cb044229e4c480cc22a250130d58dea5d02fbfc8
> Set default F
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8335:
Fix Version/s: (was: 1.6.0)
1.5.0
> Upgrade hbase connector dependency to 1.4
[
https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9175:
--
Priority: Critical (was: Major)
> Flink CEP with Checkpointing alway failed
> -
[
https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447562#comment-16447562
]
Sihua Zhou commented on FLINK-9175:
---
Hi [~godfrey] Is it possible to provide your sample
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9185:
---
Assignee: (was: mingleizhang)
> Potential null dereference in
> PrioritizedOperatorSubta
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447543#comment-16447543
]
mingleizhang commented on FLINK-9185:
-
Hi, [~Stephen Jason], I unassigned now.
> Pote
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447540#comment-16447540
]
ASF GitHub Bot commented on FLINK-9185:
---
GitHub user StephenJeson opened a pull requ
GitHub user StephenJeson opened a pull request:
https://github.com/apache/flink/pull/5894
[FLINK-9185] [runtime] Fix potential null dereference in PrioritizedOâ¦
## What is the purpose of the change
Fix potential null dereference in
PrioritizedOperatorSubtaskState#resolveP
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9236:
---
Assignee: mingleizhang
> Use Apache Parent POM 19
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447519#comment-16447519
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183269424
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -265,6 +272,29 @@ protected void initialize() throws
ResourceMana
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447495#comment-16447495
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5881
Hi @GJL! Thanks for your nice reviews, I will address the comments you left
ASAP, but some of them I could't catch up properly, looking forward your reply.
---
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447492#comment-16447492
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183267016
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -388,4 +390,108 @@ public void testStopWorker() throws Excepti
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447483#comment-16447483
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183265947
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -356,17 +395,25 @@ public void onContainersAllocated(List
contain
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447480#comment-16447480
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447479#comment-16447479
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183265730
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -265,6 +272,29 @@ protected void initialize() throws
ResourceMana
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183265708
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -114,6 +118,9 @@
private final Map resourcePrioritie
Ted Yu created FLINK-9236:
-
Summary: Use Apache Parent POM 19
Key: FLINK-9236
URL: https://issues.apache.org/jira/browse/FLINK-9236
Project: Flink
Issue Type: Improvement
Reporter: Ted Yu
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-8335.
-
Resolution: Fixed
> Upgrade hbase connector dependency to 1.4.3
>
Shuyi Chen created FLINK-9235:
-
Summary: Add Integration test for Flink-Yarn-Kerberos integration
for flip-6
Key: FLINK-9235
URL: https://issues.apache.org/jira/browse/FLINK-9235
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447411#comment-16447411
]
Shuyi Chen commented on FLINK-8286:
---
Hi [~till.rohrmann] and [~aljoscha], spent some tim
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-8286:
--
Description: The current Flink-Yarn-Kerberos in Flip-6 is broken. (was:
The current )
> Fix Flink-Yar
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-8286:
--
Summary: Fix Flink-Yarn-Kerberos integration for flip-6 (was: Investigate
Flink-Yarn-Kerberos integrati
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-8286:
--
Description: The current (was: We've found some issues with the
Flink-Yarn-Kerberos integration in the
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447360#comment-16447360
]
ASF GitHub Bot commented on FLINK-9053:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447361#comment-16447361
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447364#comment-16447364
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447359#comment-16447359
]
ASF GitHub Bot commented on FLINK-9223:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447362#comment-16447362
]
ASF GitHub Bot commented on FLINK-9076:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447363#comment-16447363
]
ASF GitHub Bot commented on FLINK-9158:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5839
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5882
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5748
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5874
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5624
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5848
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5488
---
Eron Wright created FLINK-9234:
---
Summary: Commons Logging is missing from shaded Flink Table library
Key: FLINK-9234
URL: https://issues.apache.org/jira/browse/FLINK-9234
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447282#comment-16447282
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447281#comment-16447281
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447280#comment-16447280
]
ASF GitHub Bot commented on FLINK-9190:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447283#comment-16447283
]
ASF GitHub Bot commented on FLINK-9190:
---
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/5881#discussion_r183243246
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -388,4 +390,108 @@ public void testStopWorker() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183242992
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -114,6 +118,9 @@
private final Map resourcePriorities = ne
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183243055
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -356,17 +395,25 @@ public void onContainersAllocated(List
containers) {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5881#discussion_r183243029
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -265,6 +272,29 @@ protected void initialize() throws
ResourceManagerExc
[
https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447268#comment-16447268
]
Hai Zhou commented on FLINK-9233:
-
[~StephanEwen], I saw this {{IllegalArgumentException:
[
https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447254#comment-16447254
]
Stephan Ewen commented on FLINK-9233:
-
Is this not fixed in a newer RocksDB version?
[
https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447247#comment-16447247
]
ASF GitHub Bot commented on FLINK-9076:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5874
This fix looks good, thanks!
Merging this...
---
[
https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447234#comment-16447234
]
Hai Zhou commented on FLINK-9233:
-
I am not quite sure that upgrading the rocksdb version
Hai Zhou created FLINK-9233:
---
Summary: Merging state may cause runtime exception when windows
trigger onMerge
Key: FLINK-9233
URL: https://issues.apache.org/jira/browse/FLINK-9233
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447229#comment-16447229
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5624
Merging this for now, because it stabilizes the tests...
---
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447222#comment-16447222
]
ASF GitHub Bot commented on FLINK-9053:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447221#comment-16447221
]
ASF GitHub Bot commented on FLINK-9053:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5748
So, +1, merging this...
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5748
I was unsure initially, because we tried hard to avoid the checkpoint lock
during shutdown/cancellation before (some timer / user thread might hold the
lock)...
The changes to the networ
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447205#comment-16447205
]
Hai Zhou commented on FLINK-9091:
-
+1.
> Failure while enforcing releasability in buildin
[
https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447203#comment-16447203
]
ASF GitHub Bot commented on FLINK-9212:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5893
[FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler to new REST endpoint
## What is the purpose of the change
*Port SubtasksAllAccumulatorsHandler to new REST endpoint*
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5731
@greghogan I have updated this PR, Please look it again.:mask:
---
[
https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447168#comment-16447168
]
ASF GitHub Bot commented on FLINK-9033:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447161#comment-16447161
]
ASF GitHub Bot commented on FLINK-9214:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5892
cc @StephanEwen @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447160#comment-16447160
]
ASF GitHub Bot commented on FLINK-9214:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5892
[FLINK-9214] YarnClient should be stopped in
YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal
## What is the purpose of the change
*This pull fixed a issue about res
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447144#comment-16447144
]
Fred Teunissen commented on FLINK-8500:
---
We want to use the kafka message timestamp
[
https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447140#comment-16447140
]
Hai Zhou commented on FLINK-9032:
-
Hi [~aljoscha], [~till.rohrmann] , what do you think a
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447137#comment-16447137
]
ASF GitHub Bot commented on FLINK-9088:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5891
[FLINK-9088][nifi-connector][build] Bump nifi-site-to-site-client to 1.6.0
## What is the purpose of the change
*Currently dependency of nifi-site-to-site-client is 0.6.1
We should upgrad
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447125#comment-16447125
]
ASF GitHub Bot commented on FLINK-8999:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5890
[FLINK-8999] [e2e] Ensure the job has an operator with operator state
## What is the purpose of the change
This commit that creates a job which contains an operator that use operator
state.
99 matches
Mail list logo
