Gary Yao created FLINK-17794:
Summary: Tear down installed software in reverse order in Jepsen
Tests
Key: FLINK-17794
URL: https://issues.apache.org/jira/browse/FLINK-17794
Project: Flink
Issue
Gary Yao created FLINK-17792:
Summary: Failing to invoking jstack on TM processes should not
fail Jepsen Tests
Key: FLINK-17792
URL: https://issues.apache.org/jira/browse/FLINK-17792
Project: Flink
Gary Yao created FLINK-1:
Summary: Make Mesos Jepsen Tests pass with Hadoop-free Flink
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Project: Flink
Issue Type: Bug
Gary Yao created FLINK-17687:
Summary: Collect TaskManager logs in Mesos Jepsen Tests
Key: FLINK-17687
URL: https://issues.apache.org/jira/browse/FLINK-17687
Project: Flink
Issue Type
Gary Yao created FLINK-17621:
Summary: Use default akka.ask.timeout in TPC-DS e2e test
Key: FLINK-17621
URL: https://issues.apache.org/jira/browse/FLINK-17621
Project: Flink
Issue Type: Task
Gary Yao created FLINK-17616:
Summary: Temporarily increase akka.ask.timeout in TPC-DS e2e test
Key: FLINK-17616
URL: https://issues.apache.org/jira/browse/FLINK-17616
Project: Flink
Issue Type
Gary Yao created FLINK-17558:
Summary: Partitions are released in TaskExecutor Main Thread
Key: FLINK-17558
URL: https://issues.apache.org/jira/browse/FLINK-17558
Project: Flink
Issue Type: Bug
Gary Yao created FLINK-17522:
Summary: Document flink-jepsen Command Line Options
Key: FLINK-17522
URL: https://issues.apache.org/jira/browse/FLINK-17522
Project: Flink
Issue Type: Improvement
Gary Yao created FLINK-17501:
Summary: Improve logging in
AbstractServerHandler#channelRead(ChannelHandlerContext, Object)
Key: FLINK-17501
URL: https://issues.apache.org/jira/browse/FLINK-17501
Project
Gary Yao created FLINK-17473:
Summary: Remove unused classes ArchivedExecutionVertexBuilder and
ArchivedExecutionJobVertexBuilder
Key: FLINK-17473
URL: https://issues.apache.org/jira/browse/FLINK-17473
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-17266:
Summary: WorkerResourceSpec is not serializable
Key: FLINK-17266
URL: https://issues.apache.org/jira/browse/FLINK-17266
Project: Flink
Issue Type: Bug
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
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-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-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-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-17035:
Summary: Replace FailoverTopology with SchedulingTopology
Key: FLINK-17035
URL: https://issues.apache.org/jira/browse/FLINK-17035
Project: Flink
Issue Type: Sub
; +1 (binding)
> > > > >
> > > > > Best,
> > > > > Zhijiang
> > > > >
> > > > >
> > > > > --
> > > > > From:Till Rohrmann
> &
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-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-16939:
Summary: TaskManagerMessageParameters#taskManagerIdParameter is
not declared final
Key: FLINK-16939
URL: https://issues.apache.org/jira/browse/FLINK-16939
Project: Flink
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
ze Guo 于2020年3月27日周五 下午4:49写道：
> > > > >
> > > > > > Thanks for updating!
> > > > > >
> > > > > > +1 for supporting the pipelined region scheduling. Although we
> > could
> > > > > > not prev
+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
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 (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
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-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-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-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
+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
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
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
+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
>
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
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],
*
> >
> > > > > > 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]
> > > > > >
> > > > > >
>
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-15936:
Summary: TaskExecutorTest#testSlotAcceptance deadlocks
Key: FLINK-15936
URL: https://issues.apache.org/jira/browse/FLINK-15936
Project: Flink
Issue Type: Bug
: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
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
>
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],
*
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:
&
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-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
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
Gary Yao created FLINK-15900:
Summary: JoinITCase#testRightJoinWithPk failed on Travis
Key: FLINK-15900
URL: https://issues.apache.org/jira/browse/FLINK-15900
Project: Flink
Issue Type: Bug
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
Gary Yao created FLINK-15781:
Summary: Manual Smoke Test with Batch Job
Key: FLINK-15781
URL: https://issues.apache.org/jira/browse/FLINK-15781
Project: Flink
Issue Type: Task
Affects
Gary Yao created FLINK-15780:
Summary: Manual Smoke Test of Native Kubernetes Integration
Key: FLINK-15780
URL: https://issues.apache.org/jira/browse/FLINK-15780
Project: Flink
Issue Type: Task
Gary Yao created FLINK-15779:
Summary: Manual Smoke Test of Python API
Key: FLINK-15779
URL: https://issues.apache.org/jira/browse/FLINK-15779
Project: Flink
Issue Type: Task
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],
*
Gary Yao created FLINK-15754:
Summary: Remove config options table.exec.resource.*memory from
Documentation
Key: FLINK-15754
URL: https://issues.apache.org/jira/browse/FLINK-15754
Project: Flink
Gary Yao created FLINK-15751:
Summary: RocksDB Memory Management end-to-end test fails
Key: FLINK-15751
URL: https://issues.apache.org/jira/browse/FLINK-15751
Project: Flink
Issue Type: Task
Gary Yao created FLINK-15743:
Summary: Add Flink 1.10 release notes to documentation
Key: FLINK-15743
URL: https://issues.apache.org/jira/browse/FLINK-15743
Project: Flink
Issue Type: Task
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
Gary Yao created FLINK-15638:
Summary: releasing/create_release_branch.sh does not set version
in flink-python/pyflink/version.py
Key: FLINK-15638
URL: https://issues.apache.org/jira/browse/FLINK-15638
Gary Yao created FLINK-15623:
Summary: Buildling flink-python with maven profile docs-and-source
fails
Key: FLINK-15623
URL: https://issues.apache.org/jira/browse/FLINK-15623
Project: Flink
Gary Yao created FLINK-15317:
Summary: State TTL Heap backend end-to-end test fails on Travis
Key: FLINK-15317
URL: https://issues.apache.org/jira/browse/FLINK-15317
Project: Flink
Issue Type
Gary Yao created FLINK-15316:
Summary: SQL Client end-to-end test (Old planner) failed on Travis
Key: FLINK-15316
URL: https://issues.apache.org/jira/browse/FLINK-15316
Project: Flink
Issue Type
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
Gary Yao created FLINK-15285:
Summary: Resuming Externalized Checkpoint (file, async, no
parallelism change) E2E test fails on Travis
Key: FLINK-15285
URL: https://issues.apache.org/jira/browse/FLINK-15285
Gary Yao created FLINK-15247:
Summary: Closing (Testing)MiniCluster may cause
ConcurrentModificationException
Key: FLINK-15247
URL: https://issues.apache.org/jira/browse/FLINK-15247
Project: Flink
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
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
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
Gary Yao created FLINK-15163:
Summary: japicmp should use 1.9 as the old version
Key: FLINK-15163
URL: https://issues.apache.org/jira/browse/FLINK-15163
Project: Flink
Issue Type: Bug
Gary Yao created FLINK-15082:
Summary: Mesos App Master does not respect
taskmanager.memory.total-process.size
Key: FLINK-15082
URL: https://issues.apache.org/jira/browse/FLINK-15082
Project: Flink
Gary Yao created FLINK-15058:
Summary: Log required config keys if TaskManager memory
configuration is invalid
Key: FLINK-15058
URL: https://issues.apache.org/jira/browse/FLINK-15058
Project: Flink
Gary Yao created FLINK-15057:
Summary: Set taskmanager.memory.total-process.size in jepsen tests
Key: FLINK-15057
URL: https://issues.apache.org/jira/browse/FLINK-15057
Project: Flink
Issue Type
Gary Yao created FLINK-15045:
Summary: SchedulerBase should only log the RestartStrategy in
legacy scheduling mode
Key: FLINK-15045
URL: https://issues.apache.org/jira/browse/FLINK-15045
Project: Flink
Gary Yao created FLINK-15008:
Summary: Tests in flink-yarn-tests fail with
ClassNotFoundException (JDK11)
Key: FLINK-15008
URL: https://issues.apache.org/jira/browse/FLINK-15008
Project: Flink
Gary Yao created FLINK-14940:
Summary: Travis build passes despite Test failures
Key: FLINK-14940
URL: https://issues.apache.org/jira/browse/FLINK-14940
Project: Flink
Issue Type: Bug
Gary Yao created FLINK-14939:
Summary: StreamingKafkaITCase fails due to distDir property not
being set
Key: FLINK-14939
URL: https://issues.apache.org/jira/browse/FLINK-14939
Project: Flink
Gary Yao created FLINK-14929:
Summary: ContinuousFileProcessingCheckpointITCase sporadically
fails due to FileNotFoundException
Key: FLINK-14929
URL: https://issues.apache.org/jira/browse/FLINK-14929
+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
Gary Yao created FLINK-14894:
Summary: HybridOffHeapUnsafeMemorySegmentTest#testByteBufferWrap
failed on Travis
Key: FLINK-14894
URL: https://issues.apache.org/jira/browse/FLINK-14894
Project: Flink
Gary Yao created FLINK-14859:
Summary: Avoid leaking unassigned Slot in DefaultScheduler when
Deployment is outdated
Key: FLINK-14859
URL: https://issues.apache.org/jira/browse/FLINK-14859
Project: Flink
Gary Yao created FLINK-14843:
Summary: Streaming bucketing end-to-end test can fail with Output
hash mismatch
Key: FLINK-14843
URL: https://issues.apache.org/jira/browse/FLINK-14843
Project: Flink
Gary Yao created FLINK-14834:
Summary: Running Kerberized YARN on Docker test (custom fs plugin)
fails on Travis
Key: FLINK-14834
URL: https://issues.apache.org/jira/browse/FLINK-14834
Project: Flink
Gary Yao created FLINK-14826:
Summary: Enable 'Streaming bucketing end-to-end test' to pass with
new DefaultScheduler
Key: FLINK-14826
URL: https://issues.apache.org/jira/browse/FLINK-14826
Gary Yao created FLINK-14823:
Summary: Enable 'Streaming bucketing end-to-end test' to pass with
new DefaultScheduler
Key: FLINK-14823
URL: https://issues.apache.org/jira/browse/FLINK-14823
Gary Yao created FLINK-14822:
Summary: Enable 'Streaming File Sink end-to-end test' to pass with
new DefaultScheduler
Key: FLINK-14822
URL: https://issues.apache.org/jira/browse/FLINK-14822
Gary Yao created FLINK-14821:
Summary: Enable 'Queryable state (rocksdb) with TM restart' E2E
test to pass with new DefaultScheduler
Key: FLINK-14821
URL: https://issues.apache.org/jira/browse/F
Gary Yao created FLINK-14809:
Summary: DataStreamAllroundTestProgram does not run because return
types cannot be determined
Key: FLINK-14809
URL: https://issues.apache.org/jira/browse/FLINK-14809
Project
Gary Yao created FLINK-14780:
Summary: Avoid leaking instance of DefaultScheduler before object
is constructed
Key: FLINK-14780
URL: https://issues.apache.org/jira/browse/FLINK-14780
Project: Flink
Gary Yao created FLINK-14682:
Summary: Enable AbstractTaskManagerProcessFailureRecoveryTest to
pass with new DefaultScheduler
Key: FLINK-14682
URL: https://issues.apache.org/jira/browse/FLINK-14682
Gary Yao created FLINK-14681:
Summary: Enable YARNHighAvailabilityITCase to pass with new
DefaultScheduler
Key: FLINK-14681
URL: https://issues.apache.org/jira/browse/FLINK-14681
Project: Flink
Gary Yao created FLINK-14680:
Summary: Enable KafkaConsumerTestBase#runFailOnNoBrokerTest to
pass with new DefaultScheduler
Key: FLINK-14680
URL: https://issues.apache.org/jira/browse/FLINK-14680
Project
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
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-14632:
Summary:
ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks
Key: FLINK-14632
URL: https://issues.apache.org/jira/browse/FLINK-14632
Project
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
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
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-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-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-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-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
1 - 100 of 244 matches
Mail list logo
