Jiangjie Qin created FLINK-13179:
Summary: Add document on how to run examples.
Key: FLINK-13179
URL: https://issues.apache.org/jira/browse/FLINK-13179
Project: Flink
Issue Type: Improvement
Jiangjie Qin created FLINK-13204:
Summary: The subscribedPartitionStates should be thread safe.
Key: FLINK-13204
URL: https://issues.apache.org/jira/browse/FLINK-13204
Project: Flink
Issue Ty
Jiangjie Qin created FLINK-32398:
Summary: Support Avro SpecificRecord in DataStream and Table
conversion.
Key: FLINK-32398
URL: https://issues.apache.org/jira/browse/FLINK-32398
Project: Flink
Jiangjie Qin created FLINK-33733:
Summary: [FLIP-321] Update the stability docs to add the migration
periods.
Key: FLINK-33733
URL: https://issues.apache.org/jira/browse/FLINK-33733
Project: Flink
Jiangjie Qin created FLINK-16125:
Summary: Make zookeeper.connect optional for Kafka connectors
Key: FLINK-16125
URL: https://issues.apache.org/jira/browse/FLINK-16125
Project: Flink
Issue Ty
Jiangjie Qin created FLINK-16634:
Summary: The PartitionDiscoverer in FlinkKafkaConsumer should not
use the user provided client.id.
Key: FLINK-16634
URL: https://issues.apache.org/jira/browse/FLINK-16634
Jiangjie Qin created FLINK-16845:
Summary: Implement SourceReaderOperator which runs the
SourceReader.
Key: FLINK-16845
URL: https://issues.apache.org/jira/browse/FLINK-16845
Project: Flink
Jiangjie Qin created FLINK-16848:
Summary: Improve the performance of the RecordsWithSplitIds queue.
Key: FLINK-16848
URL: https://issues.apache.org/jira/browse/FLINK-16848
Project: Flink
Iss
Jiangjie Qin created FLINK-16851:
Summary: Add common metrics to the SourceReader base
implementation.
Key: FLINK-16851
URL: https://issues.apache.org/jira/browse/FLINK-16851
Project: Flink
Jiangjie Qin created FLINK-16852:
Summary: Add metrics to the source coordinator.
Key: FLINK-16852
URL: https://issues.apache.org/jira/browse/FLINK-16852
Project: Flink
Issue Type: Sub-task
Jiangjie Qin created FLINK-16986:
Summary: Enhance the OperatorEvent handling guarantee during
checkpointing.
Key: FLINK-16986
URL: https://issues.apache.org/jira/browse/FLINK-16986
Project: Flink
Jiangjie Qin created FLINK-17393:
Summary: Improve the `FutureCompletingBlockingQueue` to wakeup
blocking put() more elegantly.
Key: FLINK-17393
URL: https://issues.apache.org/jira/browse/FLINK-17393
Jiangjie Qin created FLINK-15099:
Summary: Implement OperatorEvent passing RPC.
Key: FLINK-15099
URL: https://issues.apache.org/jira/browse/FLINK-15099
Project: Flink
Issue Type: Sub-task
Jiangjie Qin created FLINK-15100:
Summary: Add the interface and base implementation for
SourceReader.
Key: FLINK-15100
URL: https://issues.apache.org/jira/browse/FLINK-15100
Project: Flink
Jiangjie Qin created FLINK-15101:
Summary: Add the interface for SpiltEnumerator and implementation
for SourceCoordinator
Key: FLINK-15101
URL: https://issues.apache.org/jira/browse/FLINK-15101
Projec
Jiangjie Qin created FLINK-15102:
Summary: Allow users to construct a DataStream from a new Source
API
Key: FLINK-15102
URL: https://issues.apache.org/jira/browse/FLINK-15102
Project: Flink
Jiangjie Qin created FLINK-15131:
Summary: Add Source API classes
Key: FLINK-15131
URL: https://issues.apache.org/jira/browse/FLINK-15131
Project: Flink
Issue Type: Sub-task
Repor
Jiangjie Qin created FLINK-15703:
Summary: FlinkKafkaConsumer should enable partition discovery by
default.
Key: FLINK-15703
URL: https://issues.apache.org/jira/browse/FLINK-15703
Project: Flink
Jiangjie Qin created FLINK-15745:
Summary: KafkaITCase.testKeyValueSupport failure due to assertion
error.
Key: FLINK-15745
URL: https://issues.apache.org/jira/browse/FLINK-15745
Project: Flink
Jiangjie Qin created FLINK-11199:
Summary: Support interactive programming in Flink
Key: FLINK-11199
URL: https://issues.apache.org/jira/browse/FLINK-11199
Project: Flink
Issue Type: New Feat
Jiangjie Qin created FLINK-11576:
Summary: Standardize connector metrics
Key: FLINK-11576
URL: https://issues.apache.org/jira/browse/FLINK-11576
Project: Flink
Issue Type: New Feature
Jiangjie Qin created FLINK-11681:
Summary: Add an AbstractMetric to combine the metric definition
and metric management.
Key: FLINK-11681
URL: https://issues.apache.org/jira/browse/FLINK-11681
Project
Jiangjie Qin created FLINK-11683:
Summary: Implement standard metrics in Kafka connectors.
Key: FLINK-11683
URL: https://issues.apache.org/jira/browse/FLINK-11683
Project: Flink
Issue Type: S
Jiangjie Qin created FLINK-11682:
Summary: Add abstract source and sink metric classes.
Key: FLINK-11682
URL: https://issues.apache.org/jira/browse/FLINK-11682
Project: Flink
Issue Type: Sub-
Jiangjie Qin created FLINK-11893:
Summary: Update ecosystem page and add it to the navigation bar
Key: FLINK-11893
URL: https://issues.apache.org/jira/browse/FLINK-11893
Project: Flink
Issue
Jiangjie Qin created FLINK-12352:
Summary: [FLIP-36] [Phase 1] Support cache() / invalidateCache()
in Table with default ShuffleService and NetworkStack
Key: FLINK-12352
URL: https://issues.apache.org/jira/browse/
Jiangjie Qin created FLINK-12425:
Summary: Implement RPCs to allow clients release result partitions
in a Flink cluster.
Key: FLINK-12425
URL: https://issues.apache.org/jira/browse/FLINK-12425
Project
Jiangjie Qin created FLINK-19535:
Summary: SourceCoordinator should avoid fail job multiple times.
Key: FLINK-19535
URL: https://issues.apache.org/jira/browse/FLINK-19535
Project: Flink
Issue
Jiangjie Qin created FLINK-19698:
Summary: Add close() method and onCheckpointComplete() to the
Source.
Key: FLINK-19698
URL: https://issues.apache.org/jira/browse/FLINK-19698
Project: Flink
Jiangjie Qin created FLINK-19743:
Summary: Add metrics definitions.
Key: FLINK-19743
URL: https://issues.apache.org/jira/browse/FLINK-19743
Project: Flink
Issue Type: Sub-task
Compo
Jiangjie Qin created FLINK-20081:
Summary: ExecutorNotifier should run handler in the main thread
when receive an exception from the callable.
Key: FLINK-20081
URL: https://issues.apache.org/jira/browse/FLINK-2008
Jiangjie Qin created FLINK-20108:
Summary: SingleThreadFetcherManager may add splits to a shutting
down SplitFetcher
Key: FLINK-20108
URL: https://issues.apache.org/jira/browse/FLINK-20108
Project: Fl
Jiangjie Qin created FLINK-20193:
Summary: SourceCoordinator should catch exception thrown from
SplitEnumerator.start()
Key: FLINK-20193
URL: https://issues.apache.org/jira/browse/FLINK-20193
Project:
Jiangjie Qin created FLINK-20194:
Summary: KafkaSourceFetcherManager.commitOffsets() should handle
the case when there is no split fetcher.
Key: FLINK-20194
URL: https://issues.apache.org/jira/browse/FLINK-20194
Jiangjie Qin created FLINK-20222:
Summary: The CheckpointCoordinator should reset the
OperatorCoordinators when fail before the first checkpoint.
Key: FLINK-20222
URL: https://issues.apache.org/jira/browse/FLINK-2
Jiangjie Qin created FLINK-20223:
Summary: The RecreateOnResetOperatorCoordinator and
SourceCoordinator executor thread should use the user class loader.
Key: FLINK-20223
URL: https://issues.apache.org/jira/browse
Jiangjie Qin created FLINK-20270:
Summary: Fix the regression of missing ExternallyInducedSource
support in FLIP-27 Source.
Key: FLINK-20270
URL: https://issues.apache.org/jira/browse/FLINK-20270
Proj
Jiangjie Qin created FLINK-20382:
Summary: Exception thrown from JobMaster.startScheduling() may be
ignored.
Key: FLINK-20382
URL: https://issues.apache.org/jira/browse/FLINK-20382
Project: Flink
Jiangjie Qin created FLINK-20492:
Summary: The SourceOperatorStreamTask should implement
cancelTask() and finishTask()
Key: FLINK-20492
URL: https://issues.apache.org/jira/browse/FLINK-20492
Project:
Jiangjie Qin created FLINK-20655:
Summary: Add E2E tests to the new KafkaSource based on FLIP-27.
Key: FLINK-20655
URL: https://issues.apache.org/jira/browse/FLINK-20655
Project: Flink
Issue
Jiangjie Qin created FLINK-20656:
Summary: Update docs for new KafkaSource connector.
Key: FLINK-20656
URL: https://issues.apache.org/jira/browse/FLINK-20656
Project: Flink
Issue Type: Task
Jiangjie Qin created FLINK-30645:
Summary: [FLIP-286] The scope/stability annotation in
AbstractStreamOperator are inconsistent.
Key: FLINK-30645
URL: https://issues.apache.org/jira/browse/FLINK-30645
Jiangjie Qin created FLINK-31654:
Summary: DataStreamUtils.reinterpretAsKeyedStream() should not
override the user specified chaining strategy.
Key: FLINK-31654
URL: https://issues.apache.org/jira/browse/FLINK-316
Jiangjie Qin created FLINK-27554:
Summary: The asf-site does not build on Apple Silicon
Key: FLINK-27554
URL: https://issues.apache.org/jira/browse/FLINK-27554
Project: Flink
Issue Type: Impr
Jiangjie Qin created FLINK-26029:
Summary: Generalize the checkpoint protocol of OperatorCoordinator.
Key: FLINK-26029
URL: https://issues.apache.org/jira/browse/FLINK-26029
Project: Flink
Is
Jiangjie Qin created FLINK-22282:
Summary: Move creation of SplitEnumerator to the SourceCoordinator
thread
Key: FLINK-22282
URL: https://issues.apache.org/jira/browse/FLINK-22282
Project: Flink
Jiangjie Qin created FLINK-17534:
Summary: Update the interfaces to PublicEvolving and add
documentation.
Key: FLINK-17534
URL: https://issues.apache.org/jira/browse/FLINK-17534
Project: Flink
Jiangjie Qin created FLINK-17761:
Summary: FutureCompletingBlockingQueue should have a capacity
limit.
Key: FLINK-17761
URL: https://issues.apache.org/jira/browse/FLINK-17761
Project: Flink
Jiangjie Qin created FLINK-18039:
Summary: Change SourceCoordinator to handle resetToCheckpoint()
call after started.
Key: FLINK-18039
URL: https://issues.apache.org/jira/browse/FLINK-18039
Project: F
Jiangjie Qin created FLINK-18044:
Summary: Add the subtask index information to the
SourceReaderContext.
Key: FLINK-18044
URL: https://issues.apache.org/jira/browse/FLINK-18044
Project: Flink
Jiangjie Qin created FLINK-18162:
Summary: AddSplitEvents should serialize the splits into bytes.
Key: FLINK-18162
URL: https://issues.apache.org/jira/browse/FLINK-18162
Project: Flink
Issue
Jiangjie Qin created FLINK-18322:
Summary: Fix unstable ExecutorNotifierTest#testExceptionInHandler.
Key: FLINK-18322
URL: https://issues.apache.org/jira/browse/FLINK-18322
Project: Flink
Iss
Jiangjie Qin created FLINK-18323:
Summary: Implement a Kafka Source based on new Source API
Key: FLINK-18323
URL: https://issues.apache.org/jira/browse/FLINK-18323
Project: Flink
Issue Type:
Jiangjie Qin created FLINK-18428:
Summary: StreamExecutionEnvironment#continuousSource() method
should be renamed to source()
Key: FLINK-18428
URL: https://issues.apache.org/jira/browse/FLINK-18428
Pr
Jiangjie Qin created FLINK-18450:
Summary: Add watermark alignment logic to SourceReaderBase.
Key: FLINK-18450
URL: https://issues.apache.org/jira/browse/FLINK-18450
Project: Flink
Issue Type
Jiangjie Qin created FLINK-18680:
Summary: Improve RecordsWithSplitIds API
Key: FLINK-18680
URL: https://issues.apache.org/jira/browse/FLINK-18680
Project: Flink
Issue Type: Sub-task
Jiangjie Qin created FLINK-35924:
Summary: Improve the SourceReaderBase to support the
RecordsWithSplitIds share internal buffer from SplitReader.
Key: FLINK-35924
URL: https://issues.apache.org/jira/browse/FLINK-
Jiangjie Qin created FLINK-36265:
Summary: List and track the deprecated APIs for the 2.0-preview
release.
Key: FLINK-36265
URL: https://issues.apache.org/jira/browse/FLINK-36265
Project: Flink
Jiangjie Qin created FLINK-36585:
Summary: The SplitFetcherManager.close() can chain the futures in
a tight loop.
Key: FLINK-36585
URL: https://issues.apache.org/jira/browse/FLINK-36585
Project: Flink
59 matches
Mail list logo
