Qingsheng Ren created FLINK-35386:
-
Summary: Build Flink CDC 3.1 Documentation and mark it as stable
Key: FLINK-35386
URL: https://issues.apache.org/jira/browse/FLINK-35386
Project: Flink
Qingsheng Ren created FLINK-35258:
-
Summary: Broken links to Doris in Flink CDC Documentation
Key: FLINK-35258
URL: https://issues.apache.org/jira/browse/FLINK-35258
Project: Flink
Issue
Qingsheng Ren created FLINK-35251:
-
Summary: SchemaDerivation serializes mapping incorrectly on
checkpoint
Key: FLINK-35251
URL: https://issues.apache.org/jira/browse/FLINK-35251
Project: Flink
Qingsheng Ren created FLINK-34692:
-
Summary: Update Flink website to point to the new Flink CDC “Get
Started” page
Key: FLINK-34692
URL: https://issues.apache.org/jira/browse/FLINK-34692
Project:
Qingsheng Ren created FLINK-34687:
-
Summary: Home Page of Flink CDC Documentation
Key: FLINK-34687
URL: https://issues.apache.org/jira/browse/FLINK-34687
Project: Flink
Issue Type: Sub-task
Qingsheng Ren created FLINK-34686:
-
Summary: "Deployment - YARN" Page for Flink CDC Documentation
Key: FLINK-34686
URL: https://issues.apache.org/jira/browse/FLINK-34686
Project: Flink
Issue
Qingsheng Ren created FLINK-34685:
-
Summary: "Deployment - Kubernetes" Page for Flink CDC Documentation
Key: FLINK-34685
URL: https://issues.apache.org/jira/browse/FLINK-34685
Project: Flink
Qingsheng Ren created FLINK-34684:
-
Summary: "Developer Guide - Licenses" Page for Flink CDC
Documentation
Key: FLINK-34684
URL: https://issues.apache.org/jira/browse/FLINK-34684
Project: Flink
Qingsheng Ren created FLINK-34683:
-
Summary: "Developer Guide - Contribute to Flink CDC" Page for
Flink CDC Documentation
Key: FLINK-34683
URL: https://issues.apache.org/jira/browse/FLINK-34683
Qingsheng Ren created FLINK-34682:
-
Summary: "Developer Guide - Understanding Flink CDC" Page for
Flink CDC Documentation
Key: FLINK-34682
URL: https://issues.apache.org/jira/browse/FLINK-34682
Qingsheng Ren created FLINK-34681:
-
Summary: "Deployment" Pages for Flink CDC Documentation
Key: FLINK-34681
URL: https://issues.apache.org/jira/browse/FLINK-34681
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-34680:
-
Summary: "Overview" Page for Connectors in Flink CDC Documentation
Key: FLINK-34680
URL: https://issues.apache.org/jira/browse/FLINK-34680
Project: Flink
Qingsheng Ren created FLINK-34679:
-
Summary: "Core Concept" Pages for Flink CDC Documentation
Key: FLINK-34679
URL: https://issues.apache.org/jira/browse/FLINK-34679
Project: Flink
Issue
Qingsheng Ren created FLINK-34678:
-
Summary: "Introduction" Page for Flink CDC Documentation
Key: FLINK-34678
URL: https://issues.apache.org/jira/browse/FLINK-34678
Project: Flink
Issue
Qingsheng Ren created FLINK-34677:
-
Summary: Refactor the structure of documentation for Flink CDC
Key: FLINK-34677
URL: https://issues.apache.org/jira/browse/FLINK-34677
Project: Flink
Qingsheng Ren created FLINK-34664:
-
Summary: Add .asf.yaml for Flink CDC
Key: FLINK-34664
URL: https://issues.apache.org/jira/browse/FLINK-34664
Project: Flink
Issue Type: Sub-task
Qingsheng Ren created FLINK-34662:
-
Summary: Add new issue template for Flink CDC repo
Key: FLINK-34662
URL: https://issues.apache.org/jira/browse/FLINK-34662
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-34653:
-
Summary: Support table merging with route in Flink CDC
Key: FLINK-34653
URL: https://issues.apache.org/jira/browse/FLINK-34653
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-34317:
-
Summary: Cleanup pending Flink CDC issues on GitHub
Key: FLINK-34317
URL: https://issues.apache.org/jira/browse/FLINK-34317
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-33630:
-
Summary: CoordinationResponse should be wrapped by SerializedValue
in TaskOperatorEventGateway and JobMasterOperatorEventGateway
Key: FLINK-33630
URL:
Qingsheng Ren created FLINK-33512:
-
Summary: Update download link in doc of Kafka connector
Key: FLINK-33512
URL: https://issues.apache.org/jira/browse/FLINK-33512
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-33219:
-
Summary: Kafka connector has architecture test violation against
Flink 1.18
Key: FLINK-33219
URL: https://issues.apache.org/jira/browse/FLINK-33219
Project: Flink
Qingsheng Ren created FLINK-32894:
-
Summary: flink-connector-parent should use maven-shade-plugin
3.3.0+ for Java 17
Key: FLINK-32894
URL: https://issues.apache.org/jira/browse/FLINK-32894
Project:
Qingsheng Ren created FLINK-32805:
-
Summary: Release Testing: Verify Support Java 17 (LTS)
Key: FLINK-32805
URL: https://issues.apache.org/jira/browse/FLINK-32805
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-32804:
-
Summary: Release Testing: Verify FLIP-304: Pluggable failure
handling for Apache Flink
Key: FLINK-32804
URL: https://issues.apache.org/jira/browse/FLINK-32804
Qingsheng Ren created FLINK-32802:
-
Summary: Release Testing: Verify FLIP-291: Externalized
Declarative Resource Management
Key: FLINK-32802
URL: https://issues.apache.org/jira/browse/FLINK-32802
Qingsheng Ren created FLINK-32803:
-
Summary: Release Testing: Verify FLINK-32165 - Improve
observability of fine-grained resource management
Key: FLINK-32803
URL: https://issues.apache.org/jira/browse/FLINK-32803
Qingsheng Ren created FLINK-32801:
-
Summary: Release Testing: Verify FLINK-32524 - Improve the
watermark aggregation performance when enabling the watermark alignment
Key: FLINK-32801
URL:
Qingsheng Ren created FLINK-32800:
-
Summary: Release Testing: Verify FLINK-32548 - Make watermark
alignment ready for production use
Key: FLINK-32800
URL: https://issues.apache.org/jira/browse/FLINK-32800
Qingsheng Ren created FLINK-32799:
-
Summary: Release Testing: Verify FLINK-26603 -Decouple Hive with
Flink planner
Key: FLINK-32799
URL: https://issues.apache.org/jira/browse/FLINK-32799
Project:
Qingsheng Ren created FLINK-32798:
-
Summary: Release Testing: Verify FLIP-294: Support Customized
Catalog Modification Listener
Key: FLINK-32798
URL: https://issues.apache.org/jira/browse/FLINK-32798
Qingsheng Ren created FLINK-32797:
-
Summary: Release Testing: Verify FLIP-288: Enable Dynamic
Partition Discovery by Default in Kafka Source
Key: FLINK-32797
URL: https://issues.apache.org/jira/browse/FLINK-32797
Qingsheng Ren created FLINK-32796:
-
Summary: Release Testing: Verify FLIP-295: Support lazy
initialization of catalogs and persistence of catalog configurations
Key: FLINK-32796
URL:
Qingsheng Ren created FLINK-32795:
-
Summary: Release Testing: Verify FLIP-279 Unified the max display
column width for SqlClient and Table APi in both Streaming and Batch execMode
Key: FLINK-32795
URL:
Qingsheng Ren created FLINK-32794:
-
Summary: Release Testing: Verify FLIP-293: Introduce Flink Jdbc
Driver For Sql Gateway
Key: FLINK-32794
URL: https://issues.apache.org/jira/browse/FLINK-32794
Qingsheng Ren created FLINK-32793:
-
Summary: Release Testing: Verify FLINK-31535 - Extend
watermark-related features for SQL
Key: FLINK-32793
URL: https://issues.apache.org/jira/browse/FLINK-32793
Qingsheng Ren created FLINK-32791:
-
Summary: Release Testing: Verify FLIP-308: Support Time Travel
Key: FLINK-32791
URL: https://issues.apache.org/jira/browse/FLINK-32791
Project: Flink
Qingsheng Ren created FLINK-32792:
-
Summary: Release Testing: Verify FLINK-27237 - Partitioned table
statement enhancement
Key: FLINK-32792
URL: https://issues.apache.org/jira/browse/FLINK-32792
Qingsheng Ren created FLINK-32790:
-
Summary: Release Testing: Verify FLIP-311: Support Call Stored
Procedure
Key: FLINK-32790
URL: https://issues.apache.org/jira/browse/FLINK-32790
Project: Flink
Qingsheng Ren created FLINK-32789:
-
Summary: Release Testing: Verify FLIP-303: Support REPLACE TABLE
AS SELECT statement
Key: FLINK-32789
URL: https://issues.apache.org/jira/browse/FLINK-32789
Qingsheng Ren created FLINK-32787:
-
Summary: Release Testing: Verify FLIP-305: Support atomic for
CREATE TABLE AS SELECT(CTAS) statement
Key: FLINK-32787
URL: https://issues.apache.org/jira/browse/FLINK-32787
Qingsheng Ren created FLINK-32786:
-
Summary: Release Testing: Verify FLIP-302: Support TRUNCATE TABLE
statement in batch mode
Key: FLINK-32786
URL: https://issues.apache.org/jira/browse/FLINK-32786
Qingsheng Ren created FLINK-32785:
-
Summary: Release Testing: Verify FLIP-292: Enhance COMPILED PLAN
to support operator-level state TTL configuration
Key: FLINK-32785
URL:
Qingsheng Ren created FLINK-32784:
-
Summary: Release Testing: Verify FLIP-300 Add targetColumns to
DynamicTableSink#Context
Key: FLINK-32784
URL: https://issues.apache.org/jira/browse/FLINK-32784
Qingsheng Ren created FLINK-32783:
-
Summary: Release Testing: Improve parallel download of RocksDB
incremental state
Key: FLINK-32783
URL: https://issues.apache.org/jira/browse/FLINK-32783
Project:
Qingsheng Ren created FLINK-32781:
-
Summary: Release Testing: Add a metric for back-pressure from the
ChangelogStateBackend
Key: FLINK-32781
URL: https://issues.apache.org/jira/browse/FLINK-32781
Qingsheng Ren created FLINK-32782:
-
Summary: Release Testing: Disable WAL in RocksDBWriteBatchWrapper
by default
Key: FLINK-32782
URL: https://issues.apache.org/jira/browse/FLINK-32782
Project:
Qingsheng Ren created FLINK-32780:
-
Summary: Release Testing: Verify FLIP-324: Introduce Runtime
Filter for Flink Batch Jobs
Key: FLINK-32780
URL: https://issues.apache.org/jira/browse/FLINK-32780
Qingsheng Ren created FLINK-32779:
-
Summary: Release Testing: Verify FLIP-301: Hybrid Shuffle supports
Remote Storage
Key: FLINK-32779
URL: https://issues.apache.org/jira/browse/FLINK-32779
Project:
Qingsheng Ren created FLINK-32726:
-
Summary: [Umbrella] Test Flink Release 1.18
Key: FLINK-32726
URL: https://issues.apache.org/jira/browse/FLINK-32726
Project: Flink
Issue Type: Bug
Qingsheng Ren created FLINK-32247:
-
Summary: Normal group by with time attributes after a window group
by is interpreted as GlobalWindowAggregate
Key: FLINK-32247
URL:
Qingsheng Ren created FLINK-31586:
-
Summary: CLONE - CLONE - Propose a pull request for website updates
Key: FLINK-31586
URL: https://issues.apache.org/jira/browse/FLINK-31586
Project: Flink
Qingsheng Ren created FLINK-31583:
-
Summary: Build Release Candidate: 1.17.0-rc3
Key: FLINK-31583
URL: https://issues.apache.org/jira/browse/FLINK-31583
Project: Flink
Issue Type: New
Qingsheng Ren created FLINK-31587:
-
Summary: CLONE - CLONE - Vote on the release candidate
Key: FLINK-31587
URL: https://issues.apache.org/jira/browse/FLINK-31587
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-31585:
-
Summary: CLONE - CLONE - Stage source and binary releases on
dist.apache.org
Key: FLINK-31585
URL: https://issues.apache.org/jira/browse/FLINK-31585
Project: Flink
Qingsheng Ren created FLINK-31584:
-
Summary: CLONE - CLONE - Build and stage Java and Python artifacts
Key: FLINK-31584
URL: https://issues.apache.org/jira/browse/FLINK-31584
Project: Flink
Qingsheng Ren created FLINK-31582:
-
Summary: CLONE - Vote on the release candidate
Key: FLINK-31582
URL: https://issues.apache.org/jira/browse/FLINK-31582
Project: Flink
Issue Type: Sub-task
Qingsheng Ren created FLINK-31580:
-
Summary: CLONE - Stage source and binary releases on
dist.apache.org
Key: FLINK-31580
URL: https://issues.apache.org/jira/browse/FLINK-31580
Project: Flink
Qingsheng Ren created FLINK-31581:
-
Summary: CLONE - Propose a pull request for website updates
Key: FLINK-31581
URL: https://issues.apache.org/jira/browse/FLINK-31581
Project: Flink
Issue
Qingsheng Ren created FLINK-31579:
-
Summary: CLONE - Build and stage Java and Python artifacts
Key: FLINK-31579
URL: https://issues.apache.org/jira/browse/FLINK-31579
Project: Flink
Issue
Qingsheng Ren created FLINK-31578:
-
Summary: Build Release Candidate: 1.17.0-rc2
Key: FLINK-31578
URL: https://issues.apache.org/jira/browse/FLINK-31578
Project: Flink
Issue Type: New
Qingsheng Ren created FLINK-31573:
-
Summary: Nexmark performance drops in 1.17 compared with 1.13
Key: FLINK-31573
URL: https://issues.apache.org/jira/browse/FLINK-31573
Project: Flink
Issue
Qingsheng Ren created FLINK-31421:
-
Summary: DataGeneratorSourceITCase.testGatedRateLimiter failed on
CI
Key: FLINK-31421
URL: https://issues.apache.org/jira/browse/FLINK-31421
Project: Flink
Qingsheng Ren created FLINK-31420:
-
Summary: ThreadInfoRequestCoordinatorTest.testShutDown failed on CI
Key: FLINK-31420
URL: https://issues.apache.org/jira/browse/FLINK-31420
Project: Flink
Qingsheng Ren created FLINK-31418:
-
Summary:
SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI
Key: FLINK-31418
URL: https://issues.apache.org/jira/browse/FLINK-31418
Qingsheng Ren created FLINK-30978:
-
Summary: ExecutorImplITCase.testInterruptExecution hangs waiting
for SQL gateway service closing
Key: FLINK-30978
URL: https://issues.apache.org/jira/browse/FLINK-30978
Qingsheng Ren created FLINK-30936:
-
Summary: Release Testing: Verify FLINK-29941 Support SQL Client
connects to SQL Gateway
Key: FLINK-30936
URL: https://issues.apache.org/jira/browse/FLINK-30936
Qingsheng Ren created FLINK-30926:
-
Summary: [Umbrella] Test Flink Release 1.17
Key: FLINK-30926
URL: https://issues.apache.org/jira/browse/FLINK-30926
Project: Flink
Issue Type: Improvement
Qingsheng Ren created FLINK-30508:
-
Summary: CliClientITCase.testSqlStatements failed with output not
matched with expected
Key: FLINK-30508
URL: https://issues.apache.org/jira/browse/FLINK-30508
Qingsheng Ren created FLINK-30507:
-
Summary:
EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism
could not be initialized
Key: FLINK-30507
URL:
Qingsheng Ren created FLINK-30503:
-
Summary: KafkaSourceITCase$IntegrationTests.testSavepoint failed
with timeout
Key: FLINK-30503
URL: https://issues.apache.org/jira/browse/FLINK-30503
Project:
Qingsheng Ren created FLINK-30393:
-
Summary: PulsarSourceUnorderedE2ECase.testScaleDown failed with
TimeoutException
Key: FLINK-30393
URL: https://issues.apache.org/jira/browse/FLINK-30393
Project:
Qingsheng Ren created FLINK-30246:
-
Summary: Registering the same metric object with different name
and group will conflict in metric reporter
Key: FLINK-30246
URL:
Qingsheng Ren created FLINK-30234:
-
Summary: SourceReaderBase should provide an option to disable
numRecordsIn metric registration
Key: FLINK-30234
URL: https://issues.apache.org/jira/browse/FLINK-30234
Qingsheng Ren created FLINK-30105:
-
Summary: SubtaskExecutionAttemptAccumulatorsInfoTest failed with
JVM exit code 239
Key: FLINK-30105
URL: https://issues.apache.org/jira/browse/FLINK-30105
Qingsheng Ren created FLINK-29899:
-
Summary: flink-runtime tests fail with exit code 137 returned from
Docker
Key: FLINK-29899
URL: https://issues.apache.org/jira/browse/FLINK-29899
Project: Flink
Qingsheng Ren created FLINK-29898:
-
Summary:
ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI
Key: FLINK-29898
URL: https://issues.apache.org/jira/browse/FLINK-29898
Qingsheng Ren created FLINK-29897:
-
Summary: PyFlinkStreamUserDefinedFunctionTests.test_table_function
fails on CI
Key: FLINK-29897
URL: https://issues.apache.org/jira/browse/FLINK-29897
Project:
Qingsheng Ren created FLINK-29567:
-
Summary: Revert sink output metric names from numRecordsSend back
to numRecordsOut
Key: FLINK-29567
URL: https://issues.apache.org/jira/browse/FLINK-29567
Project:
Qingsheng Ren created FLINK-29389:
-
Summary: Update documentation of JDBC and HBase lookup table for
new caching options
Key: FLINK-29389
URL: https://issues.apache.org/jira/browse/FLINK-29389
Qingsheng Ren created FLINK-29219:
-
Summary: CREATE TABLE AS statement blocks SQL client's execution
Key: FLINK-29219
URL: https://issues.apache.org/jira/browse/FLINK-29219
Project: Flink
Qingsheng Ren created FLINK-29218:
-
Summary: ADD JAR syntax could not work with Hive catalog in SQL
client
Key: FLINK-29218
URL: https://issues.apache.org/jira/browse/FLINK-29218
Project: Flink
Qingsheng Ren created FLINK-29153:
-
Summary: KafkaConsumerThread should catch WakeupException when
committing offsets
Key: FLINK-29153
URL: https://issues.apache.org/jira/browse/FLINK-29153
Project:
Qingsheng Ren created FLINK-28991:
-
Summary: Add documentation for lookup table caching feature
Key: FLINK-28991
URL: https://issues.apache.org/jira/browse/FLINK-28991
Project: Flink
Issue
Qingsheng Ren created FLINK-28989:
-
Summary: Release Testing: Verify FLIP-221 lookup table cache
Key: FLINK-28989
URL: https://issues.apache.org/jira/browse/FLINK-28989
Project: Flink
Issue
Qingsheng Ren created FLINK-28948:
-
Summary: Add more test coverage for lookup table full caching
Key: FLINK-28948
URL: https://issues.apache.org/jira/browse/FLINK-28948
Project: Flink
Issue
Qingsheng Ren created FLINK-28890:
-
Summary: Incorrect semantic of latestLoadTime in
CachingLookupFunction and CachingAsyncLookupFunction
Key: FLINK-28890
URL: https://issues.apache.org/jira/browse/FLINK-28890
Qingsheng Ren created FLINK-28885:
-
Summary: Improve LookupFunction to support different kinds of
RowData as key row
Key: FLINK-28885
URL: https://issues.apache.org/jira/browse/FLINK-28885
Project:
Qingsheng Ren created FLINK-28868:
-
Summary: Migrate JDBC table connector to the new LookupFunction
interface
Key: FLINK-28868
URL: https://issues.apache.org/jira/browse/FLINK-28868
Project: Flink
Qingsheng Ren created FLINK-28854:
-
Summary: Migrate JDBC table connector to the new LookupFunction
interface
Key: FLINK-28854
URL: https://issues.apache.org/jira/browse/FLINK-28854
Project: Flink
Qingsheng Ren created FLINK-28532:
-
Summary: Support InputFormat as full caching provider in lookup
table source
Key: FLINK-28532
URL: https://issues.apache.org/jira/browse/FLINK-28532
Project: Flink
Qingsheng Ren created FLINK-28421:
-
Summary: Support full caching in lookup table source
Key: FLINK-28421
URL: https://issues.apache.org/jira/browse/FLINK-28421
Project: Flink
Issue Type:
Qingsheng Ren created FLINK-28420:
-
Summary: Support partial lookup caching in lookup join runners
Key: FLINK-28420
URL: https://issues.apache.org/jira/browse/FLINK-28420
Project: Flink
Qingsheng Ren created FLINK-28419:
-
Summary: Add runtime provider interface for full caching lookup
Key: FLINK-28419
URL: https://issues.apache.org/jira/browse/FLINK-28419
Project: Flink
Qingsheng Ren created FLINK-28418:
-
Summary: Add runtime provider interface for partial caching lookup
Key: FLINK-28418
URL: https://issues.apache.org/jira/browse/FLINK-28418
Project: Flink
Qingsheng Ren created FLINK-28417:
-
Summary: Add interface and default implementation for cache in
lookup table
Key: FLINK-28417
URL: https://issues.apache.org/jira/browse/FLINK-28417
Project: Flink
Qingsheng Ren created FLINK-28416:
-
Summary: Add the new LookupFunction interface for Lookup table
source
Key: FLINK-28416
URL: https://issues.apache.org/jira/browse/FLINK-28416
Project: Flink
Qingsheng Ren created FLINK-28415:
-
Summary: FLIP-221: Support Partial and Full Caching in Lookup
Table Source
Key: FLINK-28415
URL: https://issues.apache.org/jira/browse/FLINK-28415
Project: Flink
Qingsheng Ren created FLINK-27865:
-
Summary: Add guide and example for configuring SASL and SSL in
Kafka SQL connector document
Key: FLINK-27865
URL: https://issues.apache.org/jira/browse/FLINK-27865
Qingsheng Ren created FLINK-27636:
-
Summary: Add data type coverage and sync / async tests for catalog
in connector testing framework
Key: FLINK-27636
URL: https://issues.apache.org/jira/browse/FLINK-27636
1 - 100 of 151 matches
Mail list logo
