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-35348:
-
Summary: Implement materialized table refresh rest api
Key: FLINK-35348
URL: https://issues.apache.org/jira/browse/FLINK-35348
Project: Flink
Issue Type:
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
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-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-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-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
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-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
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
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-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:
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-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:
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:
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
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
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:
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-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
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-35188:
-
Summary: Introduce CatalogMaterializedTable and related interface
to support materialized table
Key: FLINK-35188
URL: https://issues.apache.org/jira/browse/FLINK-35188
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-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:
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:
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-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-32865:
-
Summary: DynamicFilteringDataCollectorOperator can't chain with
the upstream operator when the parallelism is inconsistent
Key: FLINK-32865
URL:
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-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:
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-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:
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-32510:
-
Summary: Reusing the LongHashJoinGenerator and
HashJoinFusionCodegenSpec code as soon as possible to avoid too high maintain
cost
Key: FLINK-32510
URL:
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-32491:
-
Summary: Introduce RuntimeFilterOperator to support runtime filter
which can reduce the shuffle data size before shuffle join
Key: FLINK-32491
URL:
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-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
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:
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-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-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-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-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
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:
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:
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-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:
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
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-30221:
-
Summary: Fix the bug of sum(try_cast(string as bigint)) return
null when partial elements can't convert to bigint
Key: FLINK-30221
URL:
dalongliu created FLINK-29726:
-
Summary: Supports hive stddev_samp function by native
implementation
Key: FLINK-29726
URL: https://issues.apache.org/jira/browse/FLINK-29726
Project: Flink
Issue
dalongliu created FLINK-29725:
-
Summary: Supports hive std function by native implementation
Key: FLINK-29725
URL: https://issues.apache.org/jira/browse/FLINK-29725
Project: Flink
Issue Type:
dalongliu created FLINK-29724:
-
Summary: Supports hive last_value function by native implementation
Key: FLINK-29724
URL: https://issues.apache.org/jira/browse/FLINK-29724
Project: Flink
Issue
dalongliu created FLINK-29723:
-
Summary: Supports hive first_value function by native
implementation
Key: FLINK-29723
URL: https://issues.apache.org/jira/browse/FLINK-29723
Project: Flink
Issue
dalongliu created FLINK-29722:
-
Summary: Supports hive max function by native implementation
Key: FLINK-29722
URL: https://issues.apache.org/jira/browse/FLINK-29722
Project: Flink
Issue Type:
dalongliu created FLINK-29721:
-
Summary: Supports hive min function by native implementation
Key: FLINK-29721
URL: https://issues.apache.org/jira/browse/FLINK-29721
Project: Flink
Issue Type:
dalongliu created FLINK-29720:
-
Summary: Supports hive average function by native implemetatoin
Key: FLINK-29720
URL: https://issues.apache.org/jira/browse/FLINK-29720
Project: Flink
Issue Type:
dalongliu created FLINK-29718:
-
Summary: Supports hive sum function by native implementation
Key: FLINK-29718
URL: https://issues.apache.org/jira/browse/FLINK-29718
Project: Flink
Issue Type:
dalongliu created FLINK-29719:
-
Summary: Supports hive count function by native implementation
Key: FLINK-29719
URL: https://issues.apache.org/jira/browse/FLINK-29719
Project: Flink
Issue Type:
dalongliu created FLINK-29717:
-
Summary: Supports hive udaf such as sum/count by native
implementation
Key: FLINK-29717
URL: https://issues.apache.org/jira/browse/FLINK-29717
Project: Flink
dalongliu created FLINK-29551:
-
Summary: Improving adaptive hash join by using sort merge join
strategy per partition instead of all partitions
Key: FLINK-29551
URL: https://issues.apache.org/jira/browse/FLINK-29551
dalongliu created FLINK-29547:
-
Summary: Select a[1] which is array type for parquet complex type
throw ClassCastException
Key: FLINK-29547
URL: https://issues.apache.org/jira/browse/FLINK-29547
dalongliu created FLINK-29451:
-
Summary: Push down group by partition column for Aggregate
(Min/Max/Count) for Parquet and Orc
Key: FLINK-29451
URL: https://issues.apache.org/jira/browse/FLINK-29451
dalongliu created FLINK-29450:
-
Summary: Push down filter by partition column for Aggregate
(Min/Max/Count) for Parquet
Key: FLINK-29450
URL: https://issues.apache.org/jira/browse/FLINK-29450
Project:
dalongliu created FLINK-29449:
-
Summary: Aggregate (Min/Max/Count) push down for Parquet
Key: FLINK-29449
URL: https://issues.apache.org/jira/browse/FLINK-29449
Project: Flink
Issue Type:
dalongliu created FLINK-29448:
-
Summary: Aggregate (Min/Max/Count) push down for ORC
Key: FLINK-29448
URL: https://issues.apache.org/jira/browse/FLINK-29448
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-29240:
-
Summary: Unify the ClassLoader in StreamExecutionEnvironment and
TableEnvironment
Key: FLINK-29240
URL: https://issues.apache.org/jira/browse/FLINK-29240
Project: Flink
dalongliu created FLINK-29162:
-
Summary: missCounter and loadCount metrics also increase even if
cache hint
Key: FLINK-29162
URL: https://issues.apache.org/jira/browse/FLINK-29162
Project: Flink
dalongliu created FLINK-29087:
-
Summary: Jdbc connector sql ITCase failed when run in idea
Key: FLINK-29087
URL: https://issues.apache.org/jira/browse/FLINK-29087
Project: Flink
Issue Type: Bug
dalongliu created FLINK-29069:
-
Summary: Release Testing: Verify FLIP-218 Create table as select
syntax
Key: FLINK-29069
URL: https://issues.apache.org/jira/browse/FLINK-29069
Project: Flink
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
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
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:
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
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
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
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
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-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:
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-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-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-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-27861:
-
Summary: Introduce UserResourceManager to manage user defined
resource
Key: FLINK-27861
URL: https://issues.apache.org/jira/browse/FLINK-27861
Project: Flink
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
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:
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-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-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-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-27593:
-
Summary: Parquet/Orc format reader optimization
Key: FLINK-27593
URL: https://issues.apache.org/jira/browse/FLINK-27593
Project: Flink
Issue Type: Bug
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
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
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
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
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
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
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-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
1 - 100 of 122 matches
Mail list logo
