[jira] [Created] (FLINK-17823) Resolve the race condition while releasing RemoteInputChannel

Zhijiang created FLINK-17823: Summary: Resolve the race condition while releasing RemoteInputChannel Key: FLINK-17823 URL: https://issues.apache.org/jira/browse/FLINK-17823 Project: Flink Issue

[jira] [Commented] (FLINK-17015) Fix NPE from NullAwareMapIterator

[ https://issues.apache.org/jira/browse/FLINK-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110787#comment-17110787 ] Zhijiang commented on FLINK-17015: -- If I understand correctly, FLINK-17610 can also be

[jira] [Assigned] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17768: Assignee: Zhijiang (was: Piotr Nowojski) > UnalignedCheckpointITCase.shouldPerformUnalignedCheck

[jira] [Closed] (FLINK-17739) ResultPartitionTest.testInitializeMoreStateThanBuffer is unstable

[ https://issues.apache.org/jira/browse/FLINK-17739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17739. Resolution: Fixed Merged in master: 7796f6e9601cdec3e1377acbfa212e6cfb36f793 > ResultPartitionTest.testIn

[jira] [Assigned] (FLINK-17739) ResultPartitionTest.testInitializeMoreStateThanBuffer is unstable

[ https://issues.apache.org/jira/browse/FLINK-17739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17739: Assignee: Zhijiang > ResultPartitionTest.testInitializeMoreStateThanBuffer is unstable >

[jira] [Created] (FLINK-17719) Provide ChannelStateReader#hasStates for hints of reading channel states

Zhijiang created FLINK-17719: Summary: Provide ChannelStateReader#hasStates for hints of reading channel states Key: FLINK-17719 URL: https://issues.apache.org/jira/browse/FLINK-17719 Project: Flink

[jira] [Closed] (FLINK-17665) Serialize DataType of Buffer into BufferResponse

[ https://issues.apache.org/jira/browse/FLINK-17665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17665. Resolution: Fixed Merged in master: 3bb18bb2122147162fbd05f3636255b6e5736906 > Serialize DataType of Buff

[jira] [Assigned] (FLINK-17665) Serialize DataType of Buffer into BufferResponse

[ https://issues.apache.org/jira/browse/FLINK-17665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17665: Assignee: Yingjie Cao > Serialize DataType of Buffer into BufferResponse > --

[jira] [Updated] (FLINK-17665) Serialize DataType of Buffer into BufferResponse

[ https://issues.apache.org/jira/browse/FLINK-17665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17665: - Issue Type: Task (was: Improvement) > Serialize DataType of Buffer into BufferResponse > --

[jira] [Closed] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17636. Resolution: Fixed Merged in master: c781d170e319d4617afc14aba716697ae0d517f0 > SingleInputGateTest.testCo

[jira] [Closed] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17640. Resolution: Fixed Merged in master: 3771835ac76822f4d5eefba8a7ea0afbe9057f4e > RecoveredInputChannelTest.

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106801#comment-17106801 ] Zhijiang commented on FLINK-16383: -- Another instance  [https://dev.azure.com/apache-fli

[jira] [Assigned] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17636: Assignee: Zhijiang > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to rea

[jira] [Assigned] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17640: Assignee: Zhijiang > RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() fail

[jira] [Commented] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105899#comment-17105899 ] Zhijiang commented on FLINK-17640: -- The purpose of this test is for guaranteeing no dea

[jira] [Closed] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16536. Resolution: Fixed Merged in master: d7525baf093035c9b0fe125602814833388d1973 > Implement InputChannel sta

[jira] [Assigned] (FLINK-17568) Task may consume data after checkpoint barrier before performing checkpoint for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17568: Assignee: Yingjie Cao > Task may consume data after checkpoint barrier before performing checkpoi

[jira] [Assigned] (FLINK-17564) Inflight data of incoming channel may be disordered for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17564: Assignee: Yingjie Cao > Inflight data of incoming channel may be disordered for unaligned checkpo

[jira] [Closed] (FLINK-17440) Potential Buffer leak in output unspilling for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17440. Resolution: Fixed Merged into master: 72f528d0cda2f51c5c71395ad619d49009af2f77 > Potential Buffer leak in

[jira] [Assigned] (FLINK-17440) Potential Buffer leak in output unspilling for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17440: Assignee: Zhijiang > Potential Buffer leak in output unspilling for unaligned checkpoints > -

[jira] [Updated] (FLINK-17413) Refactor the usages of ThreadSafeUnaligner#storeNewBuffers

[ https://issues.apache.org/jira/browse/FLINK-17413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17413: - Description: In current ThreadSafeUnaligner, the variable `storeNewBuffers` has actually two usages. On

[jira] [Updated] (FLINK-17413) Refactor the usages of ThreadSafeUnaligner#storeNewBuffers

[ https://issues.apache.org/jira/browse/FLINK-17413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17413: - Summary: Refactor the usages of ThreadSafeUnaligner#storeNewBuffers (was: Remove redundant states from

[jira] [Created] (FLINK-17413) Remove redundant states from ThreadSafeUnaligner

Zhijiang created FLINK-17413: Summary: Remove redundant states from ThreadSafeUnaligner Key: FLINK-17413 URL: https://issues.apache.org/jira/browse/FLINK-17413 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16404. Release Note: Note that the metric of `lastCheckpointAlignmentBuffered` has been removed in this ticket, b

[jira] [Commented] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

[ https://issues.apache.org/jira/browse/FLINK-17389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092601#comment-17092601 ] Zhijiang commented on FLINK-17389: -- Another instance [https://travis-ci.org/github/apac

[jira] [Commented] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

[ https://issues.apache.org/jira/browse/FLINK-17389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092600#comment-17092600 ] Zhijiang commented on FLINK-17389: -- Another instance in release-1.10  [https://api.trav

[jira] [Updated] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

[ https://issues.apache.org/jira/browse/FLINK-17389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17389: - Priority: Critical (was: Major) > LocalExecutorITCase.testBatchQueryCancel asserts error >

[jira] [Updated] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

[ https://issues.apache.org/jira/browse/FLINK-17389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17389: - Description: Executed in release-1.10 CI [https://api.travis-ci.org/v3/job/679144612/log.txt] {code:jav

[jira] [Created] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

Zhijiang created FLINK-17389: Summary: LocalExecutorITCase.testBatchQueryCancel asserts error Key: FLINK-17389 URL: https://issues.apache.org/jira/browse/FLINK-17389 Project: Flink Issue Type: Bu

[jira] [Assigned] (FLINK-17344) RecordWriterTest.testIdleTime possibly deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-17344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17344: Assignee: Wenlong Lyu (was: Wenlong Li) > RecordWriterTest.testIdleTime possibly deadlocks on Tr

[jira] [Assigned] (FLINK-17344) RecordWriterTest.testIdleTime possibly deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-17344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17344: Assignee: Wenlong Li > RecordWriterTest.testIdleTime possibly deadlocks on Travis > -

[jira] [Closed] (FLINK-17323) ChannelStateReader rejects requests about unkown channels (Unaligned checkpoints)

[ https://issues.apache.org/jira/browse/FLINK-17323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17323. Resolution: Fixed Merged in master: 07667d29181be2cd4281d36c8cdfbd9a6c4e704a > ChannelStateReader rejects

[jira] [Commented] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089545#comment-17089545 ] Zhijiang commented on FLINK-17182: -- After confirming with [~gaoyunhaii] offline, it has

[jira] [Created] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

Zhijiang created FLINK-17315: Summary: UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout Key: FLINK-17315 URL: https://issues.apache.org/jira/browse/FLINK-17315

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089263#comment-17089263 ] Zhijiang commented on FLINK-17274: -- Another instance  [https://dev.azure.com/apache-fli

[jira] [Updated] (FLINK-17299) Add checkpoint with remote channel benchmark

[ https://issues.apache.org/jira/browse/FLINK-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17299: - Summary: Add checkpoint with remote channel benchmark (was: Add remote channel throughput benchmark) >

[jira] [Assigned] (FLINK-17299) Add remote channel throughput benchmark

[ https://issues.apache.org/jira/browse/FLINK-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17299: Assignee: Yingjie Cao > Add remote channel throughput benchmark > ---

[jira] [Assigned] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17208: Assignee: Yingjie Cao > Reduce redundant data available notification of PipelinedSubpartition > -

[jira] [Assigned] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17182: Assignee: Yun Gao > RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[jira] [Commented] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084620#comment-17084620 ] Zhijiang commented on FLINK-17182: -- Thanks for reporting this [~dwysakowicz], I have as

[jira] [Assigned] (FLINK-17107) CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode()

[ https://issues.apache.org/jira/browse/FLINK-17107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17107: Assignee: Yingjie Cao > CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17081840#comment-17081840 ] Zhijiang commented on FLINK-16921: -- Another instance for this test failure, but not giv

[jira] [Created] (FLINK-17095) KafkaProducerExactlyOnceITCase fails with "address already in use"

Zhijiang created FLINK-17095: Summary: KafkaProducerExactlyOnceITCase fails with "address already in use" Key: FLINK-17095 URL: https://issues.apache.org/jira/browse/FLINK-17095 Project: Flink I

[jira] [Created] (FLINK-17094) OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException

Zhijiang created FLINK-17094: Summary: OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException Key: FLINK-17094 URL: https://issues.apache.org/jira/browse/FLINK-17094 Projec

[jira] [Created] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

Zhijiang created FLINK-17092: Summary: Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests Key: FLINK-17092 URL: https://issues.apache.org/jira/browse/FLINK-17092 Project: Flink

[jira] [Assigned] (FLINK-16822) The config set by SET command does not work

[ https://issues.apache.org/jira/browse/FLINK-16822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16822: Assignee: godfrey he > The config set by SET command does not work >

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17080209#comment-17080209 ] Zhijiang commented on FLINK-16921: -- Another instance: [https://travis-ci.org/github/apa

[jira] [Commented] (FLINK-17010) Streaming File Sink s3 end-to-end test fails with "Output hash mismatch"

[ https://issues.apache.org/jira/browse/FLINK-17010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078322#comment-17078322 ] Zhijiang commented on FLINK-17010: -- Great, this issue seems resolved. Sorry for mislead

[jira] [Commented] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077902#comment-17077902 ] Zhijiang commented on FLINK-17040: -- Thanks for the explanations [~rmetzger]! > Savepoi

[jira] [Updated] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17040: - Fix Version/s: 1.11.0 > SavepointWriterITCase broken > > >

[jira] [Updated] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17040: - Component/s: Runtime / Task > SavepointWriterITCase broken > > >

[jira] [Updated] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17040: - Priority: Blocker (was: Major) > SavepointWriterITCase broken > > >

[jira] [Updated] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17040: - Component/s: Tests > SavepointWriterITCase broken > > > Key

[jira] [Commented] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1703#comment-1703 ] Zhijiang commented on FLINK-17040: -- Thanks for reporting this [~wenlong.lwl]! It is in

[jira] [Commented] (FLINK-17010) Streaming File Sink s3 end-to-end test fails with "Output hash mismatch"

[ https://issues.apache.org/jira/browse/FLINK-17010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077768#comment-17077768 ] Zhijiang commented on FLINK-17010: -- Another case  [https://dev.azure.com/rmetzger/Flink

[jira] [Commented] (FLINK-17010) Streaming File Sink s3 end-to-end test fails with "Output hash mismatch"

[ https://issues.apache.org/jira/browse/FLINK-17010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077765#comment-17077765 ] Zhijiang commented on FLINK-17010: -- The same issue still happened in  [https://dev.azur

[jira] [Assigned] (FLINK-17040) SavepointWriterITCase broken

[ https://issues.apache.org/jira/browse/FLINK-17040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17040: Assignee: Yingjie Cao > SavepointWriterITCase broken > > >

[jira] [Closed] (FLINK-16537) Implement ResultPartition state recovery for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-16537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16537. Resolution: Fixed Merged in master: 693cb6adc42d75d1db720b45013430a4c6817d4a > Implement ResultPartition

[jira] [Assigned] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16536: Assignee: Zhijiang > Implement InputChannel state recovery for unaligned checkpoint > ---

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070233#comment-17070233 ] Zhijiang commented on FLINK-16770: -- Another instance  [https://travis-ci.org/apache/fli

[jira] [Updated] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16770: - Priority: Critical (was: Major) > Resuming Externalized Checkpoint (rocks, incremental, scale up) end-t

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070230#comment-17070230 ] Zhijiang commented on FLINK-16770: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Updated] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15981: - Fix Version/s: (was: 1.10.1) (was: 1.11.0) > Control the direct memory in Fil

[jira] [Commented] (FLINK-16787) Provide an assigner strategy of average splits allocation

[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069927#comment-17069927 ] Zhijiang commented on FLINK-16787: -- I guess this feature would be involved in more comp

[jira] [Updated] (FLINK-16787) Provide an assigner strategy of average splits allocation

[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16787: - Component/s: Runtime / Coordination API / Core > Provide an assigner strategy of averag

[jira] [Updated] (FLINK-16787) Provide an assigner strategy of average splits allocation

[ https://issues.apache.org/jira/browse/FLINK-16787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16787: - Fix Version/s: (was: 1.11.0) > Provide an assigner strategy of average splits allocation > -

[jira] [Resolved] (FLINK-16262) Class loader problem with FlinkKafkaProducer.Semantic.EXACTLY_ONCE and usrlib directory

[ https://issues.apache.org/jira/browse/FLINK-16262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang resolved FLINK-16262. -- Resolution: Fixed Merged in release-1.10: e39cfe7660daaeed4213f04ccbce6de1e8d90fe5 Merged in master: 

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069458#comment-17069458 ] Zhijiang commented on FLINK-16821: -- Thanks for solving it [~rmetzger]! I guess it is a

[jira] [Commented] (FLINK-16750) Kerberized YARN on Docker test fails with staring Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068797#comment-17068797 ] Zhijiang commented on FLINK-16750: -- > What does "staring Hadoop cluster" mean? [~gjy],

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068258#comment-17068258 ] Zhijiang commented on FLINK-16821: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16821: - Priority: Blocker (was: Critical) > Run Kubernetes test failed with invalid named "minikube" >

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068257#comment-17068257 ] Zhijiang commented on FLINK-16821: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16821: - Fix Version/s: 1.11.0 > Run Kubernetes test failed with invalid named "minikube" > -

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16821: - Priority: Critical (was: Major) > Run Kubernetes test failed with invalid named "minikube" > --

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068254#comment-17068254 ] Zhijiang commented on FLINK-16821: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Created] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

Zhijiang created FLINK-16821: Summary: Run Kubernetes test failed with invalid named "minikube" Key: FLINK-16821 URL: https://issues.apache.org/jira/browse/FLINK-16821 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067448#comment-17067448 ] Zhijiang commented on FLINK-16720: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Assigned] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16753: Assignee: Jiayi Liao > Exception from AsyncCheckpointRunnable should be wrapped in > CheckpointE

[jira] [Commented] (FLINK-15772) Shaded Hadoop S3A with credentials provider end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066583#comment-17066583 ] Zhijiang commented on FLINK-15772: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066579#comment-17066579 ] Zhijiang commented on FLINK-16753: -- Thanks for the updates and I am clear now.  I think

[jira] [Created] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

Zhijiang created FLINK-16770: Summary: Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file Key: FLINK-16770 URL: https://issues.apache.org/jira/browse/FLINK-16770

[jira] [Updated] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-16561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16561: - Fix Version/s: 1.11.0 > Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) >

[jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16582: - Fix Version/s: 1.11.0 > NettyBufferPoolTest may have warns on NettyBuffer leak > --

[jira] [Commented] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066466#comment-17066466 ] Zhijiang commented on FLINK-16638: -- [~basharaj], do you want to contribute the PR for t

[jira] [Commented] (FLINK-16645) Limit the maximum backlogs in subpartitions for data skew case

[ https://issues.apache.org/jira/browse/FLINK-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066465#comment-17066465 ] Zhijiang commented on FLINK-16645: -- Thanks for the concern. If you are interested, I ca

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066463#comment-17066463 ] Zhijiang commented on FLINK-16753: -- Hey [~wind_ljy], could you point out where `owner.

[jira] [Created] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without exit

Zhijiang created FLINK-16768: Summary: HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without exit Key: FLINK-16768 URL: https://issues.apache.org/jira/browse/FLINK-16768 Project:

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066426#comment-17066426 ] Zhijiang commented on FLINK-16629: -- Another instance  [https://dev.azure.com/rmetzger/F

[jira] [Closed] (FLINK-16712) Refactor StreamTask to construct final fields

[ https://issues.apache.org/jira/browse/FLINK-16712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16712. Resolution: Fixed Merged in master: bb4ec22a7d0e0d0831ec56b121eefb465bf8f939 > Refactor StreamTask to con

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066345#comment-17066345 ] Zhijiang commented on FLINK-16720: -- [~rmetzger], thanks for the correction. It is indee

[jira] [Updated] (FLINK-16750) Kerberized YARN on Docker test fails with staring Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16750: - Fix Version/s: 1.11.0 > Kerberized YARN on Docker test fails with staring Hadoop cluster > -

[jira] [Created] (FLINK-16750) Kerberized YARN on Docker test fails with staring Hadoop cluster

Zhijiang created FLINK-16750: Summary: Kerberized YARN on Docker test fails with staring Hadoop cluster Key: FLINK-16750 URL: https://issues.apache.org/jira/browse/FLINK-16750 Project: Flink Iss

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065340#comment-17065340 ] Zhijiang commented on FLINK-16629: -- Another instance :[https://dev.azure.com/rmetzger/

[jira] [Updated] (FLINK-16739) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key

[ https://issues.apache.org/jira/browse/FLINK-16739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16739: - Fix Version/s: 1.11.0 > PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key > ---

[jira] [Created] (FLINK-16739) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key

Zhijiang created FLINK-16739: Summary: PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails with no such key Key: FLINK-16739 URL: https://issues.apache.org/jira/browse/FLINK-16739 Project: Flink

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065330#comment-17065330 ] Zhijiang commented on FLINK-16720: -- Another instance:  [https://dev.azure.com/rmetzger/

[jira] [Updated] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16720: - Priority: Critical (was: Major) > Maven gets stuck downloading artifacts on Azure > ---

[jira] [Comment Edited] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064732#comment-17064732 ] Zhijiang edited comment on FLINK-16720 at 3/23/20, 11:37 AM: -

[jira] [Commented] (FLINK-16720) Maven gets stuck downloading artifacts on Azure

[ https://issues.apache.org/jira/browse/FLINK-16720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064732#comment-17064732 ] Zhijiang commented on FLINK-16720: -- Another instance : [https://dev.azure.com/rmetzger

[jira] [Created] (FLINK-16712) Refactor StreamTask to construct final fields

Zhijiang created FLINK-16712: Summary: Refactor StreamTask to construct final fields Key: FLINK-16712 URL: https://issues.apache.org/jira/browse/FLINK-16712 Project: Flink Issue Type: Task

<    1   2   3   4   5   6   7   8   9   10   >