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
Proje
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: Flin
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
Issue Typ
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 Ty
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/browse
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
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/b
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: Improvem
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-ta
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-ta
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
dalongliu created FLINK-32865:
-
Summary: DynamicFilteringDataCollectorOperator can't chain with
the upstream operator when the parallelism is inconsistent
Key: FLINK-32865
URL: https://issues.apache.org/jira/browse/FL
dalongliu created FLINK-32905:
-
Summary: Fix the bug of broadcast hash join doesn't support spill
to disk when enable operator fusion codegn
Key: FLINK-32905
URL: https://issues.apache.org/jira/browse/FLINK-32905
dalongliu created FLINK-33004:
-
Summary: Decoupling topology and network memory to support complex
job topologies
Key: FLINK-33004
URL: https://issues.apache.org/jira/browse/FLINK-33004
Project: Flink
dalongliu created FLINK-33229:
-
Summary: Moving Java FlinkRecomputeStatisticsProgram from scala
package to java package
Key: FLINK-33229
URL: https://issues.apache.org/jira/browse/FLINK-33229
Project: Fli
dalongliu created FLINK-33593:
-
Summary: Left title bar of the official documentation for the
master branch is misaligned
Key: FLINK-33593
URL: https://issues.apache.org/jira/browse/FLINK-33593
Project: F
dalongliu created FLINK-17096:
-
Summary: Minibatch Group Agg support state ttl
Key: FLINK-17096
URL: https://issues.apache.org/jira/browse/FLINK-17096
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-17099:
-
Summary: Refactoring State TTL solution in Group Agg、TopN
operator, etc replace Timer with StateTtlConfig
Key: FLINK-17099
URL: https://issues.apache.org/jira/browse/FLINK-17099
dalongliu created FLINK-10144:
-
Summary: No unused import "import akka.actor.ActorRef" in class
"org.apache.flink.runtime.messages.TaskManagerMessages"
Key: FLINK-10144
URL: https://issues.apache.org/jira/browse/FLINK
dalongliu created FLINK-10636:
-
Summary: ERROR
org.apache.flink.shaded.curator.org.apache.curator.ConnectionState -
Authentication failed
Key: FLINK-10636
URL: https://issues.apache.org/jira/browse/FLINK-10636
dalongliu created FLINK-12623:
-
Summary: Flink on yarn encountered AMRMClientImpl does not update
AMRM token properly
Key: FLINK-12623
URL: https://issues.apache.org/jira/browse/FLINK-12623
Project: Flink
dalongliu created FLINK-19207:
-
Summary: TtlListState#IteratorWithCleanup support remove method
Key: FLINK-19207
URL: https://issues.apache.org/jira/browse/FLINK-19207
Project: Flink
Issue Type:
dalongliu created FLINK-19633:
-
Summary: Fix ArrayIndexOutOfBoundsException in
RetractableTopNFunction
Key: FLINK-19633
URL: https://issues.apache.org/jira/browse/FLINK-19633
Project: Flink
Issu
dalongliu created FLINK-19905:
-
Summary: The Jdbc-connector's 'lookup.max-retries' option initial
value is 1 in JdbcLookupFunction
Key: FLINK-19905
URL: https://issues.apache.org/jira/browse/FLINK-19905
P
dalongliu created FLINK-30491:
-
Summary: Hive table partition supports to deserialize later during
runtime
Key: FLINK-30491
URL: https://issues.apache.org/jira/browse/FLINK-30491
Project: Flink
dalongliu created FLINK-30579:
-
Summary: Introducing cofigurable option to enable hive native
function
Key: FLINK-30579
URL: https://issues.apache.org/jira/browse/FLINK-30579
Project: Flink
Issu
dalongliu created FLINK-30824:
-
Summary: Add document for new introduced hive agg option
Key: FLINK-30824
URL: https://issues.apache.org/jira/browse/FLINK-30824
Project: Flink
Issue Type: Sub-tas
dalongliu created FLINK-31059:
-
Summary: Release Testing: Verify FLINK-29717 Supports hive udaf
such as sum/count by native implementation
Key: FLINK-31059
URL: https://issues.apache.org/jira/browse/FLINK-31059
dalongliu created FLINK-31193:
-
Summary: The option `table.exec.hive.native-agg-function.enabled`
should work at job level when using it in SqlClient side
Key: FLINK-31193
URL: https://issues.apache.org/jira/browse/FL
dalongliu created FLINK-31239:
-
Summary: Fix sum function can't get the corrected value when the
argument type is string
Key: FLINK-31239
URL: https://issues.apache.org/jira/browse/FLINK-31239
Project: Fl
dalongliu created FLINK-35187:
-
Summary: FLIP-435: Introduce a New Materialized Table for
Simplifying Data Pipelines
Key: FLINK-35187
URL: https://issues.apache.org/jira/browse/FLINK-35187
Project: Flink
dalongliu created FLINK-35188:
-
Summary: Introduce CatalogMaterializedTable and related interface
to support materialized table
Key: FLINK-35188
URL: https://issues.apache.org/jira/browse/FLINK-35188
Proj
dalongliu created FLINK-35189:
-
Summary: Introduce test-filesystem Catalog based on FileSystem
Connector to support materialized table
Key: FLINK-35189
URL: https://issues.apache.org/jira/browse/FLINK-35189
dalongliu created FLINK-35190:
-
Summary: Support the syntaxes of Create, Suspend, Resume, Refresh
and Drop materialized table
Key: FLINK-35190
URL: https://issues.apache.org/jira/browse/FLINK-35190
Proje
dalongliu created FLINK-35191:
-
Summary: Support alter materialized table related syntaxes:
suspend, resume, refresh, set and reset
Key: FLINK-35191
URL: https://issues.apache.org/jira/browse/FLINK-35191
dalongliu created FLINK-35193:
-
Summary: Support drop materialized table syntax and execution
Key: FLINK-35193
URL: https://issues.apache.org/jira/browse/FLINK-35193
Project: Flink
Issue Type: Su
dalongliu created FLINK-35194:
-
Summary: Support describe job syntax
Key: FLINK-35194
URL: https://issues.apache.org/jira/browse/FLINK-35194
Project: Flink
Issue Type: Sub-task
Componen
dalongliu created FLINK-35195:
-
Summary: Support the execution of materialized table in continuous
mode
Key: FLINK-35195
URL: https://issues.apache.org/jira/browse/FLINK-35195
Project: Flink
Iss
dalongliu created FLINK-35197:
-
Summary: Support the execution of suspend, resume materialized
table in continuous mode
Key: FLINK-35197
URL: https://issues.apache.org/jira/browse/FLINK-35197
Project: Fli
dalongliu created FLINK-35198:
-
Summary: Support the execution of refresh materialized table
Key: FLINK-35198
URL: https://issues.apache.org/jira/browse/FLINK-35198
Project: Flink
Issue Type: Sub
dalongliu created FLINK-35199:
-
Summary: Support the execution of create materialized table in
full refreshmode
Key: FLINK-35199
URL: https://issues.apache.org/jira/browse/FLINK-35199
Project: Flink
dalongliu created FLINK-35200:
-
Summary: Support the execution of suspend, resume materialized
table in full refresh mode
Key: FLINK-35200
URL: https://issues.apache.org/jira/browse/FLINK-35200
Project: F
dalongliu created FLINK-35201:
-
Summary: Support the execution of drop materialized table in full
refresh mode
Key: FLINK-35201
URL: https://issues.apache.org/jira/browse/FLINK-35201
Project: Flink
dalongliu created FLINK-35202:
-
Summary: Support the execution of set freshness for materialized
table
Key: FLINK-35202
URL: https://issues.apache.org/jira/browse/FLINK-35202
Project: Flink
Issu
dalongliu created FLINK-35204:
-
Summary: Support the execution of alter materialized table set
options
Key: FLINK-35204
URL: https://issues.apache.org/jira/browse/FLINK-35204
Project: Flink
Issu
dalongliu created FLINK-35203:
-
Summary: Support the execution of alter materialized table set
refresh mode
Key: FLINK-35203
URL: https://issues.apache.org/jira/browse/FLINK-35203
Project: Flink
dalongliu created FLINK-35205:
-
Summary: Support the execution of alter materialized table reset
options
Key: FLINK-35205
URL: https://issues.apache.org/jira/browse/FLINK-35205
Project: Flink
Is
dalongliu created FLINK-35206:
-
Summary: Desc table syntax support materialized table
Key: FLINK-35206
URL: https://issues.apache.org/jira/browse/FLINK-35206
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-35345:
-
Summary: FLIP-448: Introduce Pluggable Workflow Scheduler
Interface for Materialized Table
Key: FLINK-35345
URL: https://issues.apache.org/jira/browse/FLINK-35345
Project:
dalongliu created FLINK-35346:
-
Summary: Introduce pluggable workflow scheduler interface for
materialized table
Key: FLINK-35346
URL: https://issues.apache.org/jira/browse/FLINK-35346
Project: Flink
dalongliu created FLINK-35347:
-
Summary: Implement InMemory workflow scheduler service and plugin
to support materialized table
Key: FLINK-35347
URL: https://issues.apache.org/jira/browse/FLINK-35347
Proj
dalongliu created FLINK-35348:
-
Summary: Implement materialized table refresh rest api
Key: FLINK-35348
URL: https://issues.apache.org/jira/browse/FLINK-35348
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-35425:
-
Summary: Support convert Freshness to cron expression for full
refresh mode
Key: FLINK-35425
URL: https://issues.apache.org/jira/browse/FLINK-35425
Project: Flink
dalongliu created FLINK-26813:
-
Summary: Supports ADD/MODIFY column/watermark/constraint syntax
parse for ALTER TABLE
Key: FLINK-26813
URL: https://issues.apache.org/jira/browse/FLINK-26813
Project: Flink
dalongliu created FLINK-26929:
-
Summary: Introduce adaptive hash join for batch sql optimization
Key: FLINK-26929
URL: https://issues.apache.org/jira/browse/FLINK-26929
Project: Flink
Issue Type:
dalongliu created FLINK-26939:
-
Summary: Add TRANSLATE supported in SQL & Table API
Key: FLINK-26939
URL: https://issues.apache.org/jira/browse/FLINK-26939
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26940:
-
Summary: Add SUBSTRING_INDEX supported in SQL & Table API
Key: FLINK-26940
URL: https://issues.apache.org/jira/browse/FLINK-26940
Project: Flink
Issue Type: Sub-ta
dalongliu created FLINK-26943:
-
Summary: Add DATE_ADD supported in SQL & Table API
Key: FLINK-26943
URL: https://issues.apache.org/jira/browse/FLINK-26943
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26944:
-
Summary: Add ADD_MONTHS supported in SQL and Table API
Key: FLINK-26944
URL: https://issues.apache.org/jira/browse/FLINK-26944
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26945:
-
Summary: Add DATE_SUB supported in SQL & Table API
Key: FLINK-26945
URL: https://issues.apache.org/jira/browse/FLINK-26945
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26946:
-
Summary: Add SHIFTRIGHT supported in SQL & Table API
Key: FLINK-26946
URL: https://issues.apache.org/jira/browse/FLINK-26946
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26947:
-
Summary: Add ARRAY_CONTAINS supported in SQL & Table API
Key: FLINK-26947
URL: https://issues.apache.org/jira/browse/FLINK-26947
Project: Flink
Issue Type: Sub-tas
dalongliu created FLINK-26948:
-
Summary: Add SORT_ARRAY supported in SQL & Table API
Key: FLINK-26948
URL: https://issues.apache.org/jira/browse/FLINK-26948
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26949:
-
Summary: Add NVL supported in SQL & Table API
Key: FLINK-26949
URL: https://issues.apache.org/jira/browse/FLINK-26949
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26951:
-
Summary: Add HASH supported in SQL & Table API
Key: FLINK-26951
URL: https://issues.apache.org/jira/browse/FLINK-26951
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-27237:
-
Summary: Partition table statement enhancement
Key: FLINK-27237
URL: https://issues.apache.org/jira/browse/FLINK-27237
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-27240:
-
Summary: Support ADD PARTITION statement
Key: FLINK-27240
URL: https://issues.apache.org/jira/browse/FLINK-27240
Project: Flink
Issue Type: Sub-task
Re
dalongliu created FLINK-27241:
-
Summary: Support DROP PARTITION statement
Key: FLINK-27241
URL: https://issues.apache.org/jira/browse/FLINK-27241
Project: Flink
Issue Type: Sub-task
R
dalongliu created FLINK-27243:
-
Summary: Support SHOW PARTITIONS statement for partitioned table
Key: FLINK-27243
URL: https://issues.apache.org/jira/browse/FLINK-27243
Project: Flink
Issue Type:
dalongliu created FLINK-27242:
-
Summary: Support RENAME PARTITION statement for partitioned table
Key: FLINK-27242
URL: https://issues.apache.org/jira/browse/FLINK-27242
Project: Flink
Issue Type
dalongliu created FLINK-27363:
-
Summary: Support EXCHANGE PARTITION statement for partitioned table
Key: FLINK-27363
URL: https://issues.apache.org/jira/browse/FLINK-27363
Project: Flink
Issue Ty
dalongliu created FLINK-27364:
-
Summary: Support DESC EXTENDED partition statement for partitioned
table
Key: FLINK-27364
URL: https://issues.apache.org/jira/browse/FLINK-27364
Project: Flink
Is
dalongliu created FLINK-27593:
-
Summary: Parquet/Orc format reader optimization
Key: FLINK-27593
URL: https://issues.apache.org/jira/browse/FLINK-27593
Project: Flink
Issue Type: Bug
Co
dalongliu created FLINK-27606:
-
Summary: Fix code generator exception when using imperative udaf
that is introduced for planner scala-free
Key: FLINK-27606
URL: https://issues.apache.org/jira/browse/FLINK-27606
dalongliu created FLINK-27651:
-
Summary: Support CREATE FUNCTION USING JAR syntax
Key: FLINK-27651
URL: https://issues.apache.org/jira/browse/FLINK-27651
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-27658:
-
Summary: Introduce MutableURLClassLoader allow to register and
remove user jar dynamically
Key: FLINK-27658
URL: https://issues.apache.org/jira/browse/FLINK-27658
Project:
dalongliu created FLINK-27659:
-
Summary: Planner support to use jar which is registered by "USING
JAR" syntax
Key: FLINK-27659
URL: https://issues.apache.org/jira/browse/FLINK-27659
Project: Flink
dalongliu created FLINK-27660:
-
Summary: Table API support create function using customed jar
Key: FLINK-27660
URL: https://issues.apache.org/jira/browse/FLINK-27660
Project: Flink
Issue Type: Su
dalongliu created FLINK-27790:
-
Summary: Move ADD/Remove Jar syntax code implementation from
SqlClient to TableEnvironment side
Key: FLINK-27790
URL: https://issues.apache.org/jira/browse/FLINK-27790
Proj
dalongliu created FLINK-27861:
-
Summary: Introduce UserResourceManager to manage user defined
resource
Key: FLINK-27861
URL: https://issues.apache.org/jira/browse/FLINK-27861
Project: Flink
Issu
dalongliu created FLINK-25635:
-
Summary: Using sql client create hive catalog throw exception
Key: FLINK-25635
URL: https://issues.apache.org/jira/browse/FLINK-25635
Project: Flink
Issue Type: Ne
dalongliu created FLINK-24822:
-
Summary: Improve CatalogTableSpecBase and its subclass method
parameter
Key: FLINK-24822
URL: https://issues.apache.org/jira/browse/FLINK-24822
Project: Flink
Is
dalongliu created FLINK-28080:
-
Summary: Introduce MutableURLClassLoader as parent class of
FlinkUserClassLoader and SafetyNetWrapperClassLoader
Key: FLINK-28080
URL: https://issues.apache.org/jira/browse/FLINK-28080
dalongliu created FLINK-28101:
-
Summary: YARNHighAvailabilityITCase failed on azure
Key: FLINK-28101
URL: https://issues.apache.org/jira/browse/FLINK-28101
Project: Flink
Issue Type: Bug
dalongliu created FLINK-28213:
-
Summary: StreamExecutionEnvironment configure method support
override pipeline.jars option
Key: FLINK-28213
URL: https://issues.apache.org/jira/browse/FLINK-28213
Project:
dalongliu created FLINK-28451:
-
Summary: HiveFunctionDefinitionFactory load udf using user
classloader instead of thread context classloader
Key: FLINK-28451
URL: https://issues.apache.org/jira/browse/FLINK-28451
dalongliu created FLINK-28867:
-
Summary: Parquet reader support nested type in array/map type
Key: FLINK-28867
URL: https://issues.apache.org/jira/browse/FLINK-28867
Project: Flink
Issue Type: Su
dalongliu created FLINK-28916:
-
Summary: Add e2e test for create function using jar syntax
Key: FLINK-28916
URL: https://issues.apache.org/jira/browse/FLINK-28916
Project: Flink
Issue Type: Bug
dalongliu created FLINK-28917:
-
Summary: Add sql test for adaptive hash join
Key: FLINK-28917
URL: https://issues.apache.org/jira/browse/FLINK-28917
Project: Flink
Issue Type: Bug
Compo
dalongliu created FLINK-29005:
-
Summary: Parquet row type reader should not return null value when
some child fields is null
Key: FLINK-29005
URL: https://issues.apache.org/jira/browse/FLINK-29005
Projec
dalongliu created FLINK-29019:
-
Summary: Updating parquet format document that support complex type
Key: FLINK-29019
URL: https://issues.apache.org/jira/browse/FLINK-29019
Project: Flink
Issue Ty
dalongliu created FLINK-29020:
-
Summary: Add document for CTAS feature
Key: FLINK-29020
URL: https://issues.apache.org/jira/browse/FLINK-29020
Project: Flink
Issue Type: Sub-task
Compon
dalongliu created FLINK-29022:
-
Summary: Add document for CREATE FUNCTIOn USING JAR feature
Key: FLINK-29022
URL: https://issues.apache.org/jira/browse/FLINK-29022
Project: Flink
Issue Type: Sub-
dalongliu created FLINK-29023:
-
Summary: Updating Jar statement document
Key: FLINK-29023
URL: https://issues.apache.org/jira/browse/FLINK-29023
Project: Flink
Issue Type: Sub-task
Comp
dalongliu created FLINK-29068:
-
Summary: Release Testing: Verify FLIP-214 Create function using
jar syntax
Key: FLINK-29068
URL: https://issues.apache.org/jira/browse/FLINK-29068
Project: Flink
1 - 100 of 134 matches
Mail list logo
