[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
Ted Yu created FLINK-4436:
-
Summary: Unclosed DataOutputBuffer in Utils#setTokensFor()
Key: FLINK-4436
URL: https://issues.apache.org/jira/browse/FLINK-4436
Project: Flink
Issue Type: Bug
Ted Yu created FLINK-4437:
-
Summary: Lock evasion around lastTriggeredCheckpoint may lead to
lost updates to related fields
Key: FLINK-4437
URL: https://issues.apache.org/jira/browse/FLINK-4437
Project: Flink
Ted Yu created FLINK-4482:
-
Summary: numUnsuccessfulCheckpointsTriggers is accessed without
holding triggerLock
Key: FLINK-4482
URL: https://issues.apache.org/jira/browse/FLINK-4482
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reopened FLINK-4437:
---
Assignee: Ted Yu
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4437.
---
Resolution: Fixed
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4437.
---
Resolution: Fixed
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reopened FLINK-4437:
---
Assignee: (was: Ted Yu)
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> rel
Ted Yu created FLINK-4499:
-
Summary: Introduce findbugs maven plugin
Key: FLINK-4499
URL: https://issues.apache.org/jira/browse/FLINK-4499
Project: Flink
Issue Type: Improvement
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4436:
--
Description:
{code}
DataOutputBuffer dob = new DataOutputBuffer();
credentials.writeTokenStorageToStream
Ted Yu created FLINK-4531:
-
Summary: Thread.stop() is deprecated
Key: FLINK-4531
URL: https://issues.apache.org/jira/browse/FLINK-4531
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15448674#comment-15448674
]
Ted Yu commented on FLINK-4482:
---
[~StephanEwen]:
Can you take a look at the PR ?
> numUnsuc
Ted Yu created FLINK-4533:
-
Summary: Unprotected access to meters in StatsDReporter#report()
Key: FLINK-4533
URL: https://issues.apache.org/jira/browse/FLINK-4533
Project: Flink
Issue Type: Bug
Ted Yu created FLINK-4534:
-
Summary: Lack of synchronization in BucketingSink#restoreState()
w.r.t. state.bucketStates
Key: FLINK-4534
URL: https://issues.apache.org/jira/browse/FLINK-4534
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Summary: Lack of synchronization in BucketingSink#restoreState() (was:
Lack of synchronization in BucketingSink
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459062#comment-15459062
]
Ted Yu commented on FLINK-4482:
---
[~StephanEwen]:
All checks passed.
Should be ready to go.
Ted Yu created FLINK-4573:
-
Summary: Potential resource leak due to unclosed RandomAccessFile
in TaskManagerLogHandler#
Key: FLINK-4573
URL: https://issues.apache.org/jira/browse/FLINK-4573
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Summary: Potential resource leak due to unclosed RandomAccessFile in
TaskManagerLogHandler (was: Potential reso
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459062#comment-15459062
]
Ted Yu edited comment on FLINK-4482 at 9/6/16 12:23 AM:
[~StephanE
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4533:
--
Description:
Access to meters in AbstractReporter is protected by AbstractReporter.this.
Access to meters in S
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently y
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4482:
--
Description:
In CheckpointCoordinator#stopCheckpointScheduler() :
{code}
synchronized (lock) {
...
num
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Description:
{code}
try {
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4533:
--
Description:
Access to meters in AbstractReporter is protected by AbstractReporter.this.
Access to meters in St
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop
Ted Yu created FLINK-4626:
-
Summary: Missing break in MetricStore#add()
Key: FLINK-4626
URL: https://issues.apache.org/jira/browse/FLINK-4626
Project: Flink
Issue Type: Bug
Reporter: Ted
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4482:
--
Description:
In CheckpointCoordinator#stopCheckpointScheduler() :
{code}
synchronized (lock) {
...
num
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4499:
--
Description:
As suggested by Stephan in FLINK-4482, this issue is to add
findbugs-maven-plugin into the build p
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4533:
--
Description:
Access to meters in AbstractReporter is protected by AbstractReporter.this.
Access to meters in S
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Description:
{code}
try {
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently y
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506583#comment-15506583
]
Ted Yu commented on FLINK-4534:
---
Feel free to work on this.
> Lack of synchronization in Bu
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506581#comment-15506581
]
Ted Yu commented on FLINK-3222:
---
Feel free to work on this.
> Incorrect shift amount in Ope
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506585#comment-15506585
]
Ted Yu commented on FLINK-3734:
---
Feel free to work on this.
> Unclosed DataInputView in
>
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506596#comment-15506596
]
Ted Yu commented on FLINK-4533:
---
Adding a comment in code to the above effect would be nice.
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506590#comment-15506590
]
Ted Yu commented on FLINK-4573:
---
Feel free to work on this.
> Potential resource leak due t
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4533.
---
Resolution: Won't Fix
> Unprotected access to meters in StatsDReporter#report()
>
Ted Yu created FLINK-4659:
-
Summary: Potential resource leak due to unclosed InputStream in
SecurityContext#populateSystemSecurityProperties()
Key: FLINK-4659
URL: https://issues.apache.org/jira/browse/FLINK-4659
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4482:
--
Description:
In CheckpointCoordinator#stopCheckpointScheduler() :
{code}
synchronized (lock) {
...
num
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5855:
--
Description:
{code}
handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDur
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 3/13/17 1:13 AM:
There is s
Ted Yu created FLINK-6052:
-
Summary: Potential null access in
ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()
Key: FLINK-6052
URL: https://issues.apache.org/jira/browse/FLINK-6052
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5987:
--
Description:
zookeeper 3.4.8 has been released.
Among the fixes the following are desirable:
ZOOKEEPER-706 lar
Ted Yu created FLINK-6079:
-
Summary: Ineffective null check in FlinkKafkaConsumerBase#open()
Key: FLINK-6079
URL: https://issues.apache.org/jira/browse/FLINK-6079
Project: Flink
Issue Type: Bug
Ted Yu created FLINK-6080:
-
Summary: Unclosed ObjectOutputStream in NFA#serialize()
Key: FLINK-6080
URL: https://issues.apache.org/jira/browse/FLINK-6080
Project: Flink
Issue Type: Bug
Re
Ted Yu created FLINK-6104:
-
Summary: Unclosed WriteOptions in
ListViaRangeSpeedMiniBenchmark#main()
Key: FLINK-6104
URL: https://issues.apache.org/jira/browse/FLINK-6104
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6104:
--
Summary: Resource leak in ListViaRangeSpeedMiniBenchmark (was: Unclosed
WriteOptions in ListViaRangeSpeedMiniBe
[
https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6104:
--
Description:
{code}
final WriteOptions write_options = new WriteOptions()
.setSync(false)
.s
Ted Yu created FLINK-6105:
-
Summary: Properly handle InterruptedException
Key: FLINK-6105
URL: https://issues.apache.org/jira/browse/FLINK-6105
Project: Flink
Issue Type: Bug
Reporter: Te
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5855:
--
Description:
{code}
handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854366#comment-15854366
]
Ted Yu edited comment on FLINK-5629 at 3/17/17 5:01 PM:
RandomAcce
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/17/17 5:19 PM:
Lock on St
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5943:
--
Description:
{code}
protected void shutdown(ApplicationStatus status, String msg) {
// Need to clear the j
[
https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6052:
--
Description:
{code}
Tuple2, String>
checkpointStateHandle = checkpointStateHandles.peekLast();
Ted Yu created FLINK-6130:
-
Summary: Consider calling resourceManager#getTerminationFuture()
with lock held
Key: FLINK-6130
URL: https://issues.apache.org/jira/browse/FLINK-6130
Project: Flink
Issue
Ted Yu created FLINK-6143:
-
Summary: Unprotected access to this.flink in
LocalExecutor#endSession()
Key: FLINK-6143
URL: https://issues.apache.org/jira/browse/FLINK-6143
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 3/22/17 1:54 AM:
There is s
Ted Yu created FLINK-6169:
-
Summary: yarnClient should be stopped in
AbstractYarnClusterDescriptor in case of error
Key: FLINK-6169
URL: https://issues.apache.org/jira/browse/FLINK-6169
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937299#comment-15937299
]
Ted Yu commented on FLINK-6172:
---
Similar problem exists in StaticFileServerHandler.java
> P
Ted Yu created FLINK-6172:
-
Summary: Potentially unclosed RandomAccessFile in
HistoryServerStaticFileServerHandler
Key: FLINK-6172
URL: https://issues.apache.org/jira/browse/FLINK-6172
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938379#comment-15938379
]
Ted Yu commented on FLINK-6172:
---
RandomAccessFile#length() may throw IOE.
DefaultFileRegion
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938867#comment-15938867
]
Ted Yu commented on FLINK-4499:
---
Running this nightly is fine.
> Introduce findbugs maven p
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDu
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/27/17 12:52 AM:
-
Lock on
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5943:
--
Description:
{code}
protected void shutdown(ApplicationStatus status, String msg) {
// Need to clear the j
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854366#comment-15854366
]
Ted Yu edited comment on FLINK-5629 at 3/27/17 12:51 AM:
-
RandomAc
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG.
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942518#comment-15942518
]
Ted Yu commented on FLINK-5987:
---
Actually 3.4.10 is being voted on.
We can upgrade to 3.4.1
[
https://issues.apache.org/jira/browse/FLINK-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-6169.
---
Resolution: Not A Problem
> yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error
> -
Ted Yu created FLINK-6210:
-
Summary: RocksDB instance should be closed in
ListViaMergeSpeedMiniBenchmark
Key: FLINK-6210
URL: https://issues.apache.org/jira/browse/FLINK-6210
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6210:
--
Description:
rocksDB instance should be closed upon returning from main().
ListViaRangeSpeedMiniBenchmark has
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6143:
--
Description:
{code}
public void endSession(JobID jobID) throws Exception {
LocalFlinkMiniCluster flink = t
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6172:
--
Description:
{code}
try {
raf = new RandomAccessFile(file, "r");
} catch (FileNotFoundException e)
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938867#comment-15938867
]
Ted Yu edited comment on FLINK-4499 at 4/3/17 1:51 AM:
---
Running this
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 4/3/17 1:52 AM:
---
Lock on Stat
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDur
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 4/3/17 1:52 AM:
---
There is sim
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942518#comment-15942518
]
Ted Yu edited comment on FLINK-5987 at 4/4/17 3:17 PM:
---
We can upgra
1 - 100 of 1097 matches
Mail list logo
