Caizhi Weng created FLINK-13198:
---
Summary: Introduce TimeLength in configuration package
Key: FLINK-13198
URL: https://issues.apache.org/jira/browse/FLINK-13198
Project: Flink
Issue Type: Impro
Caizhi Weng created FLINK-13236:
---
Summary: Fix bug and improve performance in TopNBuffer
Key: FLINK-13236
URL: https://issues.apache.org/jira/browse/FLINK-13236
Project: Flink
Issue Type: Impro
Caizhi Weng created FLINK-13258:
---
Summary: Add tests for LongHashPartition, StringCallGen and
EqualiserCodeGenerator
Key: FLINK-13258
URL: https://issues.apache.org/jira/browse/FLINK-13258
Project: Flin
Caizhi Weng created FLINK-13304:
---
Summary: Fix implementation of getString and getBinary method in
NestedRow
Key: FLINK-13304
URL: https://issues.apache.org/jira/browse/FLINK-13304
Project: Flink
Caizhi Weng created FLINK-13322:
---
Summary: Fix serializer snapshot recovery in BaseArray and BaseMap
serializers.
Key: FLINK-13322
URL: https://issues.apache.org/jira/browse/FLINK-13322
Project: Flink
Caizhi Weng created FLINK-13323:
---
Summary: Add tests for complex data formats (generic array,
generic map, etc.)
Key: FLINK-13323
URL: https://issues.apache.org/jira/browse/FLINK-13323
Project: Flink
Caizhi Weng created FLINK-13348:
---
Summary: Table schema is modified when pushing projection to table
source
Key: FLINK-13348
URL: https://issues.apache.org/jira/browse/FLINK-13348
Project: Flink
Caizhi Weng created FLINK-13410:
---
Summary: Csv input format does not support LocalDate
Key: FLINK-13410
URL: https://issues.apache.org/jira/browse/FLINK-13410
Project: Flink
Issue Type: Test
Caizhi Weng created FLINK-13438:
---
Summary: Fix Hive connector with DataTypes.DATE/TIME/TIMESTAMP
support
Key: FLINK-13438
URL: https://issues.apache.org/jira/browse/FLINK-13438
Project: Flink
Caizhi Weng created FLINK-13490:
---
Summary: Fix return null in JDBCUtils::getFieldFromResultSet
Key: FLINK-13490
URL: https://issues.apache.org/jira/browse/FLINK-13490
Project: Flink
Issue Type:
Caizhi Weng created FLINK-13880:
---
Summary: The behavior of JobExecutionResult.getAccumulatorResult
does not match its java doc
Key: FLINK-13880
URL: https://issues.apache.org/jira/browse/FLINK-13880
Pro
Caizhi Weng created FLINK-15987:
---
Summary: SELECT 1.0e0 / 0.0e0 throws NumberFormatException
Key: FLINK-15987
URL: https://issues.apache.org/jira/browse/FLINK-15987
Project: Flink
Issue Type: B
Caizhi Weng created FLINK-16541:
---
Summary: Document of table.exec.shuffle-mode is incorrect
Key: FLINK-16541
URL: https://issues.apache.org/jira/browse/FLINK-16541
Project: Flink
Issue Type: Bu
Caizhi Weng created FLINK-16543:
---
Summary: Support setting schedule mode by config for Blink planner
in batch mode
Key: FLINK-16543
URL: https://issues.apache.org/jira/browse/FLINK-16543
Project: Flink
Caizhi Weng created FLINK-17023:
---
Summary: The format checking of extractExecutionParams in
config.sh is incorrect
Key: FLINK-17023
URL: https://issues.apache.org/jira/browse/FLINK-17023
Project: Flink
Caizhi Weng created FLINK-17045:
---
Summary: If multiple views are based on tables not defined in the
yaml config file, dropping one of the views will throw exception
Key: FLINK-17045
URL: https://issues.apache.org/ji
Caizhi Weng created FLINK-17080:
---
Summary: Utils.CollectHelper is possible to throw NPE if the sink
is up but not initialized when the job fails
Key: FLINK-17080
URL: https://issues.apache.org/jira/browse/FLINK-1708
Caizhi Weng created FLINK-17081:
---
Summary: Batch test classes in Blink planner does not extend
TestLogger
Key: FLINK-17081
URL: https://issues.apache.org/jira/browse/FLINK-17081
Project: Flink
Caizhi Weng created FLINK-17083:
---
Summary: Restrict users of accumulators not to return null in
Accumulator#getLocalValue
Key: FLINK-17083
URL: https://issues.apache.org/jira/browse/FLINK-17083
Project:
Caizhi Weng created FLINK-17197:
---
Summary: ContinuousFileReaderOperator might shade the real
exception when processing records
Key: FLINK-17197
URL: https://issues.apache.org/jira/browse/FLINK-17197
Pro
Caizhi Weng created FLINK-17396:
---
Summary: Support SHOW MODULES in Flink SQL
Key: FLINK-17396
URL: https://issues.apache.org/jira/browse/FLINK-17396
Project: Flink
Issue Type: New Feature
Caizhi Weng created FLINK-14347:
---
Summary: YARNSessionFIFOITCase.checkForProhibitedLogContents found
a log with prohibited string
Key: FLINK-14347
URL: https://issues.apache.org/jira/browse/FLINK-14347
Caizhi Weng created FLINK-14348:
---
Summary: YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a
fails to delete files
Key: FLINK-14348
URL: https://issues.apache.org/jira/browse/FLINK-14348
Project:
Caizhi Weng created FLINK-14960:
---
Summary: Dependency shading of table modules test fails on Travis
Key: FLINK-14960
URL: https://issues.apache.org/jira/browse/FLINK-14960
Project: Flink
Issue
Caizhi Weng created FLINK-15570:
---
Summary: Support inserting into non-empty csv tables
Key: FLINK-15570
URL: https://issues.apache.org/jira/browse/FLINK-15570
Project: Flink
Issue Type: Improve
Caizhi Weng created FLINK-10036:
---
Summary: Flink's CSV output format is not consistent with the
standard.
Key: FLINK-10036
URL: https://issues.apache.org/jira/browse/FLINK-10036
Project: Flink
Caizhi Weng created FLINK-19411:
---
Summary: MultipleInputStreamTask fails with RuntimeException when
its input contains union
Key: FLINK-19411
URL: https://issues.apache.org/jira/browse/FLINK-19411
Proje
Caizhi Weng created FLINK-19434:
---
Summary: Add StreamJobGraphGenerator support for source chaining
Key: FLINK-19434
URL: https://issues.apache.org/jira/browse/FLINK-19434
Project: Flink
Issue T
Caizhi Weng created FLINK-19621:
---
Summary: Introduce Multi-input operator in Blink planner
Key: FLINK-19621
URL: https://issues.apache.org/jira/browse/FLINK-19621
Project: Flink
Issue Type: New
Caizhi Weng created FLINK-19623:
---
Summary: Introduce ExecEdge to describe information on input edges
for ExecNode
Key: FLINK-19623
URL: https://issues.apache.org/jira/browse/FLINK-19623
Project: Flink
Caizhi Weng created FLINK-19624:
---
Summary: Update deadlock break-up algorithm to cover more cases
Key: FLINK-19624
URL: https://issues.apache.org/jira/browse/FLINK-19624
Project: Flink
Issue Ty
Caizhi Weng created FLINK-19625:
---
Summary: Introduce multi-input exec node
Key: FLINK-19625
URL: https://issues.apache.org/jira/browse/FLINK-19625
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-19626:
---
Summary: Introduce multi-input operator construction algorithm
Key: FLINK-19626
URL: https://issues.apache.org/jira/browse/FLINK-19626
Project: Flink
Issue Typ
Caizhi Weng created FLINK-19627:
---
Summary: Introduce multi-input operator for batch
Key: FLINK-19627
URL: https://issues.apache.org/jira/browse/FLINK-19627
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-19628:
---
Summary: Introduce multi-input operator for streaming
Key: FLINK-19628
URL: https://issues.apache.org/jira/browse/FLINK-19628
Project: Flink
Issue Type: Sub-ta
Caizhi Weng created FLINK-19641:
---
Summary: Optimize parallelism calculating of HiveTableSource by
checking file number
Key: FLINK-19641
URL: https://issues.apache.org/jira/browse/FLINK-19641
Project: Fl
Caizhi Weng created FLINK-19756:
---
Summary: Use multi-input optimization by default
Key: FLINK-19756
URL: https://issues.apache.org/jira/browse/FLINK-19756
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-19769:
---
Summary: Reuse StreamRecord in SourceOutputWithWatermarks#collect
Key: FLINK-19769
URL: https://issues.apache.org/jira/browse/FLINK-19769
Project: Flink
Issue
Caizhi Weng created FLINK-19780:
---
Summary: FlinkRelMdDistinctRowCount#getDistinctRowCount(Calc) will
always return 0 when number of rows are large
Key: FLINK-19780
URL: https://issues.apache.org/jira/browse/FLINK-19
Caizhi Weng created FLINK-19811:
---
Summary: FlinkRexUtil#simplify should simplify search in
conjunctions
Key: FLINK-19811
URL: https://issues.apache.org/jira/browse/FLINK-19811
Project: Flink
I
Caizhi Weng created FLINK-19870:
---
Summary: Fix special case when the reuse of exchange causes the
deadlock
Key: FLINK-19870
URL: https://issues.apache.org/jira/browse/FLINK-19870
Project: Flink
Caizhi Weng created FLINK-19874:
---
Summary: Apply JoinDeriveNullFilterRule after join reorder
Key: FLINK-19874
URL: https://issues.apache.org/jira/browse/FLINK-19874
Project: Flink
Issue Type: I
Caizhi Weng created FLINK-19908:
---
Summary: FlinkLogicalTableSourceScan and
CommonPhysicalTableSourceScan should respect source reuse config option
Key: FLINK-19908
URL: https://issues.apache.org/jira/browse/FLINK-19
Caizhi Weng created FLINK-19939:
---
Summary: Remove redundant union from multiple input node
Key: FLINK-19939
URL: https://issues.apache.org/jira/browse/FLINK-19939
Project: Flink
Issue Type: Imp
Caizhi Weng created FLINK-19940:
---
Summary: Task names on web UI should change when an operator chain
is chained with sources
Key: FLINK-19940
URL: https://issues.apache.org/jira/browse/FLINK-19940
Proje
Caizhi Weng created FLINK-19959:
---
Summary: Multiple input creation algorithm will deduce an
incorrect input order if the inputs are related under PIPELINED shuffle mode
Key: FLINK-19959
URL: https://issues.apache.or
Caizhi Weng created FLINK-19990:
---
Summary: MultipleInputNodeCreationProcessor#isChainableSource
should consider DataStreamScanProvider
Key: FLINK-19990
URL: https://issues.apache.org/jira/browse/FLINK-19990
Caizhi Weng created FLINK-20186:
---
Summary: FactoryUtil will give an incorrect error message when
multiple factories fit the connector identifier
Key: FLINK-20186
URL: https://issues.apache.org/jira/browse/FLINK-2018
Caizhi Weng created FLINK-20187:
---
Summary: FactoryUtil#createTableSource will be confused by a table
source and a table sink factory with same identifier
Key: FLINK-20187
URL: https://issues.apache.org/jira/browse/F
Caizhi Weng created FLINK-20256:
---
Summary: UDAF type inference will fail if accumulator contains
MapView with Pojo value type
Key: FLINK-20256
URL: https://issues.apache.org/jira/browse/FLINK-20256
Proj
Caizhi Weng created FLINK-20366:
---
Summary: ColumnIntervalUtil#getColumnIntervalWithFilter does not
consider the case when the predicate is a false constant
Key: FLINK-20366
URL: https://issues.apache.org/jira/browse
Caizhi Weng created FLINK-20663:
---
Summary: Managed memory may not be released in time when operators
use managed memory frequently
Key: FLINK-20663
URL: https://issues.apache.org/jira/browse/FLINK-20663
Caizhi Weng created FLINK-20887:
---
Summary: Non-deterministic functions return different values even
if it is referred with the same column name
Key: FLINK-20887
URL: https://issues.apache.org/jira/browse/FLINK-20887
Caizhi Weng created FLINK-30294:
---
Summary: Change table property key 'log.scan' to 'startup.mode'
and add a default startup mode in Table Store
Key: FLINK-30294
URL: https://issues.apache.org/jira/browse/FLINK-30294
Caizhi Weng created FLINK-30410:
---
Summary: Rename 'full' to 'latest-full' and 'compacted' to
'compacted-full' for scan.mode in Table Store
Key: FLINK-30410
URL: https://issues.apache.org/jira/browse/FLINK-30410
Caizhi Weng created FLINK-30458:
---
Summary: Refactor Table Store Documentation
Key: FLINK-30458
URL: https://issues.apache.org/jira/browse/FLINK-30458
Project: Flink
Issue Type: Improvement
Caizhi Weng created FLINK-30504:
---
Summary: Fix UnsupportedFileSystemSchemeException when writing
Table Store on OSS with other engines
Key: FLINK-30504
URL: https://issues.apache.org/jira/browse/FLINK-30504
Caizhi Weng created FLINK-30506:
---
Summary: Add documentation for writing Table Store with Spark3
Key: FLINK-30506
URL: https://issues.apache.org/jira/browse/FLINK-30506
Project: Flink
Issue Typ
Caizhi Weng created FLINK-30573:
---
Summary: Table Store dedicated compact job may skip some records
when checkpoint interval is long
Key: FLINK-30573
URL: https://issues.apache.org/jira/browse/FLINK-30573
Caizhi Weng created FLINK-30589:
---
Summary: Snapshot expiration should be skipped in Table Store
dedicated writer jobs
Key: FLINK-30589
URL: https://issues.apache.org/jira/browse/FLINK-30589
Project: Fli
Caizhi Weng created FLINK-30620:
---
Summary: Table Store Hive catalog supports specifying custom Hive
metastore client
Key: FLINK-30620
URL: https://issues.apache.org/jira/browse/FLINK-30620
Project: Flin
Caizhi Weng created FLINK-30646:
---
Summary: Table Store Hive catalog throws ClassNotFoundException
when custom hive-site.xml is presented
Key: FLINK-30646
URL: https://issues.apache.org/jira/browse/FLINK-30646
Caizhi Weng created FLINK-30861:
---
Summary: Table Store Hive Catalog throws
java.lang.ClassNotFoundException:
org.apache.hadoop.hive.common.ValidWriteIdList under certain environment
Key: FLINK-30861
URL: https://is
Caizhi Weng created FLINK-31429:
---
Summary: Support CTAS(create table as) streaming job with schema
changes in table store
Key: FLINK-31429
URL: https://issues.apache.org/jira/browse/FLINK-31429
Project:
Caizhi Weng created FLINK-31430:
---
Summary: Support migrating states between different instances of
TableWriteImpl and AbstractFileStoreWrite
Key: FLINK-31430
URL: https://issues.apache.org/jira/browse/FLINK-31430
Caizhi Weng created FLINK-31431:
---
Summary: Support copying a FileStoreTable with latest schema
Key: FLINK-31431
URL: https://issues.apache.org/jira/browse/FLINK-31431
Project: Flink
Issue Type:
Caizhi Weng created FLINK-31432:
---
Summary: Introduce a special StoreWriteOperator to deal with
schema changes
Key: FLINK-31432
URL: https://issues.apache.org/jira/browse/FLINK-31432
Project: Flink
Caizhi Weng created FLINK-31433:
---
Summary: Make SchemaChange serializable
Key: FLINK-31433
URL: https://issues.apache.org/jira/browse/FLINK-31433
Project: Flink
Issue Type: Sub-task
C
Caizhi Weng created FLINK-31434:
---
Summary: Introduce CDC sink for Table Store
Key: FLINK-31434
URL: https://issues.apache.org/jira/browse/FLINK-31434
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-31435:
---
Summary: Introduce event parser for MySql Debezium JSON format in
Table Store
Key: FLINK-31435
URL: https://issues.apache.org/jira/browse/FLINK-31435
Project: Flink
Caizhi Weng created FLINK-31436:
---
Summary: Remove schemaId from constructor of Snapshot and
ManifestFile in Table Store
Key: FLINK-31436
URL: https://issues.apache.org/jira/browse/FLINK-31436
Project: F
Caizhi Weng created FLINK-31558:
---
Summary: Support updating schema type with restrictions in CDC
sink of Table Store
Key: FLINK-31558
URL: https://issues.apache.org/jira/browse/FLINK-31558
Project: Flin
Caizhi Weng created FLINK-31659:
---
Summary: java.lang.ClassNotFoundException:
org.apache.flink.table.planner.delegation.DialectFactory when bundled Hive
connector jar is in classpath
Key: FLINK-31659
URL: https://is
Caizhi Weng created FLINK-31695:
---
Summary: Calling `bin/flink stop` when
flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory thwos
NoSuchMethodError
Key: FLINK-31695
URL: https://issues.apache.org/jira/br
Caizhi Weng created FLINK-26648:
---
Summary: Ban dependencies on flink-table-planner and depend on
flink-table-planner-loader instead
Key: FLINK-26648
URL: https://issues.apache.org/jira/browse/FLINK-26648
Caizhi Weng created FLINK-26703:
---
Summary: Introduce flink-table-store-dist module for packaging
Key: FLINK-26703
URL: https://issues.apache.org/jira/browse/FLINK-26703
Project: Flink
Issue Typ
Caizhi Weng created FLINK-27004:
---
Summary: Use '.' instead of
'file..' in table properties of managed table
Key: FLINK-27004
URL: https://issues.apache.org/jira/browse/FLINK-27004
Project: Flink
Caizhi Weng created FLINK-27070:
---
Summary: Reuse FileFormat instead of DecodingFormat/EncodingFormat
to ensure thread safety.
Key: FLINK-27070
URL: https://issues.apache.org/jira/browse/FLINK-27070
Proj
Caizhi Weng created FLINK-27085:
---
Summary: Introduce snapshot.num-retained.min option
Key: FLINK-27085
URL: https://issues.apache.org/jira/browse/FLINK-27085
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-27089:
---
Summary: Calling TRY_CAST with an invalid value throws
IndexOutOfBounds Exception.
Key: FLINK-27089
URL: https://issues.apache.org/jira/browse/FLINK-27089
Project: Flin
Caizhi Weng created FLINK-27135:
---
Summary: Rename 'file.path' table option in table store to 'path'
Key: FLINK-27135
URL: https://issues.apache.org/jira/browse/FLINK-27135
Project: Flink
Issue
Caizhi Weng created FLINK-27136:
---
Summary: Disable rolling file when writing level 0 sst files
Key: FLINK-27136
URL: https://issues.apache.org/jira/browse/FLINK-27136
Project: Flink
Issue Type:
Caizhi Weng created FLINK-27139:
---
Summary: FileStoreCommitImpl#filterCommitted should exit when
faced with expired files
Key: FLINK-27139
URL: https://issues.apache.org/jira/browse/FLINK-27139
Project:
Caizhi Weng created FLINK-27283:
---
Summary: Add end to end tests for table store
Key: FLINK-27283
URL: https://issues.apache.org/jira/browse/FLINK-27283
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-27286:
---
Summary: Fix table store connector throws ClassNotFoundException:
org.apache.flink.table.store.shaded.org.apache.flink.connector.file.table.RowDataPartitionComputer
Key: FLINK-27286
Caizhi Weng created FLINK-27408:
---
Summary: Package Flink runtime dependencies into associated table
store modules instead of flink-table-store-dist
Key: FLINK-27408
URL: https://issues.apache.org/jira/browse/FLINK-2
Caizhi Weng created FLINK-27439:
---
Summary: Fix ClassNotFoundException when using array type in table
store
Key: FLINK-27439
URL: https://issues.apache.org/jira/browse/FLINK-27439
Project: Flink
Caizhi Weng created FLINK-27542:
---
Summary: Add end to end tests for Hive to read external table
store files
Key: FLINK-27542
URL: https://issues.apache.org/jira/browse/FLINK-27542
Project: Flink
Caizhi Weng created FLINK-27562:
---
Summary: Creating HDFS table in SQL client throws
UnsupportedFileSystemSchemeException even if hadoop jar is added through --jar
argument
Key: FLINK-27562
URL: https://issues.apach
Caizhi Weng created FLINK-27580:
---
Summary: Implement filter pushdown for TableStoreHiveStorageHandler
Key: FLINK-27580
URL: https://issues.apache.org/jira/browse/FLINK-27580
Project: Flink
Issu
Caizhi Weng created FLINK-27589:
---
Summary: Fix incorrect implementation of
TableStoreDateObjectInspector
Key: FLINK-27589
URL: https://issues.apache.org/jira/browse/FLINK-27589
Project: Flink
Caizhi Weng created FLINK-27627:
---
Summary: Incorrect result when order by (string, double) pair with
NaN values
Key: FLINK-27627
URL: https://issues.apache.org/jira/browse/FLINK-27627
Project: Flink
Caizhi Weng created FLINK-27628:
---
Summary: Table Store records and fetches incorrect results with NaN
Key: FLINK-27628
URL: https://issues.apache.org/jira/browse/FLINK-27628
Project: Flink
Issu
Caizhi Weng created FLINK-27629:
---
Summary: Table Store throws NullPointerException when pushing down
NotEqual predicate to a column consisting of nulls
Key: FLINK-27629
URL: https://issues.apache.org/jira/browse/FLI
Caizhi Weng created FLINK-27739:
---
Summary: Add benchmark module for table store
Key: FLINK-27739
URL: https://issues.apache.org/jira/browse/FLINK-27739
Project: Flink
Issue Type: Improvement
Caizhi Weng created FLINK-27814:
---
Summary: Add an abstraction layer for connectors to read and write
row data instead of key-values
Key: FLINK-27814
URL: https://issues.apache.org/jira/browse/FLINK-27814
Caizhi Weng created FLINK-27835:
---
Summary: Introduce LeafPredicate interface and children method in
Predicate
Key: FLINK-27835
URL: https://issues.apache.org/jira/browse/FLINK-27835
Project: Flink
Caizhi Weng created FLINK-27863:
---
Summary: Refactor RecordReader and RecordIterator in table store
into generic types
Key: FLINK-27863
URL: https://issues.apache.org/jira/browse/FLINK-27863
Project: Fli
Caizhi Weng created FLINK-27875:
---
Summary: Introduce TableScan and TableRead as an abstraction layer
above FileStore for reading RowData
Key: FLINK-27875
URL: https://issues.apache.org/jira/browse/FLINK-27875
Caizhi Weng created FLINK-27957:
---
Summary: Extract AppendOnlyFileStore out of KeyValueFileStore
Key: FLINK-27957
URL: https://issues.apache.org/jira/browse/FLINK-27957
Project: Flink
Issue Type
1 - 100 of 220 matches
Mail list logo
