Eason Ye created FLINK-35806:
Summary: [Flink-CDC][MongoDB] Add friendly reminder if the
configured collectionList is wrong
Key: FLINK-35806
URL: https://issues.apache.org/jira/browse/FLINK-35806
Project
yux created FLINK-35805:
---
Summary: Add "OpType" metadata column in transform
Key: FLINK-35805
URL: https://issues.apache.org/jira/browse/FLINK-35805
Project: Flink
Issue Type: I
roncenzhao created FLINK-35804:
--
Summary: Incorrect calc merge generate wrong plan about
udtf+join+udf
Key: FLINK-35804
URL: https://issues.apache.org/jira/browse/FLINK-35804
Project: Flink
Rui Fan created FLINK-35803:
---
Summary: ResumeCheckpointManuallyITCase fails with checkpoint file
merging
Key: FLINK-35803
URL: https://issues.apache.org/jira/browse/FLINK-35803
Project: Flink
LvYanquan created FLINK-35802:
-
Summary: Deadlock may happen after adding new tables
Key: FLINK-35802
URL: https://issues.apache.org/jira/browse/FLINK-35802
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-35801:
--
Summary: testSwitchFromEnablingToDisablingFileMerging failed in AZP
Key: FLINK-35801
URL: https://issues.apache.org/jira/browse/FLINK-35801
Project: Flink
Issue
Anupam Aggarwal created FLINK-35800:
---
Summary: Update chinese documentation for json_(un)quote function
Key: FLINK-35800
URL: https://issues.apache.org/jira/browse/FLINK-35800
Project: Flink
Jim Hughes created FLINK-35799:
--
Summary: Add CompiledPlan annotations to BatchExecCalc
Key: FLINK-35799
URL: https://issues.apache.org/jira/browse/FLINK-35799
Project: Flink
Issue Type: Sub
Jim Hughes created FLINK-35798:
--
Summary: Implement a BatchCompiledPlanTestBase
Key: FLINK-35798
URL: https://issues.apache.org/jira/browse/FLINK-35798
Project: Flink
Issue Type: Sub-task
Jim Hughes created FLINK-35797:
--
Summary: FLIP-456: CompiledPlan support for Batch Execution Mode
Key: FLINK-35797
URL: https://issues.apache.org/jira/browse/FLINK-35797
Project: Flink
Issue
Arvid Heise created FLINK-35796:
---
Summary: Ensure that MailboxExecutor.submit is used correctly
Key: FLINK-35796
URL: https://issues.apache.org/jira/browse/FLINK-35796
Project: Flink
Issue
Wencong Liu created FLINK-35795:
---
Summary: FLIP-466: Introduce ProcessFunction Attribute in
DataStream API V2
Key: FLINK-35795
URL: https://issues.apache.org/jira/browse/FLINK-35795
Project: Flink
David Kornel created FLINK-35794:
Summary: Ability to skip kubernetes tests in e2e nightly test
script
Key: FLINK-35794
URL: https://issues.apache.org/jira/browse/FLINK-35794
Project: Flink
Weijie Guo created FLINK-35793:
--
Summary: BatchSQLTest.testBatchSQL failed in hybrid shuffle
selective mode
Key: FLINK-35793
URL: https://issues.apache.org/jira/browse/FLINK-35793
Project: Flink
xuyang created FLINK-35792:
--
Summary: Sorting by proctime does not work in rank
Key: FLINK-35792
URL: https://issues.apache.org/jira/browse/FLINK-35792
Project: Flink
Issue Type: Bug
LvYanquan created FLINK-35791:
-
Summary: Add database and table infos to Kafka json output.
Key: FLINK-35791
URL: https://issues.apache.org/jira/browse/FLINK-35791
Project: Flink
Issue Type
Sergio Peña created FLINK-35790:
---
Summary: Update docs for new schema definition in CTAS and RTAS
Key: FLINK-35790
URL: https://issues.apache.org/jira/browse/FLINK-35790
Project: Flink
Issue
Sergio Peña created FLINK-35789:
---
Summary: Allow WATERMARK & PRIMARY KEY in CREATE TABLE AS (CTAS)
Key: FLINK-35789
URL: https://issues.apache.org/jira/browse/FLINK-35789
Project: Flink
I
João Boto created FLINK-35788:
-
Summary: Deprecate old InputFormat and SinkFunction
Key: FLINK-35788
URL: https://issues.apache.org/jira/browse/FLINK-35788
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-35787:
-
Summary: DefaultSlotStatusSyncer might bring down JVM (exit code
239 instead of a proper shutdown)
Key: FLINK-35787
URL: https://issues.apache.org/jira/browse/FLINK
Roman Khachatryan created FLINK-35786:
-
Summary: NPE in BlobServer / shutdownHook
Key: FLINK-35786
URL: https://issues.apache.org/jira/browse/FLINK-35786
Project: Flink
Issue Type: Bug
URL: https://issues.apache.org/jira/browse/FLINK-35785
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing, Table SQL / Client
Reporter: Martijn Visser
Tested with Flink 1.20 RC0
Reproducer:
{code:sql}
-- Create the product table
CREATE TABLE `product
Zakelly Lan created FLINK-35784:
---
Summary: The cp file-merging directory not properly registered in
SharedStateRegistry
Key: FLINK-35784
URL: https://issues.apache.org/jira/browse/FLINK-35784
Project
layhuts created FLINK-35783:
---
Summary: Flink CDC Could not start the yaml Job
Key: FLINK-35783
URL: https://issues.apache.org/jira/browse/FLINK-35783
Project: Flink
Issue Type: Bug
Yi Cai created FLINK-35782:
--
Summary: Flink connector jdbc works wrong when using sql gateway
Key: FLINK-35782
URL: https://issues.apache.org/jira/browse/FLINK-35782
Project: Flink
Issue Type: Bug
yux created FLINK-35781:
---
Summary: Make pipeline parallelism config optional
Key: FLINK-35781
URL: https://issues.apache.org/jira/browse/FLINK-35781
Project: Flink
Issue Type: Improvement
xiangyu feng created FLINK-35780:
Summary: Support state migration from disabling to enabling ttl in
RocksDBState
Key: FLINK-35780
URL: https://issues.apache.org/jira/browse/FLINK-35780
Project
Ahmed Hamdy created FLINK-35779:
---
Summary: Update documentation for PubSubSinkV2
Key: FLINK-35779
URL: https://issues.apache.org/jira/browse/FLINK-35779
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-35778:
---
Summary: Escape URI reserved characters when creating file-merging
directories
Key: FLINK-35778
URL: https://issues.apache.org/jira/browse/FLINK-35778
Project: Flink
Gyula Fora created FLINK-35777:
--
Summary: Observe session jobs during cleanup
Key: FLINK-35777
URL: https://issues.apache.org/jira/browse/FLINK-35777
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-35776:
--
Summary: Simplify job observe logic
Key: FLINK-35776
URL: https://issues.apache.org/jira/browse/FLINK-35776
Project: Flink
Issue Type: Improvement
911432 created FLINK-35775:
--
Summary: README.md changes
Key: FLINK-35775
URL: https://issues.apache.org/jira/browse/FLINK-35775
Project: Flink
Issue Type: Improvement
Affects Versions: 1.20.0
Wenkai Qi created FLINK-35774:
-
Summary: The cache of transform is not updated after process
schema change event
Key: FLINK-35774
URL: https://issues.apache.org/jira/browse/FLINK-35774
Project: Flink
Piotr Nowojski created FLINK-35773:
--
Summary: Document s5cmd
Key: FLINK-35773
URL: https://issues.apache.org/jira/browse/FLINK-35773
Project: Flink
Issue Type: Sub-task
Reporter
Piotr Nowojski created FLINK-35772:
--
Summary: Deprecate/remove DuplicatingFileSystem
Key: FLINK-35772
URL: https://issues.apache.org/jira/browse/FLINK-35772
Project: Flink
Issue Type: Sub
Piotr Nowojski created FLINK-35771:
--
Summary: Limit s5cmd resource usage
Key: FLINK-35771
URL: https://issues.apache.org/jira/browse/FLINK-35771
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-35770:
--
Summary: Interrupt s5cmd call on cancellation
Key: FLINK-35770
URL: https://issues.apache.org/jira/browse/FLINK-35770
Project: Flink
Issue Type: Sub
Roman Khachatryan created FLINK-35769:
-
Summary: State files might not be deleted on task cancellation
Key: FLINK-35769
URL: https://issues.apache.org/jira/browse/FLINK-35769
Project: Flink
Piotr Nowojski created FLINK-35768:
--
Summary: Use native file copy in RocksDBStateDownloader
Key: FLINK-35768
URL: https://issues.apache.org/jira/browse/FLINK-35768
Project: Flink
Issue
Piotr Nowojski created FLINK-35767:
--
Summary: Provide native file copy support for S3 using s5cmd
Key: FLINK-35767
URL: https://issues.apache.org/jira/browse/FLINK-35767
Project: Flink
Junrui Li created FLINK-35766:
-
Summary: When the job contains many YieldingOperatorFactory
instances, compiling the JobGraph hangs
Key: FLINK-35766
URL: https://issues.apache.org/jira/browse/FLINK-35766
RocMarshal created FLINK-35765:
--
Summary: Support Fine Grained Resource Specifications for Adaptive
Scheduler
Key: FLINK-35765
URL: https://issues.apache.org/jira/browse/FLINK-35765
Project: Flink
Liu Liu created FLINK-35764:
---
Summary: TimerGauge is incorrect when update is called during a
measurement
Key: FLINK-35764
URL: https://issues.apache.org/jira/browse/FLINK-35764
Project: Flink
911432 created FLINK-35763:
--
Summary: Bump Java version
Key: FLINK-35763
URL: https://issues.apache.org/jira/browse/FLINK-35763
Project: Flink
Issue Type: Improvement
Affects Versions: 1.20.0
yux created FLINK-35762:
---
Summary: Cache hashCode for immutable map key classes
Key: FLINK-35762
URL: https://issues.apache.org/jira/browse/FLINK-35762
Project: Flink
Issue Type: Improvement
Rui Fan created FLINK-35761:
---
Summary: Speed up the restore process of unaligned checkpoint
Key: FLINK-35761
URL: https://issues.apache.org/jira/browse/FLINK-35761
Project: Flink
Issue Type
Hongshun Wang created FLINK-35760:
-
Summary: [docs] Add scan.newly-added-table.enabled to docs.
Key: FLINK-35760
URL: https://issues.apache.org/jira/browse/FLINK-35760
Project: Flink
Issue
Hongshun Wang created FLINK-35759:
-
Summary: [docs] Add 'scan.incremental.snapshot.backfill.skip' to
docs.
Key: FLINK-35759
URL: https://issues.apache.org/jira/browse/FLINK-35759
Project: Flink
LvYanquan created FLINK-35758:
-
Summary: [Doc] add scan.startup.timestamp-millis options to MySQL
connector docs.
Key: FLINK-35758
URL: https://issues.apache.org/jira/browse/FLINK-35758
Project: Flink
shikai.wang created FLINK-35757:
---
Summary: support read new tables when scanNewlyTableAdded is
enabled
Key: FLINK-35757
URL: https://issues.apache.org/jira/browse/FLINK-35757
Project: Flink
Weijie Guo created FLINK-35756:
--
Summary:
FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no
output for 900 seconds
Key: FLINK-35756
URL: https://issues.apache.org/jira/browse/FLINK-35756
Dawid Wysakowicz created FLINK-35755:
Summary: Upgrade flink-shaded to 19.0
Key: FLINK-35755
URL: https://issues.apache.org/jira/browse/FLINK-35755
Project: Flink
Issue Type: Sub-task
Weijie Guo created FLINK-35754:
--
Summary: SqlGatewayE2ECase.testMaterializedTableInFullMode failed
due to Internal Server Error
Key: FLINK-35754
URL: https://issues.apache.org/jira/browse/FLINK-35754
Weijie Guo created FLINK-35753:
--
Summary:
ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to
ArrayIndexOutOfBoundsException
Key: FLINK-35753
URL: https://issues.apache.org/jira/browse
Jacky Lau created FLINK-35752:
-
Summary: Migrate PythonUtil
Key: FLINK-35752
URL: https://issues.apache.org/jira/browse/FLINK-35752
Project: Flink
Issue Type: Sub-task
Components
Jacky Lau created FLINK-35751:
-
Summary: Migrate SplitPythonConditionFromCorrelateRule
Key: FLINK-35751
URL: https://issues.apache.org/jira/browse/FLINK-35751
Project: Flink
Issue Type: Sub-task
RocMarshal created FLINK-35750:
--
Summary: The latency marker metrics aren't updated after failover
Key: FLINK-35750
URL: https://issues.apache.org/jira/browse/FLINK-35750
Project: Flink
Issue
Jimmy Zhao created FLINK-35749:
--
Summary: Kafka sink component will lose data when kafka cluster is
unavailable for a while
Key: FLINK-35749
URL: https://issues.apache.org/jira/browse/FLINK-35749
Matthias Pohl created FLINK-35748:
-
Summary: DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime
with MiniBatch mode and RocksDB backend enabled
Key: FLINK-35748
URL: https://issues.apache.org/jira/browse
dncba created FLINK-35747:
-
Summary: customer ‘rest.bind-address' config overwrite by code
Key: FLINK-35747
URL: https://issues.apache.org/jira/browse/FLINK-35747
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-35746:
--
Summary: Add logic to override observed config based on settings
observed through REST API
Key: FLINK-35746
URL: https://issues.apache.org/jira/browse/FLINK-35746
Zhenqiu Huang created FLINK-35745:
-
Summary: Add namespace convention doc for Flink lineage
Key: FLINK-35745
URL: https://issues.apache.org/jira/browse/FLINK-35745
Project: Flink
Issue Type
Diljeet Singh created FLINK-35744:
-
Summary: Support flink 1.19 config.yaml format
Key: FLINK-35744
URL: https://issues.apache.org/jira/browse/FLINK-35744
Project: Flink
Issue Type
Wenkai Qi created FLINK-35743:
-
Summary: The time zone configuration for temporal functions is not
effective
Key: FLINK-35743
URL: https://issues.apache.org/jira/browse/FLINK-35743
Project: Flink
Roman Khachatryan created FLINK-35742:
-
Summary: Don't create RocksDB CF if task cancellation is in
progress
Key: FLINK-35742
URL: https://issues.apache.org/jira/browse/FLINK-35742
Project: Flink
bear.xiong created FLINK-35741:
--
Summary: It' tell me 'This is a bug. Please file an issue.' when I
executing the Flink Table API
Key: FLINK-35741
URL: https://issues.apache.org/jira/browse/FLINK-35741
Lee SeungMin created FLINK-35740:
Summary: [mysql] Allow column as chunk key even if not in Primary
Keys
Key: FLINK-35740
URL: https://issues.apache.org/jira/browse/FLINK-35740
Project: Flink
Piotr Nowojski created FLINK-35739:
--
Summary: FLIP-444: Native file copy support
Key: FLINK-35739
URL: https://issues.apache.org/jira/browse/FLINK-35739
Project: Flink
Issue Type: New
://issues.apache.org/jira/browse/FLINK-35738
Project: Flink
Issue Type: Sub-task
Components: Runtime / State Backends
Reporter: Rui Fan
The problem occurs when using RocksDB and specific queries/jobs (please see the
ticket for the detailed description).
To test
Feng Jiajie created FLINK-35737:
---
Summary: Prevent Memory Leak by Closing
MemoryExecutionGraphInfoStore on MiniCluster Shutdown
Key: FLINK-35737
URL: https://issues.apache.org/jira/browse/FLINK-35737
yux created FLINK-35736:
---
Summary: Add E2e migration scripts for Flink CDC
Key: FLINK-35736
URL: https://issues.apache.org/jira/browse/FLINK-35736
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-35735:
-
Summary: Don't list catalogs when closing session
Key: FLINK-35735
URL: https://issues.apache.org/jira/browse/FLINK-35735
Project: Flink
Issue Type
Feng Jin created FLINK-35734:
Summary: Not override the user-defined checkpoint interval in
continuous mode.
Key: FLINK-35734
URL: https://issues.apache.org/jira/browse/FLINK-35734
Project: Flink
RocMarshal created FLINK-35733:
--
Summary: Change org.jetbrains.annotations.NotNull to
javax.annotation.Nonnull
Key: FLINK-35733
URL: https://issues.apache.org/jira/browse/FLINK-35733
Project: Flink
Rob Young created FLINK-35732:
-
Summary: flink-sql-client.sh fails with ClassNotFoundException
depending on it's location
Key: FLINK-35732
URL: https://issues.apache.org/jira/browse/FLINK-35732
Project
Junrui Li created FLINK-35731:
-
Summary: Sink V2 operator is mistakenly assumed always to be
parallelism configured
Key: FLINK-35731
URL: https://issues.apache.org/jira/browse/FLINK-35731
Project: Flink
Wenkai Qi created FLINK-35730:
-
Summary: PipelineDefinitionParser add parse string method
Key: FLINK-35730
URL: https://issues.apache.org/jira/browse/FLINK-35730
Project: Flink
Issue Type: New
Matthias Pohl created FLINK-35729:
-
Summary: HiveITCase.testReadWriteHive
Key: FLINK-35729
URL: https://issues.apache.org/jira/browse/FLINK-35729
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-35728:
-
Summary: PyFlink end-to-end test because miniconda couldn't be
downloaded
Key: FLINK-35728
URL: https://issues.apache.org/jira/browse/FLINK-35728
Project: Flink
Matthias Pohl created FLINK-35727:
-
Summary: "Run kubernetes pyflink application test" failed due to
access denied issue
Key: FLINK-35727
URL: https://issues.apache.org/jira/browse/F
David Perkins created FLINK-35726:
-
Summary: Data Stream to Table API converts Map to RAW
'java.util.Map'
Key: FLINK-35726
URL: https://issues.apache.org/jira/browse/FLINK-35726
Project: Flink
Jim Hughes created FLINK-35725:
--
Summary: Translate new DISTRIBUTED BY documentation into Chinese
Key: FLINK-35725
URL: https://issues.apache.org/jira/browse/FLINK-35725
Project: Flink
Issue
zhi.wang created FLINK-35724:
Summary: javax.xml.bind.JAXBException not found with jdk11 while
writing to oss
Key: FLINK-35724
URL: https://issues.apache.org/jira/browse/FLINK-35724
Project: Flink
Dawid Wysakowicz created FLINK-35723:
Summary: Publish shaded jsonpath
Key: FLINK-35723
URL: https://issues.apache.org/jira/browse/FLINK-35723
Project: Flink
Issue Type: Sub-task
Matthias Pohl created FLINK-35722:
-
Summary:
CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint
fails because of missed operator event
Key: FLINK-35722
URL: https://issues.apache.org/jira
://issues.apache.org/jira/browse/FLINK-35721
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.19.1
Reporter: jinzhuguang
Attachments: image-2024-06-28-16-57-54-354.png
I found out that in the Flink SQL documentation
Nicolas Ferrario created FLINK-35720:
Summary: flink-connector-kafka fails to restore from checkpoint
when using an EXACTLY_ONCE sink
Key: FLINK-35720
URL: https://issues.apache.org/jira/browse/FLINK-35720
zyh created FLINK-35719:
---
Summary: [Source]NullPointerException cause by
RecordsWithSplitIds.finishedSplits()
Key: FLINK-35719
URL: https://issues.apache.org/jira/browse/FLINK-35719
Project: Flink
LvYanquan created FLINK-35718:
-
Summary: Cherrypick DBZ-5333 to fix frequently failover by
EOFException.
Key: FLINK-35718
URL: https://issues.apache.org/jira/browse/FLINK-35718
Project: Flink
Sergio Peña created FLINK-35717:
---
Summary: Allow DISTRIBUTED BY in CREATE TABLE AS (CTAS)
Key: FLINK-35717
URL: https://issues.apache.org/jira/browse/FLINK-35717
Project: Flink
Issue Type: Sub
Alan Sheinberg created FLINK-35716:
--
Summary: Fix use of AsyncScalarFunction in join conditions
Key: FLINK-35716
URL: https://issues.apache.org/jira/browse/FLINK-35716
Project: Flink
Issue
Hongshun Wang created FLINK-35715:
-
Summary: Mysql Source support schema cache to deserialize record
Key: FLINK-35715
URL: https://issues.apache.org/jira/browse/FLINK-35715
Project: Flink
melin created FLINK-35714:
-
Summary: Flink CDC pipeline sink support Automatic create tag
Key: FLINK-35714
URL: https://issues.apache.org/jira/browse/FLINK-35714
Project: Flink
Issue Type
wuzexian created FLINK-35713:
Summary: add
Key: FLINK-35713
URL: https://issues.apache.org/jira/browse/FLINK-35713
Project: Flink
Issue Type: Improvement
Reporter: wuzexian
Weijie Guo created FLINK-35712:
--
Summary: [Release-1.20] Prepare RC0 release
Key: FLINK-35712
URL: https://issues.apache.org/jira/browse/FLINK-35712
Project: Flink
Issue Type: Sub-task
Weijie Guo created FLINK-35711:
--
Summary: LocalRecoveryITCase failed on AZP due to exit code: 127
Key: FLINK-35711
URL: https://issues.apache.org/jira/browse/FLINK-35711
Project: Flink
Issue
Weijie Guo created FLINK-35710:
--
Summary: ClusterEntrypointTest failed on AZP due to exit code: 239
Key: FLINK-35710
URL: https://issues.apache.org/jira/browse/FLINK-35710
Project: Flink
Issue
Sergio Peña created FLINK-35709:
---
Summary: Allow reordering source column names in CTAS / RTAS
Key: FLINK-35709
URL: https://issues.apache.org/jira/browse/FLINK-35709
Project: Flink
Issue Type
Sergio Peña created FLINK-35708:
---
Summary: Allow defining a schema in REPLACE TABLE AS (RTAS)
Key: FLINK-35708
URL: https://issues.apache.org/jira/browse/FLINK-35708
Project: Flink
Issue Type
Sergio Peña created FLINK-35707:
---
Summary: Allow column definition in CREATE TABLE AS (CTAS)
Key: FLINK-35707
URL: https://issues.apache.org/jira/browse/FLINK-35707
Project: Flink
Issue Type
1 - 100 of 32971 matches
Mail list logo
