[
https://issues.apache.org/jira/browse/FLINK-35473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854586#comment-17854586
]
Xuannan Su commented on FLINK-35473:
[~qingyue] Can you please include in the relea
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-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-34083:
--
Summary: Deprecate string configuration keys and unused constants
in ConfigConstants
Key: FLINK-34083
URL: https://issues.apache.org/jira/browse/FLINK-34083
Project: Flin
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
Pro
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-34297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812649#comment-17812649
]
Xuannan Su commented on FLINK-34297:
[~lincoln.86xy] This change doesn't need crosst
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-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-35089:
--
Summary: Two input AbstractStreamOperator may throw NPE when
receiving RecordAttributes
Key: FLINK-35089
URL: https://issues.apache.org/jira/browse/FLINK-35089
Project: F
[
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
`AbstractStre
[
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
`AbstractStre
[
https://issues.apache.org/jira/browse/FLINK-34079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-34079:
--
Assignee: Xuannan Su (was: Xuannan Su)
> FLIP-405: Migrate string configuration key to Confi
[
https://issues.apache.org/jira/browse/FLINK-34168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-34168:
--
Assignee: Xuannan Su (was: Xuannan Su)
> Refactor all callers that using the public Xxx getX
[
https://issues.apache.org/jira/browse/FLINK-34085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-34085:
--
Assignee: Xuannan Su (was: Xuannan Su)
> Remove deprecated string configuration keys in Flin
[
https://issues.apache.org/jira/browse/FLINK-33749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880574#comment-17880574
]
Xuannan Su commented on FLINK-33749:
This is duplicated with https://issues.apache.o
[
https://issues.apache.org/jira/browse/FLINK-34085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-34085.
Resolution: Fixed
> Remove deprecated string configuration keys in Flink 2.0
> ---
[
https://issues.apache.org/jira/browse/FLINK-34085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880837#comment-17880837
]
Xuannan Su commented on FLINK-34085:
master (2.0): e3a48c2a58a6bd08f305bb5883deef880
[
https://issues.apache.org/jira/browse/FLINK-34168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-34168.
Fix Version/s: 2.0-preview
Resolution: Fixed
> Refactor all callers that using the public X
[
https://issues.apache.org/jira/browse/FLINK-34168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881164#comment-17881164
]
Xuannan Su commented on FLINK-34168:
master(2.0): 740a5674fd92e4a7471432908071002316
[
https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881776#comment-17881776
]
Xuannan Su commented on FLINK-36258:
master (2.0): ed7f57c9ccb23957e24a79668daf2302b
[
https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-36258.
Resolution: Fixed
> testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided
> ---
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: Im
[
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
backward-c
[
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
backward-c
[
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
backward-c
Xuannan Su created FLINK-35461:
--
Summary: Improve Runtime Configuration for Flink 2.0
Key: FLINK-35461
URL: https://issues.apache.org/jira/browse/FLINK-35461
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-35461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35461:
---
Description:
As Flink moves toward 2.0, we have revisited all runtime configurations and
identified
Xuannan Su created FLINK-35475:
--
Summary: Introduce isInternalSorterSupport to OperatorAttributes
Key: FLINK-35475
URL: https://issues.apache.org/jira/browse/FLINK-35475
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-35461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35461:
---
Release Note:
The following configurations have been deprecated as we are phasing out the
hash-bas
[
https://issues.apache.org/jira/browse/FLINK-35461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35461:
---
Release Note:
The following configurations have been deprecated as we are phasing out the
hash-bas
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: https://issues.apache.org/jira/browse/FLINK-332
[
https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775983#comment-17775983
]
Xuannan Su commented on FLINK-33184:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-19343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241382#comment-17241382
]
Xuannan Su commented on FLINK-19343:
Hi, Jin Xing. Thanks for your comments.
1. I ag
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 Type
[
https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228464#comment-17228464
]
Xuannan Su commented on FLINK-20050:
I think it is introduced by this commit
[d5b51
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228958#comment-17228958
]
Xuannan Su commented on FLINK-19253:
I think it is a potential race condition in Spl
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229013#comment-17229013
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] I'd love to submit a fix. Could y
[
https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229079#comment-17229079
]
Xuannan Su commented on FLINK-20068:
Another instance
https://dev.azure.com/apache-f
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229980#comment-17229980
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] You are right. This indeed can ca
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230377#comment-17230377
]
Xuannan Su commented on FLINK-19253:
[~becket_qin] I think https://issues.apache.org
[
https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230756#comment-17230756
]
Xuannan Su commented on FLINK-19253:
Thanks for letting me know. I will stay tuned u
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: New
[
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-19347:
--
Summary: Generate InputGateDeploymentDescriptor from a JobVertex
with ClusterPartitionDescriptor
Key: FLINK-19347
URL: https://issues.apache.org/jira/browse/FLINK-19347
P
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-19349:
--
Summary: StreamGraph handle CacheSource and CacheSink
Key: FLINK-19349
URL: https://issues.apache.org/jira/browse/FLINK-19349
Project: Flink
Issue Type: Sub-task
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-19350:
--
Summary: StreamingJobGraphGenerator generate job graph with cached
node
Key: FLINK-19350
URL: https://issues.apache.org/jira/browse/FLINK-19350
Project: Flink
I
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
[
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 CacheSource
[
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-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
Repo
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: Sub-task
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: Su
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
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
[
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 I
[
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
> --
[
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 ClusterPartitio
[
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-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214408#comment-17214408
]
Xuannan Su commented on FLINK-19508:
This is a very useful feature to have. Thanks [
Xuannan Su created FLINK-19669:
--
Summary: PipelinedRegionSchedulingStrategy#init
ResultPartitionType blocking check should use isBlocking method
Key: FLINK-19669
URL: https://issues.apache.org/jira/browse/FLINK-19669
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: Flin
[
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. Otherw
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
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-13574:
--
Summary: Introduce IntermediateResultStorage Interface
Key: FLINK-13574
URL: https://issues.apache.org/jira/browse/FLINK-13574
Project: Flink
Issue Type: Sub-tas
Xuannan Su created FLINK-13575:
--
Summary: Introduce IntermediateResultStorageDescriptor
Key: FLINK-13575
URL: https://issues.apache.org/jira/browse/FLINK-13575
Project: Flink
Issue Type: Sub-tas
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 Type
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 Typ
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-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
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: Bu
[
https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706184#comment-17706184
]
Xuannan Su commented on FLINK-24456:
Thanks for the effort! This is a particularly u
[
https://issues.apache.org/jira/browse/FLINK-30607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706208#comment-17706208
]
Xuannan Su commented on FLINK-30607:
[~dianfu] Thanks for the patch! This is very us
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&focusedCommentId=17218826#comment-17218826
]
Xuannan Su commented on FLINK-19761:
cc [~trohrmann] [~azagrebin] [~zjwang]
I'd lov
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218891#comment-17218891
]
Xuannan Su commented on FLINK-19761:
[~trohrmann] The assumption is that the Shuffle
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220452#comment-17220452
]
Xuannan Su commented on FLINK-19761:
You are right that not returning all the inform
[
https://issues.apache.org/jira/browse/FLINK-16127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038849#comment-17038849
]
Xuannan Su commented on FLINK-16127:
Hi [~jark], I'd like to take this issue. Could
[
https://issues.apache.org/jira/browse/FLINK-16128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038856#comment-17038856
]
Xuannan Su commented on FLINK-16128:
Hi [~jark], I'd like to take this issue. Could
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-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-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
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: Improvement
[
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-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: I
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
I
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
I
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 com
[
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 TemporalJoinSQLEx
[
https://issues.apache.org/jira/browse/FLINK-28964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597462#comment-17597462
]
Xuannan Su commented on FLINK-28964:
Thank [~jessionX] for your testing. I think you
[
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-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
1 - 100 of 174 matches
Mail list logo
