[GitHub] zentol closed pull request #7522: [hotfix] fix SubtypeCondition class spell mistake

zentol closed pull request #7522: [hotfix] fix SubtypeCondition class spell mistake URL: https://github.com/apache/flink/pull/7522 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] Myasuka opened a new pull request #7525: [FLINK-11363][test] Check and remove TaskManagerConfigurationTest

Myasuka opened a new pull request #7525: [FLINK-11363][test] Check and remove TaskManagerConfigurationTest URL: https://github.com/apache/flink/pull/7525 ## What is the purpose of the change Check whether `TaskManagerConfigurationTest` contains any relevant tests for the new code

[GitHub] pnowojski commented on a change in pull request #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request.

pnowojski commented on a change in pull request #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request. URL: https://github.com/apache/flink/pull/7520#discussion_r248757349 ## File path:

[jira] [Updated] (FLINK-11363) Check and remove TaskManagerConfigurationTest

[ https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11363: --- Labels: pull-request-available (was: ) > Check and remove TaskManagerConfigurationTest >

[jira] [Commented] (FLINK-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745312#comment-16745312 ] Till Rohrmann commented on FLINK-11293: --- Could be caused by the same problem but this time

[jira] [Assigned] (FLINK-10550) Remove LegacyYarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-10550: Assignee: TisonKun > Remove LegacyYarnClusterDescriptor > -- > >

[jira] [Updated] (FLINK-11106) Remove legacy flink-yarn component

[ https://issues.apache.org/jira/browse/FLINK-11106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11106: --- Labels: pull-request-available (was: ) > Remove legacy flink-yarn component >

[GitHub] TisonKun commented on a change in pull request #7527: [FLINK-11106] [yarn] Remove legacy flink-yarn component

TisonKun commented on a change in pull request #7527: [FLINK-11106] [yarn] Remove legacy flink-yarn component URL: https://github.com/apache/flink/pull/7527#discussion_r248803692 ## File path:

[jira] [Updated] (FLINK-11383) Dispatcher does not clean up blobs of failed submissions

[ https://issues.apache.org/jira/browse/FLINK-11383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11383: --- Labels: pull-request-available (was: ) > Dispatcher does not clean up blobs of failed

[GitHub] tillrohrmann commented on issue #7513: [FLINK-11350][tests] Delete JobClientActorRecoveryITCase

tillrohrmann commented on issue #7513: [FLINK-11350][tests] Delete JobClientActorRecoveryITCase URL: https://github.com/apache/flink/pull/7513#issuecomment-455236814 Thanks for the review @zentol. Merging. This is an

[GitHub] tillrohrmann merged pull request #7513: [FLINK-11350][tests] Delete JobClientActorRecoveryITCase

tillrohrmann merged pull request #7513: [FLINK-11350][tests] Delete JobClientActorRecoveryITCase URL: https://github.com/apache/flink/pull/7513 This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-11353) Check & port JobManagerHAJobGraphRecoveryITCase if necessary to new code base

[ https://issues.apache.org/jira/browse/FLINK-11353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11353: - Assignee: Till Rohrmann > Check & port JobManagerHAJobGraphRecoveryITCase if necessary

[jira] [Commented] (FLINK-11348) Port YARNSessionCapacitySchedulerITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-11348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745333#comment-16745333 ] TisonKun commented on FLINK-11348: -- Maybe blocked by FLINK-11078, once we implement real FLINK YARN

[GitHub] TisonKun commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

TisonKun commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-455271423 @zentol I've rebased the commits, excluded `ExecutionGraphRestartTest` and fixed conflicts with master branch. If I

[GitHub] TisonKun commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

TisonKun commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#discussion_r248781777 ## File path:

[GitHub] tillrohrmann opened a new pull request #7523: [FLINK-11383][blob] Clean up blobs of failed submissions

tillrohrmann opened a new pull request #7523: [FLINK-11383][blob] Clean up blobs of failed submissions URL: https://github.com/apache/flink/pull/7523 ## What is the purpose of the change Let the dispatcher clean up blobs of failed submissions. ## Brief change log -

[GitHub] tillrohrmann closed pull request #7509: [FLINK-10558][Yarn tests] Port YARNHighAvailabilityITCase to new codebase

tillrohrmann closed pull request #7509: [FLINK-10558][Yarn tests] Port YARNHighAvailabilityITCase to new codebase URL: https://github.com/apache/flink/pull/7509 This is an automated message from the Apache Git Service. To

[jira] [Resolved] (FLINK-10558) Port YARNHighAvailabilityITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10558. --- Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] tillrohrmann opened a new pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann opened a new pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526 ## What is the purpose of the change Removed testClientNonDetachedListeningBehaviour because the test was only

[jira] [Updated] (FLINK-11353) Check & port JobManagerHAJobGraphRecoveryITCase if necessary to new code base

[ https://issues.apache.org/jira/browse/FLINK-11353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11353: --- Labels: pull-request-available (was: ) > Check & port JobManagerHAJobGraphRecoveryITCase

[GitHub] pnowojski commented on issue #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request.

pnowojski commented on issue #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request. URL: https://github.com/apache/flink/pull/7520#issuecomment-455257940 Ok regarding previous versions. Could you try validate your fix (first trying to reproduce the failure?) by looping

[jira] [Assigned] (FLINK-11368) Check and port TaskManagerStartupTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11368: Assignee: Yun Tang > Check and port TaskManagerStartupTest to new code base if necessary >

[GitHub] TisonKun commented on a change in pull request #6917: [FLINK-10665] [tests] Remove legacy test YARNSessionFIFOITCase#testJavaAPI

TisonKun commented on a change in pull request #6917: [FLINK-10665] [tests] Remove legacy test YARNSessionFIFOITCase#testJavaAPI URL: https://github.com/apache/flink/pull/6917#discussion_r248773430 ## File path:

[GitHub] TisonKun opened a new pull request #7527: [FLINK-11106] [yarn] Remove legacy flink-yarn component

TisonKun opened a new pull request #7527: [FLINK-11106] [yarn] Remove legacy flink-yarn component URL: https://github.com/apache/flink/pull/7527 ## What is the purpose of the change based on FLINK-10665 #6917 that is the last blocking subtasks. After flink-yarn tests ported

[jira] [Updated] (FLINK-11351) Port JobManagerCleanupITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-11351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11351: --- Labels: pull-request-available (was: ) > Port JobManagerCleanupITCase to new code base >

[GitHub] dawidwys commented on issue #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request.

dawidwys commented on issue #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request. URL: https://github.com/apache/flink/pull/7520#issuecomment-455251221 I don't think we need to port it to previous versions. As far as I understand the code previous versions do it in a

[GitHub] zentol commented on issue #7522: [hotfix] fix SubtypeCondition class spell mistake

zentol commented on issue #7522: [hotfix] fix SubtypeCondition class spell mistake URL: https://github.com/apache/flink/pull/7522#issuecomment-455267107 This is not a typo, `iff` is a shorthand for `if and only if`. This is

[jira] [Closed] (FLINK-11349) Port CoordinatorShutdownTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-11349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11349. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[jira] [Closed] (FLINK-11350) Remove JobClientActorRecoveryITCase

[ https://issues.apache.org/jira/browse/FLINK-11350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11350. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[jira] [Updated] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

[ https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Suen updated FLINK-11379: --- Description: When TM loads a offloaded TDD with large size, it may throw a

[jira] [Created] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

vinoyang created FLINK-11380: Summary: YarnFlinkResourceManagerTest test case crashed Key: FLINK-11380 URL: https://issues.apache.org/jira/browse/FLINK-11380 Project: Flink Issue Type: Test

[GitHub] wuchong commented on a change in pull request #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI

wuchong commented on a change in pull request #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI URL: https://github.com/apache/flink/pull/7450#discussion_r248580800 ## File path: docs/dev/table/functions.md ## @@ -1454,28 +1454,16 @@ HEX(string)

[jira] [Updated] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11380: -- Labels: test-stability (was: ) > YarnFlinkResourceManagerTest test case crashed >

[GitHub] twalthr closed pull request #7409: [FLINK-11064] [table] Setup a new flink-table module structure

twalthr closed pull request #7409: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7409 This is an automated message from the Apache Git Service. To respond to the

[GitHub] twalthr commented on issue #7409: [FLINK-11064] [table] Setup a new flink-table module structure

twalthr commented on issue #7409: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7409#issuecomment-455095250 This PR might need some major rework because the scope of FLIP-28 will change. I close this PR for now.

[jira] [Updated] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11380: -- Fix Version/s: 1.8.0 > YarnFlinkResourceManagerTest test case crashed >

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744818#comment-16744818 ] Till Rohrmann commented on FLINK-11374: --- If the information is already there then we could expose

[GitHub] dawidwys edited a comment on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution …

dawidwys edited a comment on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution … URL: https://github.com/apache/flink/pull/7436#issuecomment-453101329 Thanks for the contribution @eaglewatcherwb . @OlegZhukov I don't think we should introduce

[jira] [Updated] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

[ https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Suen updated FLINK-11379: --- Description: When TM loads a offloaded TDD with large size, it may throw a

[jira] [Updated] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

[ https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Suen updated FLINK-11379: --- Description: When TM loads a offloaded TDD with large size, it may throw a

[jira] [Created] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

Haibo Suen created FLINK-11379: -- Summary: "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD Key: FLINK-11379 URL: https://issues.apache.org/jira/browse/FLINK-11379

[jira] [Updated] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly

[ https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11375: -- Fix Version/s: 1.8.0 > Concurrent modification to slot pool due to SlotSharingManager

[jira] [Updated] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems

[ https://issues.apache.org/jira/browse/FLINK-11378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn van de Grift updated FLINK-11378: - Summary: Allow HadoopRecoverableWriter to write to Hadoop compatible

[jira] [Updated] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11380: -- Priority: Critical (was: Major) > YarnFlinkResourceManagerTest test case crashed >

[jira] [Commented] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly

[ https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744812#comment-16744812 ] Till Rohrmann commented on FLINK-11375: --- Nice catch! > Concurrent modification to slot pool due

[GitHub] sunjincheng121 commented on issue #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunjincheng121 commented on issue #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#issuecomment-455097179 Hi @sunhaibotb Thanks for the update! The PR looks good to me. +1 to merged.

[GitHub] sunjincheng121 edited a comment on issue #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunjincheng121 edited a comment on issue #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#issuecomment-455097179 Hi @sunhaibotb Thanks for the update! The PR looks good to me. +1 to be merged.

[GitHub] dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution …

dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution … URL: https://github.com/apache/flink/pull/7436#issuecomment-455088268 @eaglewatcherwb No that is not what I meant. I just tried to elaborate on @OlegZhukov concern regarding backwards

[GitHub] klion26 commented on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 commented on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#issuecomment-455094170 @StefanRRichter @azagrebin thank you for your review, I've addressed the comments. The

[jira] [Updated] (FLINK-11345) BucketingSinkFaultToleranceITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11345: -- Priority: Critical (was: Major) > BucketingSinkFaultToleranceITCase failed on Travis >

[jira] [Updated] (FLINK-11345) BucketingSinkFaultToleranceITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11345: -- Labels: test-stability (was: ) > BucketingSinkFaultToleranceITCase failed on Travis >

[jira] [Updated] (FLINK-11343) TaskExecutorTest is unstable on travis

[ https://issues.apache.org/jira/browse/FLINK-11343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11343: - Labels: pull-request-available test-stability (was: pull-request-available) >

[jira] [Created] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems.

Martijn created FLINK-11378: --- Summary: Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems. Key: FLINK-11378 URL: https://issues.apache.org/jira/browse/FLINK-11378 Project: Flink

[GitHub] martijnvdgrift opened a new pull request #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado…

martijnvdgrift opened a new pull request #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado… URL: https://github.com/apache/flink/pull/7519 Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems. ## What is the purpose of the change At a

[jira] [Updated] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems.

[ https://issues.apache.org/jira/browse/FLINK-11378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11378: --- Labels: pull-request-available (was: ) > Allow HadoopRecoverableWriter to write to Hadoop

[jira] [Updated] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems

[ https://issues.apache.org/jira/browse/FLINK-11378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn van de Grift updated FLINK-11378: - Description: At a client we're using Flink jobs to read data from Kafka and

[GitHub] TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field

TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field URL: https://github.com/apache/flink/pull/6673#issuecomment-421026733 cc @GJL This is an automated

[GitHub] TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field

TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field URL: https://github.com/apache/flink/pull/6673#issuecomment-422276992 cc @tillrohrmann @GJL @StefanRRichter

[GitHub] TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field

TisonKun removed a comment on issue #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field URL: https://github.com/apache/flink/pull/6673#issuecomment-419695299 cc @tillrohrmann This is an

[jira] [Closed] (FLINK-10304) Remove deprecated AbstractYarnClusterDescriptor field

[ https://issues.apache.org/jira/browse/FLINK-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-10304. Resolution: Won't Do Fix Version/s: (was: 1.8.0) > Remove deprecated

[GitHub] TisonKun closed pull request #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field

TisonKun closed pull request #6673: [FLINK-10304] [client] Remove deprecated AbstractYarnClusterDescriptor field URL: https://github.com/apache/flink/pull/6673 This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-11360) Check and remove LocalFlinkMiniClusterITCase

[ https://issues.apache.org/jira/browse/FLINK-11360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11360. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] TisonKun closed pull request #7355: [hotfix] [dispatcher] Improve signature of #waitForTerminatingJobManager

TisonKun closed pull request #7355: [hotfix] [dispatcher] Improve signature of #waitForTerminatingJobManager URL: https://github.com/apache/flink/pull/7355 This is an automated message from the Apache Git Service. To

[GitHub] asfgit closed pull request #7516: [FLINK-11360] [test] Check and remove LocalFlinkMiniClusterITCase

asfgit closed pull request #7516: [FLINK-11360] [test] Check and remove LocalFlinkMiniClusterITCase URL: https://github.com/apache/flink/pull/7516 This is an automated message from the Apache Git Service. To respond to the

[GitHub] StephanEwen commented on issue #7506: [FLINK-11347] Optimize the ParquetAvroWriters factory

StephanEwen commented on issue #7506: [FLINK-11347] Optimize the ParquetAvroWriters factory URL: https://github.com/apache/flink/pull/7506#issuecomment-455308495 No worries, happy to help! This is an automated message from

[GitHub] tillrohrmann opened a new pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base

tillrohrmann opened a new pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base URL: https://github.com/apache/flink/pull/7524 ## What is the purpose of the change This commit renames JobManagerCleanupITCase into BlobsCleanupITCase and uses the

[GitHub] tillrohrmann commented on a change in pull request #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base

tillrohrmann commented on a change in pull request #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base URL: https://github.com/apache/flink/pull/7514#discussion_r248747514 ## File path:

[GitHub] tillrohrmann commented on issue #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base

tillrohrmann commented on issue #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base URL: https://github.com/apache/flink/pull/7514#issuecomment-455240288 Thanks for the review @zentol. Merging this PR.

[GitHub] tillrohrmann merged pull request #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base

tillrohrmann merged pull request #7514: [FLINK-11349][tests] Port CoordinatorShutdownTest to new code base URL: https://github.com/apache/flink/pull/7514 This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745329#comment-16745329 ] Tarush Grover commented on FLINK-6626: -- [~till.rohrmann] Can I take this task? > Unifying lifecycle

[GitHub] TisonKun commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

TisonKun commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#discussion_r248781935 ## File path:

[jira] [Closed] (FLINK-10550) Remove LegacyYarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-10550. Resolution: Duplicate Covered by FLINK-11106. It is a simply removal, and we can merge these two

[GitHub] zentol merged pull request #7517: [FLINK-11359][test] Check and port LegacyAvroExternalJarProgramITCase to new…

zentol merged pull request #7517: [FLINK-11359][test] Check and port LegacyAvroExternalJarProgramITCase to new… URL: https://github.com/apache/flink/pull/7517 This is an automated message from the Apache Git Service. To

[jira] [Reopened] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11069: -- > Remove FutureUtil > - > > Key: FLINK-11069 >

[GitHub] TisonKun commented on issue #7447: [FLINK-11294] [test] Remove legacy JobInfo usage in valid tests

TisonKun commented on issue #7447: [FLINK-11294] [test] Remove legacy JobInfo usage in valid tests URL: https://github.com/apache/flink/pull/7447#issuecomment-455127472 I see that. Thanks for your effort. This is an

[GitHub] zentol merged pull request #7245: [FLINK-11069] [utils] Remove FutureUtil

zentol merged pull request #7245: [FLINK-11069] [utils] Remove FutureUtil URL: https://github.com/apache/flink/pull/7245 This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Closed] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11069. Resolution: Fixed Fix Version/s: 1.8.0 master:

[GitHub] aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test

aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test URL: https://github.com/apache/flink/pull/7493#discussion_r248630527 ## File path:

[GitHub] aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test

aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test URL: https://github.com/apache/flink/pull/7493#discussion_r248631863 ## File path: flink-end-to-end-tests/test-scripts/test_streaming_classloader.sh ## @@

[GitHub] aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test

aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test URL: https://github.com/apache/flink/pull/7493#discussion_r248632277 ## File path:

[jira] [Commented] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744946#comment-16744946 ] Chesnay Schepler commented on FLINK-11380: -- I've seen this multiple times in recent days. >

[GitHub] zentol commented on a change in pull request #7451: [FLINK-11270][build] Do not include hadoop in flink-dist by default

zentol commented on a change in pull request #7451: [FLINK-11270][build] Do not include hadoop in flink-dist by default URL: https://github.com/apache/flink/pull/7451#discussion_r248608291 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java

[jira] [Created] (FLINK-11381) JOIN LATERAL with a table was not support

Hongtao Zhang created FLINK-11381: - Summary: JOIN LATERAL with a table was not support Key: FLINK-11381 URL: https://issues.apache.org/jira/browse/FLINK-11381 Project: Flink Issue Type:

[GitHub] asfgit closed pull request #7504: [FLINK-10778] [tests] Extend TypeSerializerSnapshotMigrationTestBase to test migrating from multiple versions

asfgit closed pull request #7504: [FLINK-10778] [tests] Extend TypeSerializerSnapshotMigrationTestBase to test migrating from multiple versions URL: https://github.com/apache/flink/pull/7504 This is an automated message

[GitHub] zentol merged pull request #7518: [hotfix] [docs] fix typo in debugging classloading doc

zentol merged pull request #7518: [hotfix] [docs] fix typo in debugging classloading doc URL: https://github.com/apache/flink/pull/7518 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] XuQianJin-Stars commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI

XuQianJin-Stars commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI URL: https://github.com/apache/flink/pull/7450#issuecomment-455105655 hi @wuchong Ok, let me revise the description 。 best qianjin

[GitHub] sunjincheng121 commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible

sunjincheng121 commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible URL: https://github.com/apache/flink/pull/7286#issuecomment-455105860 Merging...

[jira] [Closed] (FLINK-11359) Check and port LegacyAvroExternalJarProgramITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11359. Resolution: Fixed Fix Version/s: 1.8.0 master:

[GitHub] zentol commented on issue #7459: [FLINK-10822] Make MetricFetcher update interval configurable

zentol commented on issue #7459: [FLINK-10822] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#issuecomment-455125707 I've opened https://issues.apache.org/jira/browse/FLINK-11382 for this.

[jira] [Created] (FLINK-11382) Disable MetricFetcher if interval is configured to 0

Chesnay Schepler created FLINK-11382: Summary: Disable MetricFetcher if interval is configured to 0 Key: FLINK-11382 URL: https://issues.apache.org/jira/browse/FLINK-11382 Project: Flink

[jira] [Comment Edited] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files

[ https://issues.apache.org/jira/browse/FLINK-11196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744866#comment-16744866 ] Kostas Kloudas edited comment on FLINK-11196 at 1/17/19 10:38 AM: -- Hi

[jira] [Updated] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11069: - Component/s: Core > Remove FutureUtil > - > > Key:

[jira] [Closed] (FLINK-11069) Remove FutureUtil

[ https://issues.apache.org/jira/browse/FLINK-11069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11069. Resolution: Fixed > Remove FutureUtil > - > > Key:

[GitHub] dawidwys commented on issue #7440: [FLINK-10591][table] Introduced functions to return time attributes from MATCH_RECOGNIZE

dawidwys commented on issue #7440: [FLINK-10591][table] Introduced functions to return time attributes from MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7440#issuecomment-455130490 Hi @pnowojski, Thx for the review, I addressed your comments. As for formatting the

[GitHub] zentol commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

zentol commented on a change in pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#discussion_r248629014 ## File path:

[GitHub] zentol commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

zentol commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-455134967 I would propose to merge part of this PR, namely all tests that are finished in terms of porting. The majority of ports in

[GitHub] aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test

aljoscha commented on a change in pull request #7493: [FLINK-11036] Fix test_streaming_classloader.sh end-to-end test URL: https://github.com/apache/flink/pull/7493#discussion_r248629457 ## File path:

[jira] [Commented] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

[ https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744944#comment-16744944 ] zhangxinyu commented on FLINK-10002: [~lining] Did you test it?  If the log file length is smaller

[jira] [Closed] (FLINK-11289) Rework example module structure to account for licensing

[ https://issues.apache.org/jira/browse/FLINK-11289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11289. Resolution: Fixed Fix Version/s: 1.6.4 master:

[jira] [Commented] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files

[ https://issues.apache.org/jira/browse/FLINK-11196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744866#comment-16744866 ] Kostas Kloudas commented on FLINK-11196: Hi [~markcho]. Thanks for bringing this issue up. I

  1   2   3   >