Xuannan Su created FLINK-13575:
--
Summary: Introduce IntermediateResultStorageDescriptor
Key: FLINK-13575
URL: https://issues.apache.org/jira/browse/FLINK-13575
Project: Flink
Issue Type:
Xuannan Su created FLINK-13574:
--
Summary: Introduce IntermediateResultStorage Interface
Key: FLINK-13574
URL: https://issues.apache.org/jira/browse/FLINK-13574
Project: Flink
Issue Type:
Xuannan Su created FLINK-13576:
--
Summary: Enable configuring IntermediateResultStorage with YAML
Key: FLINK-13576
URL: https://issues.apache.org/jira/browse/FLINK-13576
Project: Flink
Issue
Xuannan Su created FLINK-13572:
--
Summary: Introduce Configurable, TableCreationHook and
TableCleanupHook Interfaces
Key: FLINK-13572
URL: https://issues.apache.org/jira/browse/FLINK-13572
Project: Flink
Xuannan Su created FLINK-13570:
--
Summary: Pluggable Intermediate Result Storage
Key: FLINK-13570
URL: https://issues.apache.org/jira/browse/FLINK-13570
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-16127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038849#comment-17038849
]
Xuannan Su commented on FLINK-16127:
Hi [~jark], I'd like to take this issue. Could you assign it to
[
https://issues.apache.org/jira/browse/FLINK-16128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038856#comment-17038856
]
Xuannan Su commented on FLINK-16128:
Hi [~jark], I'd like to take this issue. Could you assign it to
[
https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214408#comment-17214408
]
Xuannan Su commented on FLINK-19508:
This is a very useful feature to have. Thanks [~sjwiesman] for
[
https://issues.apache.org/jira/browse/FLINK-19346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19346:
---
Component/s: Runtime / Coordination
> Generate and put ClusterPartitionDescriptor of
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19343:
---
Component/s: (was: Table SQL / API)
> FLIP-36: Support Interactive Programming in Flink
>
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19343:
---
Component/s: (was: Runtime / Coordination)
Table SQL / API
> FLIP-36: Support
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19343:
---
Component/s: Runtime / Coordination
> FLIP-36: Support Interactive Programming in Flink
>
Xuannan Su created FLINK-19669:
--
Summary: PipelinedRegionSchedulingStrategy#init
ResultPartitionType blocking check should use isBlocking method
Key: FLINK-19669
URL:
Xuannan Su created FLINK-19476:
--
Summary: Introduce CacheManager in CatalogManager to keep track of
the ClusterPartitionDescriptor
Key: FLINK-19476
URL: https://issues.apache.org/jira/browse/FLINK-19476
Xuannan Su created FLINK-19343:
--
Summary: FLIP-36: Support Interactive Programming in Flink
Key: FLINK-19343
URL: https://issues.apache.org/jira/browse/FLINK-19343
Project: Flink
Issue Type:
Xuannan Su created FLINK-19348:
--
Summary: Introduce CacheSource and CacheSink
Key: FLINK-19348
URL: https://issues.apache.org/jira/browse/FLINK-19348
Project: Flink
Issue Type: Sub-task
Xuannan Su created FLINK-19351:
--
Summary: StreamingJobGraphGenerator set the caching node to
BoundedBlockingType
Key: FLINK-19351
URL: https://issues.apache.org/jira/browse/FLINK-19351
Project: Flink
Xuannan Su created FLINK-19349:
--
Summary: StreamGraph handle CacheSource and CacheSink
Key: FLINK-19349
URL: https://issues.apache.org/jira/browse/FLINK-19349
Project: Flink
Issue Type:
Xuannan Su created FLINK-19350:
--
Summary: StreamingJobGraphGenerator generate job graph with cached
node
Key: FLINK-19350
URL: https://issues.apache.org/jira/browse/FLINK-19350
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19349:
---
Summary: StreamGraphGenerator handle CacheSource and CacheSink (was:
StreamGraph handle
Xuannan Su created FLINK-19346:
--
Summary: Generate and put ClusterPartitionDescriptor of
ClusterPartition in JobResult when job finishes
Key: FLINK-19346
URL: https://issues.apache.org/jira/browse/FLINK-19346
Xuannan Su created FLINK-19347:
--
Summary: Generate InputGateDeploymentDescriptor from a JobVertex
with ClusterPartitionDescriptor
Key: FLINK-19347
URL: https://issues.apache.org/jira/browse/FLINK-19347
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19343:
---
Component/s: Table SQL / API
> FLIP-36: Support Interactive Programming in Flink
>
Xuannan Su created FLINK-19354:
--
Summary: Add invalidateCache() method in CachedTable
Key: FLINK-19354
URL: https://issues.apache.org/jira/browse/FLINK-19354
Project: Flink
Issue Type:
Xuannan Su created FLINK-19355:
--
Summary: Add close() method to TableEnvironment
Key: FLINK-19355
URL: https://issues.apache.org/jira/browse/FLINK-19355
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-19350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-19350:
---
Summary: StreamingJobGraphGenerator add the ClusterPartitionDescriptor of
cached node to JobVertex
Xuannan Su created FLINK-19353:
--
Summary: BlinkPlanner translate and optimize CacheOperation
Key: FLINK-19353
URL: https://issues.apache.org/jira/browse/FLINK-19353
Project: Flink
Issue Type:
Xuannan Su created FLINK-19352:
--
Summary: Add cache() method to Table
Key: FLINK-19352
URL: https://issues.apache.org/jira/browse/FLINK-19352
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218826#comment-17218826
]
Xuannan Su commented on FLINK-19761:
cc [~trohrmann] [~azagrebin] [~zjwang]
I'd love to hear your
Xuannan Su created FLINK-19761:
--
Summary: Add lookup method for registered ShuffleDescriptor in
ShuffleMaster
Key: FLINK-19761
URL: https://issues.apache.org/jira/browse/FLINK-19761
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218891#comment-17218891
]
Xuannan Su commented on FLINK-19761:
[~trohrmann] The assumption is that the ShuffleMaster should
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220452#comment-17220452
]
Xuannan Su commented on FLINK-19761:
You are right that not returning all the information it needs
Xuannan Su created FLINK-18820:
--
Summary: SourceOperator should send MAX_WATERMARK to downstream
operator when closed
Key: FLINK-18820
URL: https://issues.apache.org/jira/browse/FLINK-18820
Project:
[
https://issues.apache.org/jira/browse/FLINK-18820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-18820:
---
Description: SourceOperator should send MAX_WATERMARK to the downstream
operator when closed.
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241382#comment-17241382
]
Xuannan Su commented on FLINK-19343:
Hi, Jin Xing. Thanks for your comments.
1. I agree with you
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228958#comment-17228958
]
Xuannan Su commented on FLINK-19253:
I think it is a potential race condition in SplitFetcher.
It
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229013#comment-17229013
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] I'd love to submit a fix. Could you assign the
[
https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229079#comment-17229079
]
Xuannan Su commented on FLINK-20068:
Another instance
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229980#comment-17229980
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] You are right. This indeed can cause
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230756#comment-17230756
]
Xuannan Su commented on FLINK-19253:
Thanks for letting me know. I will stay tuned until we can
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230377#comment-17230377
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] I think
[
https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228464#comment-17228464
]
Xuannan Su commented on FLINK-20050:
I think it is introduced by this commit
Xuannan Su created FLINK-20018:
--
Summary: pipeline.cached-files option cannot escape ':' in path
Key: FLINK-20018
URL: https://issues.apache.org/jira/browse/FLINK-20018
Project: Flink
Issue
Xuannan Su created FLINK-26171:
--
Summary: pyFlink -py options has issue with path that starts with
//
Key: FLINK-26171
URL: https://issues.apache.org/jira/browse/FLINK-26171
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493008#comment-17493008
]
Xuannan Su commented on FLINK-26171:
After some research, I found that the leading two slashes are
Xuannan Su created FLINK-25685:
--
Summary: RestClusterClient gets stuck on submitting job with local
user artifact
Key: FLINK-25685
URL: https://issues.apache.org/jira/browse/FLINK-25685
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478023#comment-17478023
]
Xuannan Su commented on FLINK-25685:
I create a pr that adds the unit tests with and without
[
https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479802#comment-17479802
]
Xuannan Su commented on FLINK-25685:
[~chesnay], I created a PR with unit test and the fix. May you
[
https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-25685:
---
Affects Version/s: 1.15.0
> RestClusterClient gets stuck on submitting job with local user artifact
[
https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479869#comment-17479869
]
Xuannan Su commented on FLINK-25685:
[~wangyang0918] You are right. (y) The fix is to use
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775983#comment-17775983
]
Xuannan Su commented on FLINK-33184:
Xuannan Su created FLINK-33399:
--
Summary: Support switching from batch to stream mode for
KeyedCoProcessOperator and IntervalJoinOperator
Key: FLINK-33399
URL: https://issues.apache.org/jira/browse/FLINK-33399
Xuannan Su created FLINK-33398:
--
Summary: Support switching from batch to stream mode for one input
stream operator
Key: FLINK-33398
URL: https://issues.apache.org/jira/browse/FLINK-33398
Project: Flink
Xuannan Su created FLINK-33202:
--
Summary: FLIP-327: Support switching from batch to stream mode to
improve throughput when processing backlog data
Key: FLINK-33202
URL:
Xuannan Su created FLINK-28443:
--
Summary: Provide official Flink image for PyFlink
Key: FLINK-28443
URL: https://issues.apache.org/jira/browse/FLINK-28443
Project: Flink
Issue Type: Improvement
Xuannan Su created FLINK-28461:
--
Summary: PyFlink Table should add get_resolved_schema method
Key: FLINK-28461
URL: https://issues.apache.org/jira/browse/FLINK-28461
Project: Flink
Issue Type:
Title: Message Title
Xuannan Su created
Xuannan Su created FLINK-28126:
--
Summary: Iteration gets stuck when replayable datastream and its
downstream operator have different parallelism
Key: FLINK-28126
URL:
Xuannan Su created FLINK-28528:
--
Summary: Table.getSchema fails on table with watermark
Key: FLINK-28528
URL: https://issues.apache.org/jira/browse/FLINK-28528
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-28528:
---
Description:
The bug can be reproduced with the following test. The test can pass if we use
the
Xuannan Su created FLINK-28526:
--
Summary: Fail to lateral join with UDTF from Table with timstamp
column
Key: FLINK-28526
URL: https://issues.apache.org/jira/browse/FLINK-28526
Project: Flink
Xuannan Su created FLINK-28527:
--
Summary: Fail to lateral join with UDTF from Table with timstamp
column
Key: FLINK-28527
URL: https://issues.apache.org/jira/browse/FLINK-28527
Project: Flink
Xuannan Su created FLINK-28742:
--
Summary: Table.to_pandas fails with lit("xxx")
Key: FLINK-28742
URL: https://issues.apache.org/jira/browse/FLINK-28742
Project: Flink
Issue Type: Bug
Xuannan Su created FLINK-27523:
--
Summary: Runtime supports producing and consuming cached
intermediate result
Key: FLINK-27523
URL: https://issues.apache.org/jira/browse/FLINK-27523
Project: Flink
Xuannan Su created FLINK-27521:
--
Summary: FLIP-205: Support Cache in DataStream for Batch Processing
Key: FLINK-27521
URL: https://issues.apache.org/jira/browse/FLINK-27521
Project: Flink
Issue
Xuannan Su created FLINK-27524:
--
Summary: Introduce cache API to DataStream
Key: FLINK-27524
URL: https://issues.apache.org/jira/browse/FLINK-27524
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597462#comment-17597462
]
Xuannan Su commented on FLINK-28964:
Thank [~jessionX] for your testing. I think you have run the
[
https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-28988:
---
Description:
The following code can reproduce the case
{code:java}
public class
[
https://issues.apache.org/jira/browse/FLINK-28964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-28964.
Resolution: Fixed
> Release Testing: Verify FLIP-205 Cache in DataStream for Batch Processing
>
Xuannan Su created FLINK-29753:
--
Summary: FileSource throws exception reading file with name that
ends with xz
Key: FLINK-29753
URL: https://issues.apache.org/jira/browse/FLINK-29753
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606950#comment-17606950
]
Xuannan Su commented on FLINK-29339:
[~gaoyunhaii] I will take a look. Could you assign the ticket
Xuannan Su created FLINK-29231:
--
Summary: PyFlink udtaf produces different results in the same
sliding window
Key: FLINK-29231
URL: https://issues.apache.org/jira/browse/FLINK-29231
Project: Flink
Xuannan Su created FLINK-28857:
--
Summary: Add Document for DataStream Cache API
Key: FLINK-28857
URL: https://issues.apache.org/jira/browse/FLINK-28857
Project: Flink
Issue Type: Sub-task
Xuannan Su created FLINK-28964:
--
Summary: Release Testing: Verify FLIP-205 Cache in DataStream for
Batch Processing
Key: FLINK-28964
URL: https://issues.apache.org/jira/browse/FLINK-28964
Project: Flink
Xuannan Su created FLINK-28988:
--
Summary: Incorrect result for filter after temporal join
Key: FLINK-28988
URL: https://issues.apache.org/jira/browse/FLINK-28988
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577084#comment-17577084
]
Xuannan Su commented on FLINK-28860:
[~hxbks2ks]I will take a look at it. Could you assign the
Xuannan Su created FLINK-30607:
--
Summary: Table.to_pandas doesn't support Map type
Key: FLINK-30607
URL: https://issues.apache.org/jira/browse/FLINK-30607
Project: Flink
Issue Type: Bug
Xuannan Su created FLINK-30078:
--
Summary: Temporal join should finish when the left table is
bounded and finished
Key: FLINK-30078
URL: https://issues.apache.org/jira/browse/FLINK-30078
Project: Flink
Xuannan Su created FLINK-30258:
--
Summary: PyFlink supports closing loop back server
Key: FLINK-30258
URL: https://issues.apache.org/jira/browse/FLINK-30258
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-30258:
---
Description:
Currently, a loopback server will be started whenever a
StreamExecutionEnvironment or
[
https://issues.apache.org/jira/browse/FLINK-30258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-30258:
---
Summary: PyFlink supports closing loopback server (was: PyFlink supports
closing loop back server)
Xuannan Su created FLINK-29951:
--
Summary: Kafka SQL connector supports setting end offset/timestamp
Key: FLINK-29951
URL: https://issues.apache.org/jira/browse/FLINK-29951
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632108#comment-17632108
]
Xuannan Su commented on FLINK-19200:
Any update on this issue? I am also looking for a way to
Xuannan Su created FLINK-31943:
--
Summary: Multiple t_env cause class loading problem
Key: FLINK-31943
URL: https://issues.apache.org/jira/browse/FLINK-31943
Project: Flink
Issue Type: Bug
Xuannan Su created FLINK-31944:
--
Summary: Protobuf format throw
com.google.protobuf.InvalidProtocolBufferException
Key: FLINK-31944
URL: https://issues.apache.org/jira/browse/FLINK-31944
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706184#comment-17706184
]
Xuannan Su commented on FLINK-24456:
Thanks for the effort! This is a particularly useful feature in
[
https://issues.apache.org/jira/browse/FLINK-30607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706208#comment-17706208
]
Xuannan Su commented on FLINK-30607:
[~dianfu] Thanks for the patch! This is very useful in our use
Xuannan Su created FLINK-32476:
--
Summary: Support configuring object-reuse for internal operators
Key: FLINK-32476
URL: https://issues.apache.org/jira/browse/FLINK-32476
Project: Flink
Issue
Xuannan Su created FLINK-32008:
--
Summary: Protobuf format throws exception with Map datatype
Key: FLINK-32008
URL: https://issues.apache.org/jira/browse/FLINK-32008
Project: Flink
Issue Type:
Xuannan Su created FLINK-33890:
--
Summary: Determine the initial status before receiving the first
RecordAttributes
Key: FLINK-33890
URL: https://issues.apache.org/jira/browse/FLINK-33890
Project: Flink
Xuannan Su created FLINK-33810:
--
Summary: Propagate RecordAttributes that contains
isProcessingBacklog status
Key: FLINK-33810
URL: https://issues.apache.org/jira/browse/FLINK-33810
Project: Flink
Xuannan Su created FLINK-34085:
--
Summary: Remove deprecated string configuration keys in Flink 2.0
Key: FLINK-34085
URL: https://issues.apache.org/jira/browse/FLINK-34085
Project: Flink
Issue
Xuannan Su created FLINK-34084:
--
Summary: Deprecate unused configuration in
BinaryInput/OutputFormat and FileInput/OutputFormat
Key: FLINK-34084
URL: https://issues.apache.org/jira/browse/FLINK-34084
Xuannan Su created FLINK-34083:
--
Summary: Deprecate string configuration keys and unused constants
in ConfigConstants
Key: FLINK-34083
URL: https://issues.apache.org/jira/browse/FLINK-34083
Project:
[
https://issues.apache.org/jira/browse/FLINK-34297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812649#comment-17812649
]
Xuannan Su commented on FLINK-34297:
[~lincoln.86xy] This change doesn't need crossteam testing. I
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35089:
---
Description:
Currently the `lastRecordAttributes1` and `lastRecordAttributes2` in the
Xuannan Su created FLINK-35089:
--
Summary: Two input AbstractStreamOperator may throw NPE when
receiving RecordAttributes
Key: FLINK-35089
URL: https://issues.apache.org/jira/browse/FLINK-35089
Project:
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35089:
---
Description:
Currently the `lastRecordAttributes1` and `lastRecordAttributes2` in the
Xuannan Su created FLINK-35359:
--
Summary: General Improvement to Configuration for Flink 2.0
Key: FLINK-35359
URL: https://issues.apache.org/jira/browse/FLINK-35359
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35359:
---
Release Note:
- The following configurations have been updated to the Duration type in a
1 - 100 of 107 matches
Mail list logo
