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
+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
+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
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
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
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:
&
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],
*
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
>
: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
> >
> > > > > > 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]
> > > > > >
> > > > > >
>
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],
*
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
+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
>
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
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
+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
+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
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
+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
ze Guo 于2020年3月27日周五 下午4:49写道:
> > > > >
> > > > > > Thanks for updating!
> > > > > >
> > > > > > +1 for supporting the pipelined region scheduling. Although we
> > could
> > > > > > not prev
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
; +1 (binding)
> > > > >
> > > > > Best,
> > > > > Zhijiang
> > > > >
> > > > >
> > > > > --
> > > > > From:Till Rohrmann
> &
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
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
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
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
+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
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
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
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
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
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
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],
*
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
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
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
+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
+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
+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
-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
-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
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_
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
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
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
+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
> [
+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
+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
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
>
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
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
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
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 写道:
> > >
> > >
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
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
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:
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
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
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
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
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
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
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
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
Gary Yao created FLINK-13585:
Summary: Test TaskAsyncCallTest#testSetsUserCodeClassLoader()
deadlocks
Key: FLINK-13585
URL: https://issues.apache.org/jira/browse/FLINK-13585
Project: Flink
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Gary Yao created FLINK-17369:
Summary: Migrate
RestartPipelinedRegionFailoverStrategyBuildingTest to
PipelinedRegionComputeUtilTest
Key: FLINK-17369
URL: https://issues.apache.org/jira/browse/FLINK-17369
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
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
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
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
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
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
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
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
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
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
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
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
Gary Yao created FLINK-14632:
Summary:
ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks
Key: FLINK-14632
URL: https://issues.apache.org/jira/browse/FLINK-14632
Project
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
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 - 100 of 244 matches
Mail list logo