[
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
[
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
>
[
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
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
[
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
[
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
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:
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
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
[
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
> -
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
[
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
> --
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
[
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
> -
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
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
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
[
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
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
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
[
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
[
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
> ---
[
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
[
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
[
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
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
[
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
[
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
[
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
> --
[
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
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
[
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
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
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
[
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
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
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
--
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
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
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
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
[
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
> -
[
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
[
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
> --
>
>
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
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
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
[
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
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
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
[
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
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
[
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
> --
[
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
[
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
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
[
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
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
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
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
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
[
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
> --
[
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
[
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/
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
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
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
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
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
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
[
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
[
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
> --
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
[
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
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
[
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
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
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
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
[
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
[
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
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
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
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
-
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
[
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
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
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
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
[
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
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
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
[
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
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
[
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
[
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
> -
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
[
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
[
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
> -
[
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 - 100 of 209 matches
Mail list logo