[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447586#comment-16447586 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

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 ---

[jira] [Comment Edited] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447584#comment-16447584 ] Sihua Zhou edited comment on FLINK-9230 at 4/23/18 5:34 AM: Pull this to

[jira] [Commented] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447584#comment-16447584 ] Sihua Zhou commented on FLINK-9230: --- Pull this to blocks because it happen a bit frequently... another

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

[ 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 >

[jira] [Commented] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447581#comment-16447581 ] ASF GitHub Bot commented on FLINK-9230: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5886: [FLINK-9230][test] harden WebFrontendITCase#testStopYarn(...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5886 another instance https://travis-ci.org/apache/flink/jobs/369925642... ---

[jira] [Issue Comment Deleted] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ 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

[jira] [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 closed FLINK-9197. --- > Improve error message for TypyInformation and TypeHint with generics >

[jira] [Resolved] (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

[jira] [Closed] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

[ 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 >

[jira] [Resolved] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction

[ 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

[jira] [Closed] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction

[ 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 >

[jira] [Resolved] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

[ 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

[jira] [Resolved] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel

[ 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

[jira] [Resolved] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ 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

[jira] [Closed] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ 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 >

[jira] [Closed] (FLINK-9076) Make credit-based floating buffers optional

[ 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 > --- > >

[jira] [Comment Edited] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447569#comment-16447569 ] Stephan Ewen edited comment on FLINK-9158 at 4/23/18 4:55 AM: -- Fixed in -

[jira] [Closed] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

[ 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 > - >

[jira] [Resolved] (FLINK-9076) Make credit-based floating buffers optional

[ 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

[jira] [Closed] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ 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

[jira] [Resolved] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

[ 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

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ 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

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ 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 >

[jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447562#comment-16447562 ] Sihua Zhou commented on FLINK-9175: --- Hi [~godfrey] Is it possible to provide your sample code that could

[jira] [Assigned] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ 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 >

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447543#comment-16447543 ] mingleizhang commented on FLINK-9185: - Hi, [~Stephen Jason], I unassigned now. > Potential null

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447540#comment-16447540 ] ASF GitHub Bot commented on FLINK-9185: --- GitHub user StephenJeson opened a pull request:

[GitHub] flink pull request #5894: [FLINK-9185] [runtime] Fix potential null derefere...

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

[jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19

[ 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 > > >

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447519#comment-16447519 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447495#comment-16447495 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

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. ---

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447492#comment-16447492 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447483#comment-16447483 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447480#comment-16447480 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447479#comment-16447479 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[jira] [Created] (FLINK-9236) Use Apache Parent POM 19

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

[jira] [Resolved] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ 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 >

[jira] [Created] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447411#comment-16447411 ] Shuyi Chen commented on FLINK-8286: --- Hi [~till.rohrmann] and [~aljoscha], spent some time on this, the

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ 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

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ 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

[jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6

[ 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

[jira] [Commented] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel

[ https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447360#comment-16447360 ] ASF GitHub Bot commented on FLINK-9053: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447361#comment-16447361 ] ASF GitHub Bot commented on FLINK-8402: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447364#comment-16447364 ] ASF GitHub Bot commented on FLINK-8335: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

[ https://issues.apache.org/jira/browse/FLINK-9223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447359#comment-16447359 ] ASF GitHub Bot commented on FLINK-9223: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9076) Make credit-based floating buffers optional

[ https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447362#comment-16447362 ] ASF GitHub Bot commented on FLINK-9076: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447363#comment-16447363 ] ASF GitHub Bot commented on FLINK-9158: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5839: [FLINK-9158][Distributed Coordination] Set default...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5839 ---

[GitHub] flink pull request #5882: [FLINK-9223] bufferConsumers should be closed in S...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5882 ---

[GitHub] flink pull request #5748: [FLINK-9053][runtime] only release outputs under t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5748 ---

[GitHub] flink pull request #5874: [FLINK-9076][network] reduce minimum number of flo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5874 ---

[GitHub] flink pull request #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT ca...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5624 ---

[GitHub] flink pull request #5848: Minor cleanup of Java example code for AsyncFuncti...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5848 ---

[GitHub] flink pull request #5488: [FLINK-8335] [hbase] Upgrade hbase connector depen...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5488 ---

[jira] [Created] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

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

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447282#comment-16447282 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447281#comment-16447281 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447280#comment-16447280 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447283#comment-16447283 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim...

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

[jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

[ https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447268#comment-16447268 ] Hai Zhou commented on FLINK-9233: - [~StephanEwen], I saw this {{IllegalArgumentException: Illegal value

[jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

[ https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447254#comment-16447254 ] Stephan Ewen commented on FLINK-9233: - Is this not fixed in a newer RocksDB version? > Merging state

[jira] [Commented] (FLINK-9076) Make credit-based floating buffers optional

[ https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447247#comment-16447247 ] ASF GitHub Bot commented on FLINK-9076: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5874: [FLINK-9076][network] reduce minimum number of floating b...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5874 This fix looks good, thanks! Merging this... ---

[jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

[ https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447234#comment-16447234 ] Hai Zhou commented on FLINK-9233: - I am not quite sure that upgrading the rocksdb version to 5.9 or higher

[jira] [Created] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

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

[jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447229#comment-16447229 ] ASF GitHub Bot commented on FLINK-8402: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT cases for...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5624 Merging this for now, because it stabilizes the tests... ---

[jira] [Commented] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel

[ https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447222#comment-16447222 ] ASF GitHub Bot commented on FLINK-9053: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel

[ https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447221#comment-16447221 ] ASF GitHub Bot commented on FLINK-9053: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5748: [FLINK-9053][runtime] only release outputs under the chec...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5748 So, +1, merging this... ---

[GitHub] flink issue #5748: [FLINK-9053][runtime] only release outputs under the chec...

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

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447205#comment-16447205 ] Hai Zhou commented on FLINK-9091: - +1. > Failure while enforcing releasability in building flink-json

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447203#comment-16447203 ] ASF GitHub Bot commented on FLINK-9212: --- GitHub user yew1eb opened a pull request:

[GitHub] flink pull request #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHa...

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] flink issue #5731: [FLINK-9033][config] Replace usages of deprecated TASK_MA...

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: ---

[jira] [Commented] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS

[ https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447168#comment-16447168 ] ASF GitHub Bot commented on FLINK-9033: --- Github user yew1eb commented on the issue:

[jira] [Commented] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

[ https://issues.apache.org/jira/browse/FLINK-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447161#comment-16447161 ] ASF GitHub Bot commented on FLINK-9214: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5892: [FLINK-9214] YarnClient should be stopped in YARNSessionC...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5892 cc @StephanEwen @tillrohrmann ---

[jira] [Commented] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

[ https://issues.apache.org/jira/browse/FLINK-9214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447160#comment-16447160 ] ASF GitHub Bot commented on FLINK-9214: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5892: [FLINK-9214] YarnClient should be stopped in YARNS...

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

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447144#comment-16447144 ] Fred Teunissen commented on FLINK-8500: --- We want to use the kafka message timestamp in our business

[jira] [Commented] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447140#comment-16447140 ] Hai Zhou commented on FLINK-9032: - Hi [~aljoscha], [~till.rohrmann] , what do you think about this? >

[jira] [Commented] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0

[ https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447137#comment-16447137 ] ASF GitHub Bot commented on FLINK-9088: --- GitHub user yew1eb opened a pull request:

[GitHub] flink pull request #5891: [FLINK-9088][nifi-connector][build] Bump nifi-site...

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

[jira] [Commented] (FLINK-8999) Ensure the job has an operator with operator state.

[ https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447125#comment-16447125 ] ASF GitHub Bot commented on FLINK-8999: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #5890: [FLINK-8999] [e2e] Ensure the job has an operator ...

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

[jira] [Commented] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447120#comment-16447120 ] ASF GitHub Bot commented on FLINK-9188: --- Github user tweise commented on the issue:

  1   2   >