[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=17110787#comment-17110787 ] Zhijiang commented on FLINK-17015: -- If I understand correctly, FLINK-17610 can also be treated as a

[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) >

[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 >

[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

[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 >

[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 >

[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=17106801#comment-17106801 ] Zhijiang commented on FLINK-16383: -- Another instance 

[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

[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()

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

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

[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

[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

[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

[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

[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.

[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:

[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,

[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=17092601#comment-17092601 ] Zhijiang commented on FLINK-17389: -- Another instance 

[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=17092600#comment-17092600 ] Zhijiang commented on FLINK-17389: -- Another instance in release-1.10 

[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]

[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:

[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

[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

[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=17089545#comment-17089545 ] Zhijiang commented on FLINK-17182: -- After confirming with [~gaoyunhaii] offline, it has no effect for

[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=17089263#comment-17089263 ] Zhijiang commented on FLINK-17274: -- Another instance 

[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=17084620#comment-17084620 ] Zhijiang commented on FLINK-17182: -- Thanks for reporting this [~dwysakowicz], I have assigned

[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=17081840#comment-17081840 ] Zhijiang commented on FLINK-16921: -- Another instance for this test failure, but not given specific

[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

[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

[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=17080209#comment-17080209 ] Zhijiang commented on FLINK-16921: -- Another instance: 

[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=17078322#comment-17078322 ] Zhijiang commented on FLINK-17010: -- Great, this issue seems resolved. Sorry for misleading. >

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

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

[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: - 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: Tests > SavepointWriterITCase broken > > >

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

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

[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=17077768#comment-17077768 ] Zhijiang commented on FLINK-17010: -- Another case 

[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=17077765#comment-17077765 ] Zhijiang commented on FLINK-17010: -- The same issue still happened in 

[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=17070233#comment-17070233 ] Zhijiang commented on FLINK-16770: -- Another instance 

[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)

[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=17070230#comment-17070230 ] Zhijiang commented on FLINK-16770: -- Another instance 

[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

[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=17069927#comment-17069927 ] Zhijiang commented on FLINK-16787: -- I guess this feature would be involved in more components, from API

[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

[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=17069458#comment-17069458 ] Zhijiang commented on FLINK-16821: -- Thanks for solving it [~rmetzger]! I guess it is already needed

[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=17068797#comment-17068797 ] Zhijiang commented on FLINK-16750: -- > What does "staring Hadoop cluster" mean? [~gjy], the above logs

[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=17068258#comment-17068258 ] Zhijiang commented on FLINK-16821: -- Another instance 

[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=17068257#comment-17068257 ] Zhijiang commented on FLINK-16821: -- Another instance 

[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=17068254#comment-17068254 ] Zhijiang commented on FLINK-16821: -- Another instance 

[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=17067448#comment-17067448 ] Zhijiang commented on FLINK-16720: -- Another instance 

[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 >

[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=17066583#comment-17066583 ] Zhijiang commented on FLINK-15772: -- Another instance 

[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=17066579#comment-17066579 ] Zhijiang commented on FLINK-16753: -- Thanks for the updates and I am clear now.  I think it is

[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=17066466#comment-17066466 ] Zhijiang commented on FLINK-16638: -- [~basharaj], do you want to contribute the PR for this bug? If so,

[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=17066465#comment-17066465 ] Zhijiang commented on FLINK-16645: -- Thanks for the concern. If you are interested, I can also assign it

[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=17066463#comment-17066463 ] Zhijiang commented on FLINK-16753: -- Hey [~wind_ljy], could you point out where

[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

[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=17066426#comment-17066426 ] Zhijiang commented on FLINK-16629: -- Another instance 

[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

[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=17066345#comment-17066345 ] Zhijiang commented on FLINK-16720: -- [~rmetzger], thanks for the correction. It is indeed the issue of

[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

[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=17065340#comment-17065340 ] Zhijiang commented on FLINK-16629: -- Another instance

[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=17065330#comment-17065330 ] Zhijiang commented on FLINK-16720: -- Another instance: 

[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=17064732#comment-17064732 ] Zhijiang edited comment on FLINK-16720 at 3/23/20, 11:37 AM: - Another two

[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=17064732#comment-17064732 ] Zhijiang commented on FLINK-16720: -- Another instance :

[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   >