Yangze Guo created FLINK-33870:
--
Summary: Split the HighAvailabilityServices into LeaderServices
and PersistentServices
Key: FLINK-33870
URL: https://issues.apache.org/jira/browse/FLINK-33870
Project: Fl
Yangze Guo created FLINK-33852:
--
Summary: FLIP-403 High Availability Services for OLAP Scenarios
Key: FLINK-33852
URL: https://issues.apache.org/jira/browse/FLINK-33852
Project: Flink
Issue Type
Yangze Guo created FLINK-33532:
--
Summary: Move the serialization of ShuffleDescriptorGroup out of
the RPC main thread
Key: FLINK-33532
URL: https://issues.apache.org/jira/browse/FLINK-33532
Project: Flin
Yangze Guo created FLINK-33289:
--
Summary: SQL Gateway supports IPv6 addresses.
Key: FLINK-33289
URL: https://issues.apache.org/jira/browse/FLINK-33289
Project: Flink
Issue Type: Improvement
Yangze Guo created FLINK-33203:
--
Summary: FLIP-374: Adding a separate configuration for specifying
Java Options of the SQL Gateway
Key: FLINK-33203
URL: https://issues.apache.org/jira/browse/FLINK-33203
Yangze Guo created FLINK-33054:
--
Summary: Align the job execution result fetching timeout in
CollectResultFetcher to akka timeout
Key: FLINK-33054
URL: https://issues.apache.org/jira/browse/FLINK-33054
P
Yangze Guo created FLINK-33053:
--
Summary: Watcher leak in Zookeeper HA mode
Key: FLINK-33053
URL: https://issues.apache.org/jira/browse/FLINK-33053
Project: Flink
Issue Type: Bug
Compo
Yangze Guo created FLINK-32879:
--
Summary: slotmanager.max-total-resource.cpu/memory should be
ignored in standalone mode.
Key: FLINK-32879
URL: https://issues.apache.org/jira/browse/FLINK-32879
Project:
Yangze Guo created FLINK-32771:
--
Summary: Remove the invalid config option
slotmanager.request-timeout
Key: FLINK-32771
URL: https://issues.apache.org/jira/browse/FLINK-32771
Project: Flink
Iss
Yangze Guo created FLINK-28313:
--
Summary: Add history server flag to DashboardConfiguration
Key: FLINK-28313
URL: https://issues.apache.org/jira/browse/FLINK-28313
Project: Flink
Issue Type: Sub
Yangze Guo created FLINK-28312:
--
Summary: Introduce REST APIs for log URL retrieval
Key: FLINK-28312
URL: https://issues.apache.org/jira/browse/FLINK-28312
Project: Flink
Issue Type: Sub-task
Yangze Guo created FLINK-28311:
--
Summary: Introduce REST APIs for the environmental information
Key: FLINK-28311
URL: https://issues.apache.org/jira/browse/FLINK-28311
Project: Flink
Issue Type:
Yangze Guo created FLINK-28310:
--
Summary: Introduce aggregating task metrics
Key: FLINK-28310
URL: https://issues.apache.org/jira/browse/FLINK-28310
Project: Flink
Issue Type: Sub-task
Yangze Guo created FLINK-28309:
--
Summary: Introduce metrics of the duration that a task stays in
each status
Key: FLINK-28309
URL: https://issues.apache.org/jira/browse/FLINK-28309
Project: Flink
Yangze Guo created FLINK-28308:
--
Summary: Introduce accumulated time metrics that a running task is
busy / idle / back-pressured
Key: FLINK-28308
URL: https://issues.apache.org/jira/browse/FLINK-28308
Pr
Yangze Guo created FLINK-28307:
--
Summary: FLIP-241: Completed Jobs Information Enhancement
Key: FLINK-28307
URL: https://issues.apache.org/jira/browse/FLINK-28307
Project: Flink
Issue Type: New
Yangze Guo created FLINK-27409:
--
Summary: Cleanup stale slot allocation record when the resource
requirement of a job is empty
Key: FLINK-27409
URL: https://issues.apache.org/jira/browse/FLINK-27409
Proj
Yangze Guo created FLINK-27256:
--
Summary: Log the root exception in closing the task manager
connection
Key: FLINK-27256
URL: https://issues.apache.org/jira/browse/FLINK-27256
Project: Flink
Is
Yangze Guo created FLINK-26675:
--
Summary: Parallelized heavy serialization operations in
StreamingJobGraphGenerator
Key: FLINK-26675
URL: https://issues.apache.org/jira/browse/FLINK-26675
Project: Flink
Yangze Guo created FLINK-26641:
--
Summary: Optimize the time of fetching job status in the job
submission of session cluster
Key: FLINK-26641
URL: https://issues.apache.org/jira/browse/FLINK-26641
Project
Yangze Guo created FLINK-26627:
--
Summary: Allow user to config the init/max wait time in the
ExponentialWaitStrategy of job submission
Key: FLINK-26627
URL: https://issues.apache.org/jira/browse/FLINK-26627
Yangze Guo created FLINK-25742:
--
Summary: Remove the redundant serialization of RPC invocation at
Flink side.
Key: FLINK-25742
URL: https://issues.apache.org/jira/browse/FLINK-25742
Project: Flink
Yangze Guo created FLINK-25741:
--
Summary: Ignore buffer pools which have no floating buffer in
buffer redistributing
Key: FLINK-25741
URL: https://issues.apache.org/jira/browse/FLINK-25741
Project: Flink
Yangze Guo created FLINK-24951:
--
Summary: Allow watch bookmarks to mitigate frequent watcher
rebuilding
Key: FLINK-24951
URL: https://issues.apache.org/jira/browse/FLINK-24951
Project: Flink
Is
Yangze Guo created FLINK-24541:
--
Summary: ConfigurationUtils#assembleDynamicConfigsStr should
consider special characters
Key: FLINK-24541
URL: https://issues.apache.org/jira/browse/FLINK-24541
Project:
Yangze Guo created FLINK-24380:
--
Summary: Flink should handle the state transition of the pod from
Pending to Failed
Key: FLINK-24380
URL: https://issues.apache.org/jira/browse/FLINK-24380
Project: Flink
Yangze Guo created FLINK-24262:
--
Summary: Remove unused ContainerOverlays
Key: FLINK-24262
URL: https://issues.apache.org/jira/browse/FLINK-24262
Project: Flink
Issue Type: Technical Debt
Yangze Guo created FLINK-24161:
--
Summary: Can not stop the job with savepoint while a task is
finishing
Key: FLINK-24161
URL: https://issues.apache.org/jira/browse/FLINK-24161
Project: Flink
Is
Yangze Guo created FLINK-23921:
--
Summary: WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF
is not stable
Key: FLINK-23921
URL: https://issues.apache.org/jira/browse/FLINK-23921
Project: Flink
Yangze Guo created FLINK-23912:
--
Summary: Remove unnecessary "Clearing resource requirements of job"
Key: FLINK-23912
URL: https://issues.apache.org/jira/browse/FLINK-23912
Project: Flink
Issue
Yangze Guo created FLINK-23743:
--
Summary: Test the fine-grained resource management
Key: FLINK-23743
URL: https://issues.apache.org/jira/browse/FLINK-23743
Project: Flink
Issue Type: Improvement
Yangze Guo created FLINK-23463:
--
Summary: Replace the tag with ShortCodes in document
Key: FLINK-23463
URL: https://issues.apache.org/jira/browse/FLINK-23463
Project: Flink
Issue Type: Bug
Yangze Guo created FLINK-23359:
--
Summary: Fix the number of available slots in
testResourceCanBeAllocatedForDifferentJobAfterFree
Key: FLINK-23359
URL: https://issues.apache.org/jira/browse/FLINK-23359
P
Yangze Guo created FLINK-23265:
--
Summary: Support evenly spread out in fine-grained resource
management
Key: FLINK-23265
URL: https://issues.apache.org/jira/browse/FLINK-23265
Project: Flink
Is
Yangze Guo created FLINK-23264:
--
Summary: Fine Grained Resource Management Phase 2
Key: FLINK-23264
URL: https://issues.apache.org/jira/browse/FLINK-23264
Project: Flink
Issue Type: New Feature
Yangze Guo created FLINK-23165:
--
Summary: Add StreamExecutionEnvironment#registerSlotSharingGroup
to PyFlink
Key: FLINK-23165
URL: https://issues.apache.org/jira/browse/FLINK-23165
Project: Flink
Yangze Guo created FLINK-22683:
--
Summary: The total Flink/process memory of memoryConfiguration in
/taskmanagers can be null or incorrect value
Key: FLINK-22683
URL: https://issues.apache.org/jira/browse/FLINK-22683
Yangze Guo created FLINK-22627:
--
Summary: Remove SlotManagerImpl
Key: FLINK-22627
URL: https://issues.apache.org/jira/browse/FLINK-22627
Project: Flink
Issue Type: Technical Debt
Compo
Yangze Guo created FLINK-22624:
--
Summary: Default resource allocation strategy will allocate more
pending task managers than demand
Key: FLINK-22624
URL: https://issues.apache.org/jira/browse/FLINK-22624
Yangze Guo created FLINK-22618:
--
Summary: Fix incorrect free resource metrics of task managers
Key: FLINK-22618
URL: https://issues.apache.org/jira/browse/FLINK-22618
Project: Flink
Issue Type:
Yangze Guo created FLINK-22536:
--
Summary: Promote the critical log in FineGrainedSlotManager to
INFO level
Key: FLINK-22536
URL: https://issues.apache.org/jira/browse/FLINK-22536
Project: Flink
Yangze Guo created FLINK-22505:
--
Summary: Limit the precision of Resource
Key: FLINK-22505
URL: https://issues.apache.org/jira/browse/FLINK-22505
Project: Flink
Issue Type: Bug
Compone
Yangze Guo created FLINK-22351:
--
Summary: Promote the log level of the resource declaration to INFO
in FineGrainedSlotManager
Key: FLINK-22351
URL: https://issues.apache.org/jira/browse/FLINK-22351
Proje
Yangze Guo created FLINK-21633:
--
Summary: Index pending task managers in TaskManagerTracker
Key: FLINK-21633
URL: https://issues.apache.org/jira/browse/FLINK-21633
Project: Flink
Issue Type: Sub
Yangze Guo created FLINK-21312:
--
Summary:
SavepointITCase.testStopSavepointWithBoundedInputConcurrently is unstable
Key: FLINK-21312
URL: https://issues.apache.org/jira/browse/FLINK-21312
Project: Flink
Yangze Guo created FLINK-21273:
--
Summary: Remove unused ExecutionVertexSchedulingRequirements
Key: FLINK-21273
URL: https://issues.apache.org/jira/browse/FLINK-21273
Project: Flink
Issue Type: B
Yangze Guo created FLINK-21270:
--
Summary: Generate the slot request respect to the resource
specification of SlotSharingGroup if present
Key: FLINK-21270
URL: https://issues.apache.org/jira/browse/FLINK-21270
Yangze Guo created FLINK-21269:
--
Summary: Introduce runtime interfaces for specifying SSG-based
resource requirements
Key: FLINK-21269
URL: https://issues.apache.org/jira/browse/FLINK-21269
Project: Flin
Yangze Guo created FLINK-21267:
--
Summary: FLIP-156: Runtime Interfaces for Fine-Grained Resource
Requirements
Key: FLINK-21267
URL: https://issues.apache.org/jira/browse/FLINK-21267
Project: Flink
Yangze Guo created FLINK-21221:
--
Summary: Deduplication of ResourceCounter
Key: FLINK-21221
URL: https://issues.apache.org/jira/browse/FLINK-21221
Project: Flink
Issue Type: Improvement
Yangze Guo created FLINK-21220:
--
Summary: Change the type of cpuCores in ResourceProfile to
CPUResource
Key: FLINK-21220
URL: https://issues.apache.org/jira/browse/FLINK-21220
Project: Flink
Is
Yangze Guo created FLINK-21177:
--
Summary: Introduce the counterpart of
slotmanager.number-of-slots.max in fine-grained resource management
Key: FLINK-21177
URL: https://issues.apache.org/jira/browse/FLINK-21177
Yangze Guo created FLINK-21174:
--
Summary: Optimize the performance of ResourceAllocationStrategy
Key: FLINK-21174
URL: https://issues.apache.org/jira/browse/FLINK-21174
Project: Flink
Issue Type
Yangze Guo created FLINK-21047:
--
Summary: Expose the correct registered/free resources information
in SlotManager
Key: FLINK-21047
URL: https://issues.apache.org/jira/browse/FLINK-21047
Project: Flink
Yangze Guo created FLINK-20865:
--
Summary: Prevent potential resource deadlock in fine-grained
resource management
Key: FLINK-20865
URL: https://issues.apache.org/jira/browse/FLINK-20865
Project: Flink
Yangze Guo created FLINK-20864:
--
Summary: Apply exact matching rules in fulfilling resource
requirement with slot resource
Key: FLINK-20864
URL: https://issues.apache.org/jira/browse/FLINK-20864
Project:
Yangze Guo created FLINK-20863:
--
Summary: Exclude network memory from ResourceProfile
Key: FLINK-20863
URL: https://issues.apache.org/jira/browse/FLINK-20863
Project: Flink
Issue Type: Task
Yangze Guo created FLINK-20838:
--
Summary: Implement SlotRequestAdapter for the
FineGrainedSlotManager
Key: FLINK-20838
URL: https://issues.apache.org/jira/browse/FLINK-20838
Project: Flink
Issu
Yangze Guo created FLINK-20837:
--
Summary: Assign an increasing number larger than the numberOfSlot
to dynamic slots
Key: FLINK-20837
URL: https://issues.apache.org/jira/browse/FLINK-20837
Project: Flink
Yangze Guo created FLINK-20836:
--
Summary: Register TaskManager with total and default slot resource
profile in SlotManager
Key: FLINK-20836
URL: https://issues.apache.org/jira/browse/FLINK-20836
Project:
Yangze Guo created FLINK-20835:
--
Summary: Implement FineGrainedSlotManager
Key: FLINK-20835
URL: https://issues.apache.org/jira/browse/FLINK-20835
Project: Flink
Issue Type: Sub-task
C
Yangze Guo created FLINK-20073:
--
Summary: Add kerberos setup documentation for native k8s
integration
Key: FLINK-20073
URL: https://issues.apache.org/jira/browse/FLINK-20073
Project: Flink
Issu
Yangze Guo created FLINK-18971:
--
Summary: Support to mount kerberos conf as ConfigMap and Keytab as
Secrete
Key: FLINK-18971
URL: https://issues.apache.org/jira/browse/FLINK-18971
Project: Flink
Yangze Guo created FLINK-18583:
--
Summary: The _id field is incorrectly set to index in
Elasticsearch6 DynamicTableSink
Key: FLINK-18583
URL: https://issues.apache.org/jira/browse/FLINK-18583
Project: Fli
Yangze Guo created FLINK-18361:
--
Summary: Support username and password options for new
Elasticsearch connector
Key: FLINK-18361
URL: https://issues.apache.org/jira/browse/FLINK-18361
Project: Flink
Yangze Guo created FLINK-18267:
--
Summary: Missing NOTICE file in flink-examples-streaming
Key: FLINK-18267
URL: https://issues.apache.org/jira/browse/FLINK-18267
Project: Flink
Issue Type: Bug
Yangze Guo created FLINK-18264:
--
Summary: Translate the "External Resource Framework" page into
Chinese
Key: FLINK-18264
URL: https://issues.apache.org/jira/browse/FLINK-18264
Project: Flink
Is
Yangze Guo created FLINK-18205:
--
Summary: Mitigate the use of reflection in HadoopModule
Key: FLINK-18205
URL: https://issues.apache.org/jira/browse/FLINK-18205
Project: Flink
Issue Type: Improv
Yangze Guo created FLINK-18109:
--
Summary: Manually test external resource framework with GPUDriver
Key: FLINK-18109
URL: https://issues.apache.org/jira/browse/FLINK-18109
Project: Flink
Issue Ty
Yangze Guo created FLINK-18081:
--
Summary: Fix broken links in "Kerberos Authentication Setup and
Configuration" doc
Key: FLINK-18081
URL: https://issues.apache.org/jira/browse/FLINK-18081
Project: Flink
Yangze Guo created FLINK-18080:
--
Summary: Translate the "Kerberos Authentication Setup and
Configuration" page into Chinese
Key: FLINK-18080
URL: https://issues.apache.org/jira/browse/FLINK-18080
Project
Yangze Guo created FLINK-18018:
--
Summary: Bundle GPU plugin in "plugins/" directory
Key: FLINK-18018
URL: https://issues.apache.org/jira/browse/FLINK-18018
Project: Flink
Issue Type: Improvement
Yangze Guo created FLINK-17917:
--
Summary: ResourceInformationReflector#getExternalResources should
ignore the external resource with a value of 0
Key: FLINK-17917
URL: https://issues.apache.org/jira/browse/FLINK-1791
Yangze Guo created FLINK-17862:
--
Summary: The internal class StreamingRuntimeContext is leaked in
AbstractUdfStreamOperator
Key: FLINK-17862
URL: https://issues.apache.org/jira/browse/FLINK-17862
Project
Yangze Guo created FLINK-17795:
--
Summary: Add an example to show how to leverage GPU resources
Key: FLINK-17795
URL: https://issues.apache.org/jira/browse/FLINK-17795
Project: Flink
Issue Type:
Yangze Guo created FLINK-17579:
--
Summary: Set the resource id of taskexecutor from environment
variable if possible in standalone mode
Key: FLINK-17579
URL: https://issues.apache.org/jira/browse/FLINK-17579
Yangze Guo created FLINK-17574:
--
Summary: Deduplicate the process execution logic in Flink
Key: FLINK-17574
URL: https://issues.apache.org/jira/browse/FLINK-17574
Project: Flink
Issue Type: Impr
Yangze Guo created FLINK-17540:
--
Summary: Adding tests/tools checking the pattern of new
configuration options following the xyz.max/min pattern
Key: FLINK-17540
URL: https://issues.apache.org/jira/browse/FLINK-17540
Yangze Guo created FLINK-17539:
--
Summary: Migrate the configuration options which do not follow the
xyz.max/min pattern.
Key: FLINK-17539
URL: https://issues.apache.org/jira/browse/FLINK-17539
Project: F
Yangze Guo created FLINK-17536:
--
Summary: Change the config option of max limitation to
"slotmanager.number-of-slots.max"
Key: FLINK-17536
URL: https://issues.apache.org/jira/browse/FLINK-17536
Project:
Yangze Guo created FLINK-17535:
--
Summary: Treat min/max as part of the hierarchy of config option
Key: FLINK-17535
URL: https://issues.apache.org/jira/browse/FLINK-17535
Project: Flink
Issue Typ
Yangze Guo created FLINK-17408:
--
Summary: Introduce GPUDriver
Key: FLINK-17408
URL: https://issues.apache.org/jira/browse/FLINK-17408
Project: Flink
Issue Type: Sub-task
Components: Ru
Yangze Guo created FLINK-17407:
--
Summary: Introduce external resource framework.
Key: FLINK-17407
URL: https://issues.apache.org/jira/browse/FLINK-17407
Project: Flink
Issue Type: Sub-task
Yangze Guo created FLINK-17331:
--
Summary: Add NettyMessageContent interface for all the class which
could be write to NettyMessage
Key: FLINK-17331
URL: https://issues.apache.org/jira/browse/FLINK-17331
Yangze Guo created FLINK-17300:
--
Summary: Log the lineage information between ExecutionAttemptID
and AllocationID
Key: FLINK-17300
URL: https://issues.apache.org/jira/browse/FLINK-17300
Project: Flink
Yangze Guo created FLINK-17297:
--
Summary: Log the lineage information between ExecutionAttemptID
and SlotRequestID
Key: FLINK-17297
URL: https://issues.apache.org/jira/browse/FLINK-17297
Project: Flink
Yangze Guo created FLINK-17298:
--
Summary: Log the lineage information between ExecutionAttemptID
and SlotRequestID
Key: FLINK-17298
URL: https://issues.apache.org/jira/browse/FLINK-17298
Project: Flink
Yangze Guo created FLINK-17295:
--
Summary: Refactor the ExecutionAttemptID to consist of
ExecutionVertexID and attemptNumber
Key: FLINK-17295
URL: https://issues.apache.org/jira/browse/FLINK-17295
Project
Yangze Guo created FLINK-17216:
--
Summary: Allow user to provide credential provider to
Elasticsearch rest client.
Key: FLINK-17216
URL: https://issues.apache.org/jira/browse/FLINK-17216
Project: Flink
Yangze Guo created FLINK-17044:
--
Summary: FLIP-108: Add GPU support in Flink
Key: FLINK-17044
URL: https://issues.apache.org/jira/browse/FLINK-17044
Project: Flink
Issue Type: New Feature
Yangze Guo created FLINK-16874:
--
Summary: Respect the dynamic options when calculating memory
options in taskmanager.sh
Key: FLINK-16874
URL: https://issues.apache.org/jira/browse/FLINK-16874
Project: Fl
Yangze Guo created FLINK-16605:
--
Summary: Add max limitation to the total number of slots
Key: FLINK-16605
URL: https://issues.apache.org/jira/browse/FLINK-16605
Project: Flink
Issue Type: Impro
Yangze Guo created FLINK-16566:
--
Summary: Change the log level of the launching command and dynamic
properties from DEBUG to INFO in Mesos integration
Key: FLINK-16566
URL: https://issues.apache.org/jira/browse/FLINK
Yangze Guo created FLINK-16416:
--
Summary: Shutdown the task manager gracefully in standalone mode
Key: FLINK-16416
URL: https://issues.apache.org/jira/browse/FLINK-16416
Project: Flink
Issue Typ
Yangze Guo created FLINK-16297:
--
Summary: Remove the redundant intent and blank line in highlight
code blocks
Key: FLINK-16297
URL: https://issues.apache.org/jira/browse/FLINK-16297
Project: Flink
Yangze Guo created FLINK-16237:
--
Summary: Wordcount on Docker test (custom fs plugin) fails.
Key: FLINK-16237
URL: https://issues.apache.org/jira/browse/FLINK-16237
Project: Flink
Issue Type: Bu
Yangze Guo created FLINK-15870:
--
Summary: Wait the job's terminal state through REST interface
Key: FLINK-15870
URL: https://issues.apache.org/jira/browse/FLINK-15870
Project: Flink
Issue Type:
Yangze Guo created FLINK-15679:
--
Summary: Improve Flink's ID system
Key: FLINK-15679
URL: https://issues.apache.org/jira/browse/FLINK-15679
Project: Flink
Issue Type: Improvement
Rep
Yangze Guo created FLINK-15611:
--
Summary: KafkaITCase.testOneToOneSources fails on Travis
Key: FLINK-15611
URL: https://issues.apache.org/jira/browse/FLINK-15611
Project: Flink
Issue Type: Bug
Yangze Guo created FLINK-15442:
--
Summary: Harden the Avro Confluent Schema Registry nightly
end-to-end test
Key: FLINK-15442
URL: https://issues.apache.org/jira/browse/FLINK-15442
Project: Flink
1 - 100 of 115 matches
Mail list logo
