ZhouXianming created FLINK-32112:
Summary: Fixed State Backend sample config in zh-doc
Key: FLINK-32112
URL: https://issues.apache.org/jira/browse/FLINK-32112
Project: Flink
Issue Type
luoyuxia created FLINK-32117:
Summary: Add more test for update statement
Key: FLINK-32117
URL: https://issues.apache.org/jira/browse/FLINK-32117
Project: Flink
Issue Type: Improvement
melin created FLINK-32125:
-
Summary: Support Unified job submission API
Key: FLINK-32125
URL: https://issues.apache.org/jira/browse/FLINK-32125
Project: Flink
Issue Type: New Feature
Liu created FLINK-32133:
---
Summary: Batch requests and remove requests in the end to reduce
YarnResourceManager's excess containers
Key: FLINK-32133
URL: https://issues.apache.org/jira/browse/FLINK-
LiuZeshan created FLINK-32139:
-
Summary: Data accidentally deleted and not deleted when upsert
sink to hbase
Key: FLINK-32139
URL: https://issues.apache.org/jira/browse/FLINK-32139
Project: Flink
LiuZeshan created FLINK-32140:
-
Summary: Data accidentally deleted and not deleted when upsert
sink to hbase
Key: FLINK-32140
URL: https://issues.apache.org/jira/browse/FLINK-32140
Project: Flink
melin created FLINK-32163:
-
Summary: Support the same application run multiple jobs in HA mode
Key: FLINK-32163
URL: https://issues.apache.org/jira/browse/FLINK-32163
Project: Flink
Issue Type: New
xulongfeng created FLINK-32172:
--
Summary: KafkaExample can not run with args
Key: FLINK-32172
URL: https://issues.apache.org/jira/browse/FLINK-32172
Project: Flink
Issue Type: Bug
wangliang created FLINK-32175:
-
Summary: translate doc(datagen.md) to chinese
Key: FLINK-32175
URL: https://issues.apache.org/jira/browse/FLINK-32175
Project: Flink
Issue Type: Improvement
zhangdong7 created FLINK-32202:
--
Summary: useless configuration
Key: FLINK-32202
URL: https://issues.apache.org/jira/browse/FLINK-32202
Project: Flink
Issue Type: Improvement
Leijurv created FLINK-32215:
---
Summary: Date format in flink-statefun startupPosition
documentation is incorrect
Key: FLINK-32215
URL: https://issues.apache.org/jira/browse/FLINK-32215
Project: Flink
dalongliu created FLINK-32220:
-
Summary: Improving the adaptive local hash agg code to avoid get
value from RowData repeatedly
Key: FLINK-32220
URL: https://issues.apache.org/jira/browse/FLINK-32220
someshwar created FLINK-32224:
-
Summary: Unable to connect multiple host using RabbitMQ Connector
Key: FLINK-32224
URL: https://issues.apache.org/jira/browse/FLINK-32224
Project: Flink
Issue
luoyuxia created FLINK-32232:
Summary: Supports parse support truncate table statement
Key: FLINK-32232
URL: https://issues.apache.org/jira/browse/FLINK-32232
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32233:
Summary: Introduce SupportsTruncate interface
Key: FLINK-32233
URL: https://issues.apache.org/jira/browse/FLINK-32233
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32234:
Summary: Support execute truncate table statement
Key: FLINK-32234
URL: https://issues.apache.org/jira/browse/FLINK-32234
Project: Flink
Issue Type: Sub-task
ConradJam created FLINK-32243:
-
Summary: Bump okhttp version to 4.11.0
Key: FLINK-32243
URL: https://issues.apache.org/jira/browse/FLINK-32243
Project: Flink
Issue Type: Improvement
Marcono1234 created FLINK-32248:
---
Summary: Incorrect AssertJ usage
Key: FLINK-32248
URL: https://issues.apache.org/jira/browse/FLINK-32248
Project: Flink
Issue Type: Bug
Components
melin created FLINK-32251:
-
Summary: flink jdbc catalog cannot add parameters to url
Key: FLINK-32251
URL: https://issues.apache.org/jira/browse/FLINK-32251
Project: Flink
Issue Type: New Feature
tanjialiang created FLINK-32252:
---
Summary: SELECT COUNT(*) will return nothing when source no data
return
Key: FLINK-32252
URL: https://issues.apache.org/jira/browse/FLINK-32252
Project: Flink
xiechenling created FLINK-32266:
---
Summary: Kafka Source Continues Consuming Previous Topic After
Loading Savepoint
Key: FLINK-32266
URL: https://issues.apache.org/jira/browse/FLINK-32266
Project: Flink
Spongebob created FLINK-32274:
-
Summary: kafka class could not be found while using appliction
mode.
Key: FLINK-32274
URL: https://issues.apache.org/jira/browse/FLINK-32274
Project: Flink
Issue
dalongliu created FLINK-32277:
-
Summary: Introduce operator fusion codegen framework
Key: FLINK-32277
URL: https://issues.apache.org/jira/browse/FLINK-32277
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32278:
-
Summary: HashJoin support operator fusion codegen
Key: FLINK-32278
URL: https://issues.apache.org/jira/browse/FLINK-32278
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32279:
-
Summary: Shuffle HashJoin support spill to disk when enable
operator fusion codegen
Key: FLINK-32279
URL: https://issues.apache.org/jira/browse/FLINK-32279
Project: Flink
dalongliu created FLINK-32280:
-
Summary: HashAgg support operator fusion codegen
Key: FLINK-32280
URL: https://issues.apache.org/jira/browse/FLINK-32280
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32281:
-
Summary: Enable two-phase agg default when agg function support
adaptive local hashagg
Key: FLINK-32281
URL: https://issues.apache.org/jira/browse/FLINK-32281
Project
linweijiang created FLINK-32284:
---
Summary: When using session windows, the state of slot 1 keeps
growing
Key: FLINK-32284
URL: https://issues.apache.org/jira/browse/FLINK-32284
Project: Flink
luoyuxia created FLINK-32286:
Summary: Align the shade pattern that Hive connector using for
calcite related class with flink-table-planner
Key: FLINK-32286
URL: https://issues.apache.org/jira/browse/FLINK-32286
luoyuxia created FLINK-32287:
Summary: Add doc for truncate table statement
Key: FLINK-32287
URL: https://issues.apache.org/jira/browse/FLINK-32287
Project: Flink
Issue Type: Sub-task
xingbe created FLINK-32288:
--
Summary: Improve the scheduling performance of
AdaptiveBatchScheduler
Key: FLINK-32288
URL: https://issues.apache.org/jira/browse/FLINK-32288
Project: Flink
Issue Type
Spongebob created FLINK-32308:
-
Summary: RestClusterClient submit job to remote cluster
Key: FLINK-32308
URL: https://issues.apache.org/jira/browse/FLINK-32308
Project: Flink
Issue Type: Bug
wgcn created FLINK-32319:
Summary: flink can't the partition of network after restart
Key: FLINK-32319
URL: https://issues.apache.org/jira/browse/FLINK-32319
Project: Flink
Issue Type
Aitozi created FLINK-32320:
--
Summary: Same correlate can not be reused due to the different
correlationId
Key: FLINK-32320
URL: https://issues.apache.org/jira/browse/FLINK-32320
Project: Flink
macdoor615 created FLINK-32321:
--
Summary: Temporal Join job missing condition after “ON”
Key: FLINK-32321
URL: https://issues.apache.org/jira/browse/FLINK-32321
Project: Flink
Issue Type: Bug
macdoor615 created FLINK-32333:
--
Summary: The same SQL statement, sql-client and sql-gateway give
different execution plans
Key: FLINK-32333
URL: https://issues.apache.org/jira/browse/FLINK-32333
chenyuexin created FLINK-32341:
--
Summary: Fix resource requirements rest API response empty result
Key: FLINK-32341
URL: https://issues.apache.org/jira/browse/FLINK-32341
Project: Flink
Issue
/jira/browse/FLINK-32346
Project: Flink
Issue Type: Improvement
Components: Connectors / JDBC
Reporter: zhilinli
Attachments: image-2023-06-15-16-42-16-773.png
Sharding key boundaries large storage long integer overflow, use BigDecimal
instead
tartarus created FLINK-32349:
Summary: Support atomic for CREATE TABLE AS SELECT(CTAS) statement
Key: FLINK-32349
URL: https://issues.apache.org/jira/browse/FLINK-32349
Project: Flink
Issue Type
luoyuxia created FLINK-32350:
Summary: FLIP-311: Support Call Stored Procedure
Key: FLINK-32350
URL: https://issues.apache.org/jira/browse/FLINK-32350
Project: Flink
Issue Type: New Feature
luoyuxia created FLINK-32351:
Summary: Introduce base interfaces for call procedure
Key: FLINK-32351
URL: https://issues.apache.org/jira/browse/FLINK-32351
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32352:
Summary: Support convert call procedure statement to correpsonding
operation
Key: FLINK-32352
URL: https://issues.apache.org/jira/browse/FLINK-32352
Project: Flink
luoyuxia created FLINK-32354:
Summary: Support to execute the call procedure operation
Key: FLINK-32354
URL: https://issues.apache.org/jira/browse/FLINK-32354
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32355:
Summary: Support to list procedure
Key: FLINK-32355
URL: https://issues.apache.org/jira/browse/FLINK-32355
Project: Flink
Issue Type: Sub-task
Components
luoyuxia created FLINK-32356:
Summary: Add document for calling procedure
Key: FLINK-32356
URL: https://issues.apache.org/jira/browse/FLINK-32356
Project: Flink
Issue Type: Sub-task
Spongebob created FLINK-32361:
-
Summary: error after replace dependent jar file
Key: FLINK-32361
URL: https://issues.apache.org/jira/browse/FLINK-32361
Project: Flink
Issue Type: Bug
jackylau created FLINK-32363:
Summary: calcite 1.21 supports type coercion but flink don't
enable it in validate
Key: FLINK-32363
URL: https://issues.apache.org/jira/browse/FLINK-32363
Project:
hanjie created FLINK-32365:
--
Summary: orc format get table statistics slow
Key: FLINK-32365
URL: https://issues.apache.org/jira/browse/FLINK-32365
Project: Flink
Issue Type: Improvement
zhou created FLINK-32367:
Summary: lead function second param leat to ClassCastException
Key: FLINK-32367
URL: https://issues.apache.org/jira/browse/FLINK-32367
Project: Flink
Issue Type: Bug
luoyuxia created FLINK-32397:
Summary: Add doc for add/drop/show partition
Key: FLINK-32397
URL: https://issues.apache.org/jira/browse/FLINK-32397
Project: Flink
Issue Type: Sub-task
KianChen created FLINK-32400:
Summary: KafkaSourceBuilder#maybeOverride get property as a string
to checking if has value may not be the best way
Key: FLINK-32400
URL: https://issues.apache.org/jira/browse/FLINK
KianChen created FLINK-32401:
Summary: KafkaSourceBuilder reset the 'auto.offset.reset'
Key: FLINK-32401
URL: https://issues.apache.org/jira/browse/FLINK-32401
Project: Flink
dongwoo.kim created FLINK-32408:
---
Summary: JobManager HA configuration update needed in Flink k8s
Operator
Key: FLINK-32408
URL: https://issues.apache.org/jira/browse/FLINK-32408
Project: Flink
dalongliu created FLINK-32426:
-
Summary: Fix adaptive local hash can't work when auxGrouping exist
Key: FLINK-32426
URL: https://issues.apache.org/jira/browse/FLINK-32426
Project: Flink
gary created FLINK-32434:
Summary: missing s3 config by catalog
Key: FLINK-32434
URL: https://issues.apache.org/jira/browse/FLINK-32434
Project: Flink
Issue Type: Bug
Components
luoyuxia created FLINK-32460:
Summary: Add doc for list procedures
Key: FLINK-32460
URL: https://issues.apache.org/jira/browse/FLINK-32460
Project: Flink
Issue Type: Sub-task
wgcn created FLINK-32461:
Summary: manage operator state increase very large
Key: FLINK-32461
URL: https://issues.apache.org/jira/browse/FLINK-32461
Project: Flink
Issue Type: Bug
Affects
StephenLin created FLINK-32463:
--
Summary: annotation word spelling error about @return of method
shutdownServiceUninterruptible in TimerService
Key: FLINK-32463
URL: https://issues.apache.org/jira/browse/FLINK-32463
grandfisher created FLINK-32471:
---
Summary: IS_NOT_NULL can add to SUITABLE_FILTER_TO_PUSH
Key: FLINK-32471
URL: https://issues.apache.org/jira/browse/FLINK-32471
Project: Flink
Issue Type
baxinyu created FLINK-32477:
---
Summary: flink-connector-jdbc Fixed missing words in documentation
Key: FLINK-32477
URL: https://issues.apache.org/jira/browse/FLINK-32477
Project: Flink
Issue Type
luoyuxia created FLINK-32481:
Summary: Support type inference for procedure
Key: FLINK-32481
URL: https://issues.apache.org/jira/browse/FLINK-32481
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32489:
-
Summary: Support serialize and merge BloomFilter for runtime filter
Key: FLINK-32489
URL: https://issues.apache.org/jira/browse/FLINK-32489
Project: Flink
Issue
dalongliu created FLINK-32491:
-
Summary: Introduce RuntimeFilterOperator to support runtime filter
which can reduce the shuffle data size before shuffle join
Key: FLINK-32491
URL: https://issues.apache.org/jira
dalongliu created FLINK-32493:
-
Summary: Introduce RuntimeFilterBuilderOperator to build a
BloomFilter from build side data of shuffle join
Key: FLINK-32493
URL: https://issues.apache.org/jira/browse/FLINK-32493
haishui created FLINK-32496:
---
Summary: Sources with idleness and alignment always wait for
alignment when part of multiple sources is idle
Key: FLINK-32496
URL: https://issues.apache.org/jira/browse/FLINK-32496
dalongliu created FLINK-32510:
-
Summary: Reusing the LongHashJoinGenerator and
HashJoinFusionCodegenSpec code as soon as possible to avoid too high maintain
cost
Key: FLINK-32510
URL: https://issues.apache.org/jira
luoyuxia created FLINK-32515:
Summary: FLIP-303: Support REPLACE TABLE AS SELECT statement
Key: FLINK-32515
URL: https://issues.apache.org/jira/browse/FLINK-32515
Project: Flink
Issue Type: New
luoyuxia created FLINK-32516:
Summary: Support to parse REPLACE TABLE AS statement
Key: FLINK-32516
URL: https://issues.apache.org/jira/browse/FLINK-32516
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32517:
Summary: Support to execute [CREATE OR] REPLACE TABLE AS statement
Key: FLINK-32517
URL: https://issues.apache.org/jira/browse/FLINK-32517
Project: Flink
Issue Type
luoyuxia created FLINK-32519:
Summary: Add doc for [CREATE OR] REPLACE TABLE AS statement
Key: FLINK-32519
URL: https://issues.apache.org/jira/browse/FLINK-32519
Project: Flink
Issue Type: Sub
luoyuxia created FLINK-32518:
Summary: Enable atomicity for [CREATE OR] REPLACE table as
statement
Key: FLINK-32518
URL: https://issues.apache.org/jira/browse/FLINK-32518
Project: Flink
Issue
apache.org/jira/browse/FLINK-32528
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.17.0
Reporter: LakeShen
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
LaraJiang created FLINK-32542:
-
Summary: 'connector'='starrocks' 如何手动指定starrocks 中__op
隐藏字段,用来实现物理删除
Key: FLINK-32542
URL: https://issues.apache.org/jira/browse/FLINK-32542
Project: F
jiangchunyang created FLINK-32550:
-
Summary: Single-parallel task consumes multi-partition data
exception in pulsar
Key: FLINK-32550
URL: https://issues.apache.org/jira/browse/FLINK-32550
Project
jasonliangyc created FLINK-32579:
Summary: The filter criteria on the lookup table of Lookup join
has no effect
Key: FLINK-32579
URL: https://issues.apache.org/jira/browse/FLINK-32579
Project: Flink
tartarus created FLINK-32580:
Summary: FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS)
Key: FLINK-32580
URL: https://issues.apache.org/jira/browse/FLINK-32580
Project: Flink
Issue Type
tartarus created FLINK-32581:
Summary: Add document for atomic CTAS
Key: FLINK-32581
URL: https://issues.apache.org/jira/browse/FLINK-32581
Project: Flink
Issue Type: Sub-task
xingbe created FLINK-32586:
--
Summary: Enable input locality in SimpleExecutionSlotAllocator
Key: FLINK-32586
URL: https://issues.apache.org/jira/browse/FLINK-32586
Project: Flink
Issue Type
jasonliangyc created FLINK-32587:
Summary: The results returned from the CDC sql query are null or
the value was changed unexpectly
Key: FLINK-32587
URL: https://issues.apache.org/jira/browse/FLINK-32587
luoyuxia created FLINK-32596:
Summary: The partition key will be wrong when use Flink dialect to
create Hive table
Key: FLINK-32596
URL: https://issues.apache.org/jira/browse/FLINK-32596
Project: Flink
dalongliu created FLINK-32607:
-
Summary: Kafka table source support projection pushdown
Key: FLINK-32607
URL: https://issues.apache.org/jira/browse/FLINK-32607
Project: Flink
Issue Type
dalongliu created FLINK-32608:
-
Summary: Improve source reusing with projection push down
Key: FLINK-32608
URL: https://issues.apache.org/jira/browse/FLINK-32608
Project: Flink
Issue Type: Sub
dalongliu created FLINK-32610:
-
Summary: JSON format supports projection push down
Key: FLINK-32610
URL: https://issues.apache.org/jira/browse/FLINK-32610
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32609:
-
Summary: Kafka table source supports projection push down
Key: FLINK-32609
URL: https://issues.apache.org/jira/browse/FLINK-32609
Project: Flink
Issue Type: Sub
padavan created FLINK-32635:
---
Summary: Add Lag function to Table API
Key: FLINK-32635
URL: https://issues.apache.org/jira/browse/FLINK-32635
Project: Flink
Issue Type: Improvement
chenyuzhi created FLINK-32636:
-
Summary: Promethues metric exporter expose stopped job metric
Key: FLINK-32636
URL: https://issues.apache.org/jira/browse/FLINK-32636
Project: Flink
Issue Type
jianhao.Li created FLINK-32637:
--
Summary: The UNNEST function will cause the Delayed Retry Strategy
For Lookup doesn't work
Key: FLINK-32637
URL: https://issues.apache.org/jira/browse/FLINK-
Dove created FLINK-32639:
Summary: Filter and Limit exist at the same time, limit cannot
take effect
Key: FLINK-32639
URL: https://issues.apache.org/jira/browse/FLINK-32639
Project: Flink
Issue
jasonliangyc created FLINK-32642:
Summary: The upsert mode doesn't work for the compound keys
Key: FLINK-32642
URL: https://issues.apache.org/jira/browse/FLINK-32642
Project: Flink
weitianpei created FLINK-32644:
--
Summary: ts
Key: FLINK-32644
URL: https://issues.apache.org/jira/browse/FLINK-32644
Project: Flink
Issue Type: Bug
Reporter: weitianpei
dalongliu created FLINK-32646:
-
Summary: The snapshot is null in CatalogTable when query specify
the time snapshot
Key: FLINK-32646
URL: https://issues.apache.org/jira/browse/FLINK-32646
Project: Flink
chenyuzhi created FLINK-32649:
-
Summary: Mismatch label and value for prometheus reporter
Key: FLINK-32649
URL: https://issues.apache.org/jira/browse/FLINK-32649
Project: Flink
Issue Type: Bug
Aitozi created FLINK-32659:
--
Summary: DB connection may leak if exception is thrown in
JdbcOutputFormat#close
Key: FLINK-32659
URL: https://issues.apache.org/jira/browse/FLINK-32659
Project: Flink
lizhiqiang created FLINK-32666:
--
Summary: ASM rewrite class lead to package failed.
Key: FLINK-32666
URL: https://issues.apache.org/jira/browse/FLINK-32666
Project: Flink
Issue Type: Bug
chenyuzhi created FLINK-32669:
-
Summary: Support port-range for taskmanager data port
Key: FLINK-32669
URL: https://issues.apache.org/jira/browse/FLINK-32669
Project: Flink
Issue Type
grandfisher created FLINK-32679:
---
Summary: Filter conditions cannot be pushed to JOIN in some case
Key: FLINK-32679
URL: https://issues.apache.org/jira/browse/FLINK-32679
Project: Flink
Issue
sunyanyong created FLINK-32697:
--
Summary: When using JDBC to insert data into the oracle database,
an error will be reported if the target field is lowercase,
Key: FLINK-32697
URL: https://issues.apache.org/jira
liangjj created FLINK-32707:
---
Summary: the timestamp field precision should be set to 0 instead
of 1
Key: FLINK-32707
URL: https://issues.apache.org/jira/browse/FLINK-32707
Project: Flink
Issue
Aitozi created FLINK-32711:
--
Summary: Type mismatch when proctime function used as parameter
Key: FLINK-32711
URL: https://issues.apache.org/jira/browse/FLINK-32711
Project: Flink
Issue Type
yuan created FLINK-32712:
Summary: Enhance Flink ogg-json format
Key: FLINK-32712
URL: https://issues.apache.org/jira/browse/FLINK-32712
Project: Flink
Issue Type: Bug
Components: Formats
801 - 900 of 36655 matches
Mail list logo
