Re: [ANNOUNCE] Andrey Zagrebin becomes a Flink committer

2019-08-14 Thread Gary Yao
Congratulations Andrey, well deserved! Best, Gary On Thu, Aug 15, 2019 at 7:50 AM Bowen Li wrote: > Congratulations Andrey! > > On Wed, Aug 14, 2019 at 10:18 PM Rong Rong wrote: > >> Congratulations Andrey! >> >> On Wed, Aug 14, 2019 at 10:14 PM chaojianok wrote: >> >> > Congratulations Andre

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

2019-08-14 Thread Gary Yao
+1 (non-binding) Jepsen test suite passed 10 times consecutively On Wed, Aug 14, 2019 at 5:31 PM Aljoscha Krettek wrote: > +1 > > I did some testing on a Google Cloud Dataproc cluster (it gives you a > managed YARN and Google Cloud Storage (GCS)): > - tried both YARN session mode and YARN per

Re: [VOTE] Apache Flink 1.9.0, release candidate #3

2019-08-20 Thread Gary Yao
+1 (non-binding) Reran Jepsen tests 10 times. On Wed, Aug 21, 2019 at 5:35 AM vino yang wrote: > +1 (non-binding) > > - checkout source code and build successfully > - started a local cluster and ran some example jobs successfully > - verified signatures and hashes > - checked release notes and

[DISCUSS] Features for Apache Flink 1.10

2019-09-06 Thread Gary Yao
Hi community, Since Apache Flink 1.9.0 has been released more than 2 weeks ago, I want to start kicking off the discussion about what we want to achieve for the 1.10 release. Based on discussions with various people as well as observations from mailing list threads, Yu Li and I have compiled a li

Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC

2019-09-06 Thread Gary Yao
Congratulations Klou! On Sat, Sep 7, 2019 at 6:21 AM Thomas Weise wrote: > Congratulations! > > > On Fri, Sep 6, 2019 at 9:22 AM zhijiang .invalid> > wrote: > > > Congratulations Klou! > > > > Best, > > Zhijiang > > -- > > From:Zhu

Re: [VOTE] Release 1.10.0, release candidate #1

2020-02-05 Thread Gary Yao
rowse/FLINK-15917 [2] https://issues.apache.org/jira/browse/FLINK-15918 [3] https://issues.apache.org/jira/browse/FLINK-8949 On Wed, Feb 5, 2020 at 7:04 AM Thomas Weise wrote: > Hi Gary, > > Thanks for the reply. > > --> > > On Tue, Feb 4, 2020 at 5:20 AM Gary Yao wrote: &

[VOTE] Release 1.10.0, release candidate #2

2020-02-05 Thread Gary Yao
Hi everyone, Please review and vote on the release candidate #2 for the version 1.10.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

Re: [VOTE] Release 1.10.0, release candidate #1

2020-02-05 Thread Gary Yao
gt;> flink-conf.yaml but upgrade our existing tooling and configuration. >> Therefore we notice this issue as part of the upgrade to 1.10, and not >> when >> we upgraded to 1.9. >> >> I would expect many other users to be in the same camp, and therefore >

Re: [VOTE] Release 1.10.0, release candidate #2

2020-02-05 Thread Gary Yao
:00 PM Gary Yao wrote: > Hi everyone, > Please review and vote on the release candidate #2 for the version 1.10.0, > as follows: > [ ] +1, Approve the release > [ ] -1, Do not approve the release (please provide specific comments) > > > The complete staging area is availabl

Re: [VOTE] Release 1.10.0, release candidate #2

2020-02-07 Thread Gary Yao
> > > > > > > > The order of classpaths should be influenced by the ls of Linux. > By > > > > > default > > > > > > the ls command is listing the files in alphabetical order. [1] > > > > > > > > > > > > >

[VOTE] Release 1.10.0, release candidate #3

2020-02-07 Thread Gary Yao
Hi everyone, Please review and vote on the release candidate #3 for the version 1.10.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

[RESULT] [VOTE] Release 1.10.0, release candidate #3

2020-02-10 Thread Gary Yao
I'm happy to announce that we have unanimously approved this release. There are 16 approving votes, 5 of which are binding: * Kurt Young (binding) * Jark Wu (binding) * Kostas Kloudas (binding) * Thomas Weise (binding) * Jincheng Sun (binding) * Aihua Li (non-binding) * Zhu Zhu (non-binding) * Con

Re: [VOTE] FLIP-99: Make Max Exception Configurable

2020-02-27 Thread Gary Yao
+1 (binding) Best, Gary On Thu, Feb 20, 2020 at 10:39 AM Yadong Xie wrote: > Hi all > > I want to start the vote for FLIP-99, which proposes to make the max > exception configurable in web UI. > > To help everyone better understand the proposal, we spent some efforts on > making an online POC >

Re: [VOTE] FLIP-100: Add Attempt Information

2020-03-02 Thread Gary Yao
Hi Yadong, Thanks for driving this FLIP. I have a few questions/remarks: * Why are we duplicating the subtask index in the objects that are stored in the attempts-time-info array? I thought that all objects in the same array share the same subtask index. * Are we confident that the attemp

Re: [VOTE] FLIP-100: Add Attempt Information

2020-03-03 Thread Gary Yao
Hi Yadong, Thank you for updating the wiki page. Only one minor suggestion – I would change: > If show-history is true return the information of attempt. to > If show-history is true, information for all attempts including previous ones will be returned That being said, FLIP-100 looks

Re: [VOTE] FLIP-100[NEW]: Add Attempt Information

2020-03-04 Thread Gary Yao
+1 (binding) Best, Gary On Wed, Mar 4, 2020 at 1:18 PM Yadong Xie wrote: > Hi all > > I want to start the vote for FLIP-100, which proposes to add attempt > information inside subtask and timeline in web UI. > > To help everyone better understand the proposal, we spent some efforts on > making

Re: [VOTE] FLIP 116: Unified Memory Configuration for Job Managers

2020-03-25 Thread Gary Yao
+1 (binding) Best, Gary On Wed, Mar 18, 2020 at 3:16 PM Andrey Zagrebin wrote: > Hi All, > > The discussion for FLIP-116 looks to be resolved [1]. > Therefore, I start the vote for it. > The vote will end at 6pm CET on Monday, 23 March. > > Best, > Andrey > > [1] > > http://mail-archives.apache

[DISCUSS] FLIP-119: Pipelined Region Scheduling

2020-03-26 Thread Gary Yao
Hi community, In the past releases, we have been working on refactoring Flink's scheduler with the goal of making the scheduler extensible [1]. We have rolled out most of the intended refactoring in Flink 1.10, and we think it is now time to leverage our newly introduced abstractions to implement

Re: [DISCUSS] Creating a new repo to host Stateful Functions Dockerfiles

2020-03-27 Thread Gary Yao
+1 for a separate repository. Best, Gary On Fri, Mar 27, 2020 at 2:46 AM Hequn Cheng wrote: > +1 for a separate repository. > The dedicated `flink-docker` repo works fine now. We can do it similarly. > > Best, > Hequn > > On Fri, Mar 27, 2020 at 1:16 AM Till Rohrmann > wrote: > > > +1 for a se

Re: [DISCUSS] FLIP-119: Pipelined Region Scheduling

2020-03-30 Thread Gary Yao
ze Guo 于2020年3月27日周五 下午4:49写道: > > > > > > > > > > > Thanks for updating! > > > > > > > > > > > > +1 for supporting the pipelined region scheduling. Although we > > could > > > > > > not prev

[VOTE] FLIP-119: Pipelined Region Scheduling

2020-03-31 Thread Gary Yao
Hi all, I would like to start the vote for FLIP-119 [1], which is discussed and reached a consensus in the discussion thread [2]. The vote will be open until April 3 (72h) unless there is an objection or not enough votes. Best, Gary [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-119

Re: [VOTE] FLIP-119: Pipelined Region Scheduling

2020-04-06 Thread Gary Yao
; +1 (binding) > > > > > > > > > > Best, > > > > > Zhijiang > > > > > > > > > > > > > > > -- > > > > > From:Till Rohrmann > &

Re: [DISCUSS] Switch to Azure Pipelines as the primary CI tool / switch off Travis

2020-04-17 Thread Gary Yao
I am in favour of decommissioning Travis. Moreover, I wanted to use this thread to raise another issue with Travis that I have discovered recently; many of the builds running in my private Travis account are timing out in the compilation stage (i.e., compilation takes more than 50 minutes). This m

Re: [VOTE] FLIP-56: Dynamic Slot Allocation

2019-09-24 Thread Gary Yao
Hi Xintong, Thanks for starting the vote. The proposed changes look good to me. +1 (binding) Best, Gary On Mon, Sep 23, 2019 at 4:18 PM Till Rohrmann wrote: > Thanks for updating the Flip. It looks good to me. > > +1 (binding) > > Cheers, > Till > > On Mon, Sep 23, 2019 at 4:12 PM Xintong Son

[REMINDER] Ensuring build stability

2019-10-18 Thread Gary Yao
Hi community, We created the bui...@flink.apache.org mailing list as an effort to be more transparent about build instabilities, especially about issues that were only surfacing in CRON builds at the time, such as, Scala 2.12 and Java 9 compilation errors. While the situation has gotten better, t

[ANNOUNCE] Progress of Apache Flink 1.10 #2

2019-11-01 Thread Gary Yao
Hi community, Because we have approximately one month of development time left until the targeted Flink 1.10 feature freeze, we thought now would be a good time to give another progress update. Below we have included a list of the ongoing efforts that have made progress since our last release prog

Re: [VOTE] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-21 Thread Gary Yao
+1 (binding) Best, Gary On Thu, Nov 21, 2019 at 7:55 AM Zhu Zhu wrote: > Thanks Yu for this proposal. > +1(non-binding) for the overall design. > > I have 2 questions about the result check though. Posted in the discussion > ML thread. > > Thanks, > Zhu Zhu > > Becket Qin 于2019年11月21日周四 上午11:5

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.10.0 release

2019-12-09 Thread Gary Yao
Hi all, We have just created the release-1.10 branch. Please remember to merge bug fixes to both release-1.10 and master branches from now on if you want the fix to be included in the Flink 1.10 release. Best, Yu & Gary On Tue, Nov 19, 2019 at 4:44 PM Yu Li wrote: > Hi devs, > > Per the featur

Re: [DISCUSS] Adding e2e tests for Flink's Mesos integration

2019-12-11 Thread Gary Yao
Thanks for driving this effort. Also +1 from my side. I have left a few questions below. > - Wordcount end-to-end test. For verifying the basic process of Mesos > deployment. Would this add additional test coverage compared to the "multiple submissions" test case? I am asking because the E2E test

Re: [DISCUSS] Adding e2e tests for Flink's Mesos integration

2019-12-12 Thread Gary Yao
xpected usage of off-heap memory. > - A streaming task using rocks backend. It covers the scenario using > off-heap memory. > > Look forward to your kind feedback. > > [1]https://issues.apache.org/jira/browse/FLINK-15135 > > Best, > Yangze Guo > > > > On Wed, De

Re: [ANNOUNCE] Zhu Zhu becomes a Flink committer

2019-12-17 Thread Gary Yao
Congratulations, well deserved. On Tue, Dec 17, 2019 at 10:09 AM lining jing wrote: > Congratulations Zhu Zhu~ > > Andrey Zagrebin 于2019年12月16日周一 下午5:01写道: > > > Congrats Zhu Zhu! > > > > On Mon, Dec 16, 2019 at 8:10 AM Xintong Song > > wrote: > > > > > Congratulations Zhu Zhu~ > > > > > > Tha

[ANNOUNCE] Apache Flink 1.10.0, release candidate #0

2020-01-17 Thread Gary Yao
Hi all, RC0 for Apache Flink 1.10.0 has been created. This has all the artifacts that we would typically have for a release, except for a source code tag and a PR for the release announcement. This preview-only RC is created only to drive the current testing efforts, and no official vote will tak

[VOTE] Release 1.10.0, release candidate #1

2020-01-27 Thread Gary Yao
Hi everyone, Please review and vote on the release candidate #1 for the version 1.10.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

Re: [VOTE] Release 1.10.0, release candidate #1

2020-02-03 Thread Gary Yao
Hi everyone, I am hereby canceling the vote due to: FLINK-15837 FLINK-15840 Another RC will be created later today. Best, Gary On Mon, Jan 27, 2020 at 10:06 PM Gary Yao wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the version 1.10.0, > a

Re: [VOTE] Release 1.10.0, release candidate #1

2020-02-04 Thread Gary Yao
b 3, 2020 at 10:55 AM Thomas Weise wrote: > > > I found another issue with the Kinesis connector: > > > > https://issues.apache.org/jira/browse/FLINK-15868 > > > > > > On Mon, Feb 3, 2020 at 3:35 AM Gary Yao wrote: > > > >> Hi eve

Re: Rewriting a new file instead of writing a ".valid-length" file in BucketSink when restoring

2018-05-15 Thread Gary Yao
Hi, The BucketingSink truncates the file if the Hadoop FileSystem supports this operation (Hadoop 2.7 and above) [1]. What version of Hadoop are you using? Best, Gary [1] https://github.com/apache/flink/blob/bcd028d75b0e5c5c691e24640a2196b2fdaf85e0/flink-connectors/flink-connector-filesystem/src

Re: [VOTE] Release 1.5.0, release candidate #5

2018-05-23 Thread Gary Yao
+1 (non-binding) I have run all examples (batch & streaming), and only found a non-blocking issue with TPCHQuery3 [1] which has been introduced a year ago. I have also deployed a cluster with HA enabled on YARN (Hadoop 2.8.3) without problems. [1] https://issues.apache.org/jira/browse/FLINK-9399

Re: [VOTE] Release 1.5.0, release candidate #6

2018-05-25 Thread Gary Yao
+1 (non-binding) I have tested HA capabilities on YARN (Hadoop 2.8.3). Best, Gary On Fri, May 25, 2018 at 4:54 PM, Tzu-Li (Gordon) Tai wrote: > +1 > > - Verified signatures and hashes > - Built from source with Hadoop 2.8.1 and Scala 2.11.7, tests pass locally > - No binaries in source archive

Re: [VOTE] Release 1.5.1, release candidate #2

2018-07-10 Thread Gary Yao
+1 (non-binding) Ran Jepsen tests [1] on EC2 for around 8 hours without issues. [1] https://github.com/apache/flink/pull/6240 On Tue, Jul 10, 2018 at 11:00 AM, Aljoscha Krettek wrote: > +1 (binding) > > - verified signatures and checksums > - built successfully from source > > > On 10. Jul 201

Re: [VOTE] Release 1.6.0, release candidate #1

2018-07-25 Thread Gary Yao
-1 (non-binding) We introduced a regression: https://issues.apache.org/jira/browse/FLINK-9939 Best, Gary On Tue, Jul 24, 2018 at 9:38 AM, Till Rohrmann wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the version 1.6.0, > as follows: > [ ] +1, Approve the release

Re: [VOTE] Release 1.5.2, release candidate #1

2018-07-25 Thread Gary Yao
-1 (non-binding) We introduced a regression: https://issues.apache.org/jira/browse/FLINK-9939 Best, Gary P.S. Link under [2] should be https://dist.apache.org/repos/dist/dev/flink/flink-1.5.2/ On Tue, Jul 24, 2018 at 2:43 PM, Chesnay Schepler wrote: > Hi everyone, > Please review and vote on

Re: How to handle tests that need docker?

2018-08-17 Thread Gary Yao
Hi, If you are writing JUnit tests, you could use testcontainers [1] to start the PubSub container. Then you could introduce a build profile [2] that enables certain JUnit tests by using Categories [3] or the maven-failsafe-plugin [4]. Best, Gary [1] https://www.testcontainers.org/usage/generic_

Re: Cannot run example on EMR

2018-08-30 Thread Gary Yao
Hi Andy, Can you try setting HADOOP_CLASSPATH=`hadoop classpath` [1]? This is a common problem, and we should update the Flink AWS documentation. Can you open a ticket for that? Best, Gary [1] https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/deployment/hadoop.html On Thu, Aug 30

Re: Cancel flink job occur exception.

2018-09-08 Thread Gary Yao
Hi Devin, If I understand you correctly, you are submitting a job in the YARN per-job cluster mode. You are then invoking the "cancel with savepoint" command but the client is not able to poll for the savepoint location before the cluster shuts down. I think your analysis is correct. As far as I

Re: Cancel flink job occur exception.

2018-09-09 Thread Gary Yao
t he temporarily solve this problem in our way. > > I have created an issue to follow it.[1] > > [1]: https://issues.apache.org/jira/browse/FLINK-10309 > > Thanks, vino. > > Gary Yao 于2018年9月9日周日 下午1:13写道: > > > Hi Devin, > > > > If I understand you correct

Re: [VOTE] Release 1.6.1, release candidate #1

2018-09-19 Thread Gary Yao
+1 (non-binding) Ran test suite from the flink-jepsen project on AWS EC2 without issues. Best, Gary On Sat, Sep 15, 2018 at 11:32 PM, Till Rohrmann wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the version 1.6.1, > as follows: > [ ] +1, Approve the release > [

Re: [VOTE] Release 1.5.4, release candidate #1

2018-09-20 Thread Gary Yao
+1 (non-binding) Ran test suite from the flink-jepsen project on AWS EC2 without issues. Best, Gary On Wed, Sep 19, 2018 at 11:02 PM, Fabian Hueske wrote: > +1 binding > > * I checked the diffs and did not find any added dependencies or updated > dependency versions. > * I checked the sha has

Re: [VOTE] Release 1.7.0, release candidate #3

2018-11-29 Thread Gary Yao
+1 (non-binding) I ran the Jepsen tests against the flink-1.7.0-bin-hadoop28-scala_2.12.tgz distribution. Best, Gary On Thu, Nov 29, 2018 at 5:51 PM Timo Walther wrote: > +1 > > - run `mvn clean verify` locally with success > - run a couple of end-to-end tests locally with success > > Found o

Re: [FLINK-6626] Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

2019-01-18 Thread Gary Yao
Hi Tarush, If nobody is assigned, you can assign yourself. Best, Gary On Fri, Jan 18, 2019 at 6:42 AM tarush grover wrote: > Hi Team, > > Anyone working on this jira ticket? > > Regards, > Tarush >

Re: flink runtime incompatibility with java 9 or above due to akka version

2019-01-24 Thread Gary Yao
Hi Matthieu, Flink is not Java 9 compatible at the moment [1]. Although Flink can be compiled with Java 9, not all tests are currently passing. For a list of modules that have failing tests, see [2]. The problem that you found persists in Akka versions prior to 2.5.6 [3][4]. Best, Gary [1] http

[PROGRESS-UPDATE] Redesign Flink Scheduling, introducing dedicated Scheduler Component

2019-04-12 Thread Gary Yao
Hi all, As you might have seen already, we are currently reworking Flink's scheduling. At the moment, scheduling is a concern that is scattered across different components, such as ExecutionGraph, Execution and SlotPool. Scheduling also happens only on the granularity of individual tasks, which ma

[DISCUSS] Temporarily remove support for job rescaling via CLI action "modify"

2019-04-23 Thread Gary Yao
Hi all, As the subject states, I am proposing to temporarily remove support for changing the parallelism of a job via the following syntax [1]: ./bin/flink modify [job-id] -p [new-parallelism] This is an experimental feature that we introduced with the first rollout of FLIP-6 (Flink 1.5). Ho

Re: [DISCUSS] Temporarily remove support for job rescaling via CLI action "modify"

2019-04-24 Thread Gary Yao
or now. Actually some users are not aware of that > it’s > > > still experimental, and ask quite a lot about the problem it causes. > > > > > > Best, > > > Paul Lam > > > > > > 在 2019年4月24日,14:49,Stephan Ewen 写道: > > > > > >

Re: [DISCUSS] Temporarily remove support for job rescaling via CLI action "modify"

2019-04-29 Thread Gary Yao
Since there were no objections so far, I will proceed with removing the code [1]. [1] https://issues.apache.org/jira/browse/FLINK-12312 On Wed, Apr 24, 2019 at 1:38 PM Gary Yao wrote: > The idea is to also remove the rescaling code in the JobMaster. This will > make > it easier to r

Re: aggregate stream of logs

2018-01-09 Thread Gary Yao
Hi, First of all, your question is more suited for the Flink user mailing list (this is the dev mailing list). I think you can use a GlobalWindow [1] with a custom trigger. A global window assigns all elements with the same key to the same window, and will not perform any computation unless trigg

Re: difference b/t filesystem and connector-filesystem

2018-01-18 Thread Gary Yao
Hi, to do that you can set the env variable HADOOP_CONF_DIR: https://ci.apache.org/projects/flink/flink-docs-master/ops/config.html#hdfs Best, Gary On Wed, Jan 17, 2018 at 2:27 AM, cw7k wrote: > Hi, question on this page: > "You need to point Flink to a valid Hadoop configuration..."https:

Re: Incorrect Rest URL

2018-03-08 Thread Gary Yao
Hi Minglei, What Flink version are you using? The path was only recently changed to /jobs/overview [1], and you linked to the documentation of the snapshot version. While I tested the feature, I discovered another bug in 1.5, though [2]. Best, Gary [1] https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-13145) Run HA dataset/datastream E2E test with new RestartPipelinedRegionStrategy

2019-07-08 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13145: Summary: Run HA dataset/datastream E2E test with new RestartPipelinedRegionStrategy Key: FLINK-13145 URL: https://issues.apache.org/jira/browse/FLINK-13145 Project: Flink

[jira] [Created] (FLINK-13193) Enable setting custom Flink config in test specs for Jepsen tests

2019-07-10 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13193: Summary: Enable setting custom Flink config in test specs for Jepsen tests Key: FLINK-13193 URL: https://issues.apache.org/jira/browse/FLINK-13193 Project: Flink

[jira] [Created] (FLINK-13222) Add documentation for AdaptedRestartPipelinedRegionStrategyNG

2019-07-11 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13222: Summary: Add documentation for AdaptedRestartPipelinedRegionStrategyNG Key: FLINK-13222 URL: https://issues.apache.org/jira/browse/FLINK-13222 Project: Flink Issue

[jira] [Created] (FLINK-13223) Set jobmanager.execution.failover-strategy to region in default flink-conf.yaml

2019-07-11 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13223: Summary: Set jobmanager.execution.failover-strategy to region in default flink-conf.yaml Key: FLINK-13223 URL: https://issues.apache.org/jira/browse/FLINK-13223 Project

[jira] [Created] (FLINK-13345) Dump jstack output for Flink JVMs after Jepsen Tests

2019-07-21 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13345: Summary: Dump jstack output for Flink JVMs after Jepsen Tests Key: FLINK-13345 URL: https://issues.apache.org/jira/browse/FLINK-13345 Project: Flink Issue Type: New

[jira] [Created] (FLINK-13452) Pipelined region failover strategy does not recover Job if checkpoint cannot be read

2019-07-28 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13452: Summary: Pipelined region failover strategy does not recover Job if checkpoint cannot be read Key: FLINK-13452 URL: https://issues.apache.org/jira/browse/FLINK-13452 Project

[jira] [Created] (FLINK-13508) CommonTestUtils#waitUntilCondition() may attempt to sleep with negative time

2019-07-31 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13508: Summary: CommonTestUtils#waitUntilCondition() may attempt to sleep with negative time Key: FLINK-13508 URL: https://issues.apache.org/jira/browse/FLINK-13508 Project: Flink

[jira] [Created] (FLINK-13585) Test TaskAsyncCallTest#testSetsUserCodeClassLoader() deadlocks

2019-08-05 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13585: Summary: Test TaskAsyncCallTest#testSetsUserCodeClassLoader() deadlocks Key: FLINK-13585 URL: https://issues.apache.org/jira/browse/FLINK-13585 Project: Flink

[jira] [Created] (FLINK-13953) Facilitate enabling new Scheduler in MiniCluster Tests

2019-09-04 Thread Gary Yao (Jira)
Gary Yao created FLINK-13953: Summary: Facilitate enabling new Scheduler in MiniCluster Tests Key: FLINK-13953 URL: https://issues.apache.org/jira/browse/FLINK-13953 Project: Flink Issue Type

[jira] [Created] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy

2019-09-10 Thread Gary Yao (Jira)
Gary Yao created FLINK-14045: Summary: Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy Key: FLINK-14045 URL: https://issues.apache.org/jira/browse/FLINK-14045 Project: Flink

[jira] [Created] (FLINK-15917) Root Exception not shown in Web UI

2020-02-05 Thread Gary Yao (Jira)
Gary Yao created FLINK-15917: Summary: Root Exception not shown in Web UI Key: FLINK-15917 URL: https://issues.apache.org/jira/browse/FLINK-15917 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15918) Uptime Metric not reset on Job Restart

2020-02-05 Thread Gary Yao (Jira)
Gary Yao created FLINK-15918: Summary: Uptime Metric not reset on Job Restart Key: FLINK-15918 URL: https://issues.apache.org/jira/browse/FLINK-15918 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15936) TaskExecutorTest#testSlotAcceptance deadlocks

2020-02-05 Thread Gary Yao (Jira)
Gary Yao created FLINK-15936: Summary: TaskExecutorTest#testSlotAcceptance deadlocks Key: FLINK-15936 URL: https://issues.apache.org/jira/browse/FLINK-15936 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15953) Job Status is hard to read for some Statuses

2020-02-07 Thread Gary Yao (Jira)
Gary Yao created FLINK-15953: Summary: Job Status is hard to read for some Statuses Key: FLINK-15953 URL: https://issues.apache.org/jira/browse/FLINK-15953 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16445) Raise japicmp.referenceVersion to 1.10.0

2020-03-05 Thread Gary Yao (Jira)
Gary Yao created FLINK-16445: Summary: Raise japicmp.referenceVersion to 1.10.0 Key: FLINK-16445 URL: https://issues.apache.org/jira/browse/FLINK-16445 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16590) flink-oss-fs-hadoop: Not all dependencies in NOTICE file are bundled

2020-03-13 Thread Gary Yao (Jira)
Gary Yao created FLINK-16590: Summary: flink-oss-fs-hadoop: Not all dependencies in NOTICE file are bundled Key: FLINK-16590 URL: https://issues.apache.org/jira/browse/FLINK-16590 Project: Flink

[jira] [Created] (FLINK-16710) Log Upload blocks Main Thread in TaskExecutor

2020-03-22 Thread Gary Yao (Jira)
Gary Yao created FLINK-16710: Summary: Log Upload blocks Main Thread in TaskExecutor Key: FLINK-16710 URL: https://issues.apache.org/jira/browse/FLINK-16710 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs

2020-03-23 Thread Gary Yao (Jira)
Gary Yao created FLINK-16718: Summary: KvStateServerHandlerTest leaks Netty ByteBufs Key: FLINK-16718 URL: https://issues.apache.org/jira/browse/FLINK-16718 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16939) TaskManagerMessageParameters#taskManagerIdParameter is not declared final

2020-04-02 Thread Gary Yao (Jira)
Gary Yao created FLINK-16939: Summary: TaskManagerMessageParameters#taskManagerIdParameter is not declared final Key: FLINK-16939 URL: https://issues.apache.org/jira/browse/FLINK-16939 Project: Flink

[jira] [Created] (FLINK-16940) Avoid creating currentRegion HashSet with manually set initialCapacity

2020-04-02 Thread Gary Yao (Jira)
Gary Yao created FLINK-16940: Summary: Avoid creating currentRegion HashSet with manually set initialCapacity Key: FLINK-16940 URL: https://issues.apache.org/jira/browse/FLINK-16940 Project: Flink

[jira] [Created] (FLINK-16960) Add PipelinedRegion Interface to Topology

2020-04-03 Thread Gary Yao (Jira)
Gary Yao created FLINK-16960: Summary: Add PipelinedRegion Interface to Topology Key: FLINK-16960 URL: https://issues.apache.org/jira/browse/FLINK-16960 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17035) Replace FailoverTopology with SchedulingTopology

2020-04-07 Thread Gary Yao (Jira)
Gary Yao created FLINK-17035: Summary: Replace FailoverTopology with SchedulingTopology Key: FLINK-17035 URL: https://issues.apache.org/jira/browse/FLINK-17035 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-17050) Remove methods getVertex() and getResultPartition() from SchedulingTopology

2020-04-08 Thread Gary Yao (Jira)
Gary Yao created FLINK-17050: Summary: Remove methods getVertex() and getResultPartition() from SchedulingTopology Key: FLINK-17050 URL: https://issues.apache.org/jira/browse/FLINK-17050 Project: Flink

[jira] [Created] (FLINK-17172) Re-enable debug level logging in Jepsen Tests

2020-04-15 Thread Gary Yao (Jira)
Gary Yao created FLINK-17172: Summary: Re-enable debug level logging in Jepsen Tests Key: FLINK-17172 URL: https://issues.apache.org/jira/browse/FLINK-17172 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17180) Implement PipelinedRegion interface for SchedulingTopology

2020-04-15 Thread Gary Yao (Jira)
Gary Yao created FLINK-17180: Summary: Implement PipelinedRegion interface for SchedulingTopology Key: FLINK-17180 URL: https://issues.apache.org/jira/browse/FLINK-17180 Project: Flink Issue

[jira] [Created] (FLINK-17181) Simplify generic Types in Topology Interface

2020-04-15 Thread Gary Yao (Jira)
Gary Yao created FLINK-17181: Summary: Simplify generic Types in Topology Interface Key: FLINK-17181 URL: https://issues.apache.org/jira/browse/FLINK-17181 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17266) WorkerResourceSpec is not serializable

2020-04-20 Thread Gary Yao (Jira)
Gary Yao created FLINK-17266: Summary: WorkerResourceSpec is not serializable Key: FLINK-17266 URL: https://issues.apache.org/jira/browse/FLINK-17266 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17369) Migrate RestartPipelinedRegionFailoverStrategyBuildingTest to PipelinedRegionComputeUtilTest

2020-04-24 Thread Gary Yao (Jira)
Gary Yao created FLINK-17369: Summary: Migrate RestartPipelinedRegionFailoverStrategyBuildingTest to PipelinedRegionComputeUtilTest Key: FLINK-17369 URL: https://issues.apache.org/jira/browse/FLINK-17369

[jira] [Created] (FLINK-14225) Travis is unable to parse of the secure environment variables

2019-09-26 Thread Gary Yao (Jira)
Gary Yao created FLINK-14225: Summary: Travis is unable to parse of the secure environment variables Key: FLINK-14225 URL: https://issues.apache.org/jira/browse/FLINK-14225 Project: Flink Issue

[jira] [Created] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

2019-09-26 Thread Gary Yao (Jira)
Gary Yao created FLINK-14226: Summary: Subset of nightly tests fail due to No output has been received in the last 10m0s Key: FLINK-14226 URL: https://issues.apache.org/jira/browse/FLINK-14226 Project

[jira] [Created] (FLINK-14244) Use correct RestartBackoffTimetrategy in new DefaultScheduler

2019-09-27 Thread Gary Yao (Jira)
Gary Yao created FLINK-14244: Summary: Use correct RestartBackoffTimetrategy in new DefaultScheduler Key: FLINK-14244 URL: https://issues.apache.org/jira/browse/FLINK-14244 Project: Flink Issue

[jira] [Created] (FLINK-14291) Add unit tests for DefaultScheduler to test concurrent failover behavior

2019-09-30 Thread Gary Yao (Jira)
Gary Yao created FLINK-14291: Summary: Add unit tests for DefaultScheduler to test concurrent failover behavior Key: FLINK-14291 URL: https://issues.apache.org/jira/browse/FLINK-14291 Project: Flink

[jira] [Created] (FLINK-14318) JDK11 build stalls during shading

2019-10-03 Thread Gary Yao (Jira)
Gary Yao created FLINK-14318: Summary: JDK11 build stalls during shading Key: FLINK-14318 URL: https://issues.apache.org/jira/browse/FLINK-14318 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14389) Restore task state in new DefaultScheduler

2019-10-14 Thread Gary Yao (Jira)
Gary Yao created FLINK-14389: Summary: Restore task state in new DefaultScheduler Key: FLINK-14389 URL: https://issues.apache.org/jira/browse/FLINK-14389 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14555) Streaming File Sink s3 end-to-end test stalls

2019-10-29 Thread Gary Yao (Jira)
Gary Yao created FLINK-14555: Summary: Streaming File Sink s3 end-to-end test stalls Key: FLINK-14555 URL: https://issues.apache.org/jira/browse/FLINK-14555 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-10-30 Thread Gary Yao (Jira)
Gary Yao created FLINK-14572: Summary: BlobsCleanupITCase failed in Travis stage core - scheduler_ng Key: FLINK-14572 URL: https://issues.apache.org/jira/browse/FLINK-14572 Project: Flink Issue

[jira] [Created] (FLINK-14576) Elasticsearch (v6.3.1) sink end-to-end test instable

2019-10-30 Thread Gary Yao (Jira)
Gary Yao created FLINK-14576: Summary: Elasticsearch (v6.3.1) sink end-to-end test instable Key: FLINK-14576 URL: https://issues.apache.org/jira/browse/FLINK-14576 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14587) HiveTableSourceTest timeouts on Travis

2019-10-31 Thread Gary Yao (Jira)
Gary Yao created FLINK-14587: Summary: HiveTableSourceTest timeouts on Travis Key: FLINK-14587 URL: https://issues.apache.org/jira/browse/FLINK-14587 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

2019-11-01 Thread Gary Yao (Jira)
Gary Yao created FLINK-14592: Summary: FlinkKafkaInternalProducerITCase fails with BindException Key: FLINK-14592 URL: https://issues.apache.org/jira/browse/FLINK-14592 Project: Flink Issue

[jira] [Created] (FLINK-14628) Wordcount on Docker test (custom fs plugin) fails on Travis

2019-11-06 Thread Gary Yao (Jira)
Gary Yao created FLINK-14628: Summary: Wordcount on Docker test (custom fs plugin) fails on Travis Key: FLINK-14628 URL: https://issues.apache.org/jira/browse/FLINK-14628 Project: Flink Issue

[jira] [Created] (FLINK-14632) ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks

2019-11-06 Thread Gary Yao (Jira)
Gary Yao created FLINK-14632: Summary: ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks Key: FLINK-14632 URL: https://issues.apache.org/jira/browse/FLINK-14632 Project

[jira] [Created] (FLINK-14636) Handle schedule mode LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST correctly in DefaultScheduler

2019-11-06 Thread Gary Yao (Jira)
Gary Yao created FLINK-14636: Summary: Handle schedule mode LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST correctly in DefaultScheduler Key: FLINK-14636 URL: https://issues.apache.org/jira/browse/FLINK-14636

[jira] [Created] (FLINK-14651) Set default value of config option jobmanager.scheduler to "ng"

2019-11-07 Thread Gary Yao (Jira)
Gary Yao created FLINK-14651: Summary: Set default value of config option jobmanager.scheduler to "ng" Key: FLINK-14651 URL: https://issues.apache.org/jira/browse/FLINK-14651 Proj

  1   2   3   >