[jira] [Commented] (FLINK-11387) Flink task can not restart from failed after running two days.

2019-01-17 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745856#comment-16745856 ] TisonKun commented on FLINK-11387: -- [~jiweiautohome] I would suggest you to ask/post th

[jira] [Updated] (FLINK-11388) Add an OSS RecoverableWriter

2019-01-17 Thread wujinhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu updated FLINK-11388: Issue Type: Sub-task (was: Task) Parent: FLINK-9749 > Add an OSS RecoverableWriter >

[jira] [Commented] (FLINK-11388) Add an OSS RecoverableWriter

2019-01-17 Thread wujinhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745861#comment-16745861 ] wujinhu commented on FLINK-11388: - [~stefanrichte...@gmail.com] Pls keep an eye on this

[jira] [Created] (FLINK-11388) Add an OSS RecoverableWriter

2019-01-17 Thread wujinhu (JIRA)
wujinhu created FLINK-11388: --- Summary: Add an OSS RecoverableWriter Key: FLINK-11388 URL: https://issues.apache.org/jira/browse/FLINK-11388 Project: Flink Issue Type: Task Components: Str

[jira] [Updated] (FLINK-11388) Add an OSS RecoverableWriter

2019-01-17 Thread wujinhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu updated FLINK-11388: Environment: (was: OSS offers persistence only after uploads or multi-part uploads complete.  In order

[jira] [Updated] (FLINK-11388) Add an OSS RecoverableWriter

2019-01-17 Thread wujinhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu updated FLINK-11388: Description: OSS offers persistence only after uploads or multi-part uploads complete.  In order to make s

[jira] [Created] (FLINK-11387) Flink task can not restart from failed after running two days.

2019-01-17 Thread jiwei (JIRA)
jiwei created FLINK-11387: - Summary: Flink task can not restart from failed after running two days. Key: FLINK-11387 URL: https://issues.apache.org/jira/browse/FLINK-11387 Project: Flink Issue Type:

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

2019-01-17 Thread GitBox
TisonKun removed a comment on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-455406751 travis fails as below, which I think is irrelevant to this pr. >20:58:02.307 [WARNING] The requested profile "i

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

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

[jira] [Updated] (FLINK-11384) Remove legacy MesosTaskManager

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11384: --- Labels: pull-request-available (was: ) > Remove legacy MesosTaskManager > -

[GitHub] TisonKun opened a new pull request #7531: [FLINK-11384] [mesos] Remove legacy MesosTaskManager

2019-01-17 Thread GitBox
TisonKun opened a new pull request #7531: [FLINK-11384] [mesos] Remove legacy MesosTaskManager URL: https://github.com/apache/flink/pull/7531 ## What is the purpose of the change Remove `MesosTaskManager` and `MesosTaskManagerRunner` ## Verifying this change This change

[jira] [Updated] (FLINK-11385) Remove legacy MesosJobManager

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11385: --- Labels: pull-request-available (was: ) > Remove legacy MesosJobManager > --

[GitHub] TisonKun opened a new pull request #7530: [FLINK-11385] [mesos] Remove legacy MesosJobManager

2019-01-17 Thread GitBox
TisonKun opened a new pull request #7530: [FLINK-11385] [mesos] Remove legacy MesosJobManager URL: https://github.com/apache/flink/pull/7530 ## What is the purpose of the change `MesosJobManager` is totally legacy code. Now we use a `Mesos.*Entrypoint` as its replacement in FLIP-6 a

[jira] [Updated] (FLINK-11385) Remove legacy MesosJobManager

2019-01-17 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11385: - Issue Type: Sub-task (was: Bug) Parent: FLINK-10392 > Remove legacy MesosJobManager > -

[jira] [Created] (FLINK-11386) Remove legacy ContaineredJobManager

2019-01-17 Thread TisonKun (JIRA)
TisonKun created FLINK-11386: Summary: Remove legacy ContaineredJobManager Key: FLINK-11386 URL: https://issues.apache.org/jira/browse/FLINK-11386 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-11385) Remove legacy MesosJobManager

2019-01-17 Thread TisonKun (JIRA)
TisonKun created FLINK-11385: Summary: Remove legacy MesosJobManager Key: FLINK-11385 URL: https://issues.apache.org/jira/browse/FLINK-11385 Project: Flink Issue Type: Bug Components: M

[jira] [Created] (FLINK-11384) Remove legacy MesosTaskManager

2019-01-17 Thread TisonKun (JIRA)
TisonKun created FLINK-11384: Summary: Remove legacy MesosTaskManager Key: FLINK-11384 URL: https://issues.apache.org/jira/browse/FLINK-11384 Project: Flink Issue Type: Sub-task Compone

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

2019-01-17 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745782#comment-16745782 ] shengjk1 commented on FLINK-11336: -- Unfamiliar with batch and bounded streams,so Inconv

[GitHub] TisonKun opened a new pull request #7529: [hotfix] [blob] Generalize usage of NoOpTransientBlobService

2019-01-17 Thread GitBox
TisonKun opened a new pull request #7529: [hotfix] [blob] Generalize usage of NoOpTransientBlobService URL: https://github.com/apache/flink/pull/7529 ## What is the purpose of the change A dummy implementation of `TransientBlobService` is general for further extension. Also replace

[GitHub] TisonKun opened a new pull request #7528: [hotfix] [utils] Implement utils without cost of "enum"

2019-01-17 Thread GitBox
TisonKun opened a new pull request #7528: [hotfix] [utils] Implement utils without cost of "enum" URL: https://github.com/apache/flink/pull/7528 ## What is the purpose of the change `org.apache.flink.docs.util.Utils` uses `enum` mechanism to implement. This would cause additional co

[jira] [Closed] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

2019-01-17 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11376. Resolution: Not A Problem > flink cli -yn -ys is not effect if (yn * ys) parallelism form env.setParall

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

2019-01-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11381: Assignee: vinoyang > JOIN LATERAL with a table was not support > ---

[jira] [Commented] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

2019-01-17 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745724#comment-16745724 ] shengjk1 commented on FLINK-11377: -- yes thanks > AbstractYarnClusterDescriptor's valid

[jira] [Closed] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

2019-01-17 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11377. Resolution: Not A Problem > AbstractYarnClusterDescriptor's validClusterSpecification is not final > appl

[jira] [Commented] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

2019-01-17 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745721#comment-16745721 ] shengjk1 commented on FLINK-11376: -- Hi,Till Rohrmann,thanks for you comment,I agree wit

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

2019-01-17 Thread GitBox
TisonKun commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-455406751 travis fails as below, which I think is irrelevant to this pr. >20:58:02.307 [WARNING] The requested profile "include-k

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

2019-01-17 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11362: --- Assignee: boshu Zheng > Check and port TaskManagerComponentsStartupShutdownTest to new code

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745699#comment-16745699 ] Congxian Qiu commented on FLINK-11352: -- #testCheckpointedStreamingProgramIncrementa

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

2019-01-17 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-11382: - Assignee: leesf > Disable MetricFetcher if interval is configured to 0 > --

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

2019-01-17 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745692#comment-16745692 ] leesf commented on FLINK-11382: --- [~Zentol], hi, The update interval must be larger than 0

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

2019-01-17 Thread GitBox
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 m

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

2019-01-17 Thread Till Rohrmann (JIRA)
[ 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 f012270b1b9fad32e543e7a0195e793ebb402fc5

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

2019-01-17 Thread GitBox
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 th

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

2019-01-17 Thread GitBox
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 respond

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

2019-01-17 Thread TisonKun (JIRA)
[ 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 AbstractYarnClusterDescrip

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

2019-01-17 Thread GitBox
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 res

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

2019-01-17 Thread GitBox
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

2019-01-17 Thread GitBox
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 messa

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

2019-01-17 Thread GitBox
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 automa

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

2019-01-17 Thread GitBox
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: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.j

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

2019-01-17 Thread GitBox
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 to

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ 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 > -

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

2019-01-17 Thread TisonKun (JIRA)
[ 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 subtasks

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

2019-01-17 Thread TisonKun (JIRA)
[ 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 > -- > >

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

2019-01-17 Thread GitBox
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: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRes

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

2019-01-17 Thread GitBox
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: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/VertexSlotSharing

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

2019-01-17 Thread GitBox
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 understan

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

2019-01-17 Thread Tarush Grover (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745329#comment-16745329 ] Tarush Grover commented on FLINK-6626: -- [~till.rohrmann] Can I take this task? > Un

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

2019-01-17 Thread GitBox
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] zentol commented on issue #7522: [hotfix] fix SubtypeCondition class spell mistake

2019-01-17 Thread GitBox
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] [Commented] (FLINK-11348) Port YARNSessionCapacitySchedulerITCase to new code base

2019-01-17 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745333#comment-16745333 ] TisonKun commented on FLINK-11348: -- Maybe blocked by FLINK-11078, once we implement rea

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

2019-01-17 Thread GitBox
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: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOIT

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

2019-01-17 Thread Yun Tang (JIRA)
[ 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 > --

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

2019-01-17 Thread Till Rohrmann (JIRA)
[ 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-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis

2019-01-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745312#comment-16745312 ] Till Rohrmann commented on FLINK-11293: --- Could be caused by the same problem but t

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

2019-01-17 Thread GitBox
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 th

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ 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 if

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

2019-01-17 Thread GitBox
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 r

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

2019-01-17 Thread GitBox
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 tot

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

2019-01-17 Thread GitBox
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: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streamin

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

2019-01-17 Thread GitBox
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 ba

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ 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] [Closed] (FLINK-11349) Port CoordinatorShutdownTest to new code base

2019-01-17 Thread Till Rohrmann (JIRA)
[ 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 97802655b8f28886aac65e7f9f469ab29177257a

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

2019-01-17 Thread Till Rohrmann (JIRA)
[ 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 https://github.com/apache/flink/commit/

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

2019-01-17 Thread GitBox
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 t

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

2019-01-17 Thread GitBox
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. T

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

2019-01-17 Thread GitBox
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: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ExecutionG

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

2019-01-17 Thread GitBox
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 automate

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

2019-01-17 Thread GitBox
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 mess

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

2019-01-17 Thread GitBox
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 re

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

2019-01-17 Thread Till Rohrmann (JIRA)
[ 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 8f5cd0db28ade5a285211bc6949541d1cf4c

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ 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] tillrohrmann opened a new pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base

2019-01-17 Thread GitBox
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 Mi

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ 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 submi

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

2019-01-17 Thread GitBox
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 - Chec

[jira] [Closed] (FLINK-10817) Upgrade presto dependency to support path-style access

2019-01-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10817. Resolution: Fixed Fix Version/s: 1.8.0 Fixed on master in 8e1e12e011d715538ac6ec2bd

[GitHub] aljoscha closed pull request #7058: [FLINK-10817] Upgrade presto dependency to support path-style access

2019-01-17 Thread GitBox
aljoscha closed pull request #7058: [FLINK-10817] Upgrade presto dependency to support path-style access URL: https://github.com/apache/flink/pull/7058 This is an automated message from the Apache Git Service. To respond to

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

2019-01-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11383: - Summary: Dispatcher does not clean up blobs of failed submissions Key: FLINK-11383 URL: https://issues.apache.org/jira/browse/FLINK-11383 Project: Flink Is

[GitHub] zhisheng17 opened a new pull request #7522: [hotfix] fix SubtypeCondition class spell mistake

2019-01-17 Thread GitBox
zhisheng17 opened a new pull request #7522: [hotfix] fix SubtypeCondition class spell mistake URL: https://github.com/apache/flink/pull/7522 RT ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rat

[jira] [Commented] (FLINK-11342) Add example for every built-In TableAPI&SQL Function

2019-01-17 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745170#comment-16745170 ] Hequn Cheng commented on FLINK-11342: - Great, I will create sub-tasks in the next fe

[jira] [Updated] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11372: --- Labels: pull-request-available (was: ) > Incorrect delegation of compatibility checks to ne

[GitHub] dawidwys commented on issue #7495: [hotfix][streaming-java] Add override annotation to mergeWindows meth…

2019-01-17 Thread GitBox
dawidwys commented on issue #7495: [hotfix][streaming-java] Add override annotation to mergeWindows meth… URL: https://github.com/apache/flink/pull/7495#issuecomment-455201766 Thank you for your contribution @leesf This is a

[GitHub] dawidwys merged pull request #7495: [hotfix][streaming-java] Add override annotation to mergeWindows meth…

2019-01-17 Thread GitBox
dawidwys merged pull request #7495: [hotfix][streaming-java] Add override annotation to mergeWindows meth… URL: https://github.com/apache/flink/pull/7495 This is an automated message from the Apache Git Service. To respond t

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

2019-01-17 Thread GitBox
Fokko commented on issue #7506: [FLINK-11347] Optimize the ParquetAvroWriters factory URL: https://github.com/apache/flink/pull/7506#issuecomment-455200619 Thanks @StephanEwen for the explanation. Just catching up with the Flink codebase again. Cheers -

[GitHub] tzulitai opened a new pull request #7521: [FLINK-11372] Fix incorrect delegation of compatibility checks to new CompositeTypeSerializerSnapshots

2019-01-17 Thread GitBox
tzulitai opened a new pull request #7521: [FLINK-11372] Fix incorrect delegation of compatibility checks to new CompositeTypeSerializerSnapshots URL: https://github.com/apache/flink/pull/7521 ## What is the purpose of the change For deprecated snapshots that are no longer in use (but

[jira] [Closed] (FLINK-11341) Correct javadoc of AkkaUtils#getAkkaConfig

2019-01-17 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11341. Resolution: Fixed Fix Version/s: (was: 1.7.1) 1.8.0 Rele

[GitHub] dawidwys commented on issue #7500: [FLINK-11341][doc]Correct javadoc of AkkaUtils#getAkkaConfig

2019-01-17 Thread GitBox
dawidwys commented on issue #7500: [FLINK-11341][doc]Correct javadoc of AkkaUtils#getAkkaConfig URL: https://github.com/apache/flink/pull/7500#issuecomment-455199988 Hi @Asura7969 thank you for your contribution, merged. This

[GitHub] dawidwys merged pull request #7500: [FLINK-11341][doc]Correct javadoc of AkkaUtils#getAkkaConfig

2019-01-17 Thread GitBox
dawidwys merged pull request #7500: [FLINK-11341][doc]Correct javadoc of AkkaUtils#getAkkaConfig URL: https://github.com/apache/flink/pull/7500 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] Fokko commented on issue #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink

2019-01-17 Thread GitBox
Fokko commented on issue #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink URL: https://github.com/apache/flink/pull/7508#issuecomment-455199372 Green on my side: https://travis-ci.org/Fokko/flink/builds/480413297

[jira] [Closed] (FLINK-11294) Remove legacy JobInfo usage in valid tests

2019-01-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11294. Resolution: Fixed Fixed via dcacf0b5676f216806857269132ff3640d98ba3d 3ee4a5b99d8019bd60b363550eb628e6e7cd

[GitHub] GJL merged pull request #7512: [FLINK-11294][tests] Remove legacy JobInfo usage in valid tests

2019-01-17 Thread GitBox
GJL merged pull request #7512: [FLINK-11294][tests] Remove legacy JobInfo usage in valid tests URL: https://github.com/apache/flink/pull/7512 This is an automated message from the Apache Git Service. To respond to the messag

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

2019-01-17 Thread GitBox
dawidwys commented on issue #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request. URL: https://github.com/apache/flink/pull/7520#issuecomment-455194040 @pnowojski Could you have a look at this PR? This is a

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

2019-01-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11293: --- Labels: pull-request-available test-stability (was: test-stability) > KafkaITCase.testConcu

[GitHub] dawidwys opened a new pull request #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request.

2019-01-17 Thread GitBox
dawidwys opened a new pull request #7520: [FLINK-11293][kafka, test] Added timeout to delete topic request. URL: https://github.com/apache/flink/pull/7520 ## What is the purpose of the change The purpose of this PR is to harden kafka ITCases. It targets probable kafka AdminC

[jira] [Commented] (FLINK-11342) Add example for every built-In TableAPI&SQL Function

2019-01-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745111#comment-16745111 ] Stephan Ewen commented on FLINK-11342: -- That sounds good. > Add example for every

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

2019-01-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-11348: Assignee: Gary Yao > Port YARNSessionCapacitySchedulerITCase to new code base > -

[GitHub] GJL commented on a change in pull request #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

2019-01-17 Thread GitBox
GJL commented on a change in pull request #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#discussion_r248679390 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java

[jira] [Commented] (FLINK-11258) Add badge to the README

2019-01-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745068#comment-16745068 ] Chesnay Schepler commented on FLINK-11258: -- I have my doubts regarding the psyc

[jira] [Updated] (FLINK-11342) Add example for every built-In TableAPI&SQL Function

2019-01-17 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11342: Component/s: Documentation > Add example for every built-In TableAPI&SQL Function > -

[jira] [Commented] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

2019-01-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745058#comment-16745058 ] Till Rohrmann commented on FLINK-11377: --- Hi [~shengjk1], {{-yn}} will no longer be

  1   2   3   >