[
https://issues.apache.org/jira/browse/FLINK-36261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su closed FLINK-36261.
--
Resolution: Fixed
> Revisit all breaking changes before Flink 2.0 Preview
> --
[
https://issues.apache.org/jira/browse/FLINK-36261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887756#comment-17887756
]
Xuannan Su edited comment on FLINK-36261 at 10/9/24 3:55 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887756#comment-17887756
]
Xuannan Su commented on FLINK-36261:
All the breaking changes have been listed in th
[
https://issues.apache.org/jira/browse/FLINK-36437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36437:
--
Assignee: Xuannan Su (was: Weijie Guo)
> Hive connector failed to compile with JDK 11
>
Xuannan Su created FLINK-36437:
--
Summary: Hive connector failed to compile with JDK 11
Key: FLINK-36437
URL: https://issues.apache.org/jira/browse/FLINK-36437
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-36261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36261:
--
Assignee: Xuannan Su (was: Xuannan Su)
> Revisit all breaking changes before Flink 2.0 Previ
[
https://issues.apache.org/jira/browse/FLINK-35012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885795#comment-17885795
]
Xuannan Su commented on FLINK-35012:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885775#comment-17885775
]
Xuannan Su commented on FLINK-36348:
master(2.0): 338d0246eccd66fbc5e20d433c8cdd090e
[
https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-36348.
Resolution: Fixed
> Netty shuffle direct memory consumption end-to-end test failed due to direct
[
https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su resolved FLINK-33750.
Resolution: Fixed
> Remove deprecated config options.
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885672#comment-17885672
]
Xuannan Su commented on FLINK-33750:
All of the following configurations have been c
[
https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36348:
--
Assignee: Xuannan Su
> Netty shuffle direct memory consumption end-to-end test failed due to
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885280#comment-17885280
]
Xuannan Su edited comment on FLINK-36290 at 9/27/24 9:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885280#comment-17885280
]
Xuannan Su edited comment on FLINK-36290 at 9/27/24 9:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885280#comment-17885280
]
Xuannan Su commented on FLINK-36290:
It is probably related to the [commit|http://
[
https://issues.apache.org/jira/browse/FLINK-36305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su closed FLINK-36305.
--
Resolution: Duplicate
> Remove deprecated Table/SQL config options
> -
[
https://issues.apache.org/jira/browse/FLINK-36304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su closed FLINK-36304.
--
Resolution: Duplicate
> Remove deprecated Statebackend config options
> --
[
https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883652#comment-17883652
]
Xuannan Su commented on FLINK-33750:
Most easy-to-remove ConfigOptions are removed
[
https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883214#comment-17883214
]
Xuannan Su commented on FLINK-36292:
https://dev.azure.com/apache-flink/apache-flink
Xuannan Su created FLINK-36311:
--
Summary: Remove deprecated flink-formats config options
Key: FLINK-36311
URL: https://issues.apache.org/jira/browse/FLINK-36311
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36311:
--
Assignee: Dian Fu
> Remove deprecated flink-formats config options
>
Xuannan Su created FLINK-36308:
--
Summary: Remove deprecated CEP config options
Key: FLINK-36308
URL: https://issues.apache.org/jira/browse/FLINK-36308
Project: Flink
Issue Type: Sub-task
Xuannan Su created FLINK-36307:
--
Summary: Remove deprecated config options
Key: FLINK-36307
URL: https://issues.apache.org/jira/browse/FLINK-36307
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36307:
---
Component/s: (was: Runtime / Configuration)
> Remove deprecated PyFlink config options
> ---
[
https://issues.apache.org/jira/browse/FLINK-36308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36308:
--
Assignee: Dian Fu
> Remove deprecated CEP config options
> --
[
https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36307:
---
Fix Version/s: 2.0-preview
> Remove deprecated PyFlink config options
>
[
https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36307:
--
Assignee: Dian Fu
> Remove deprecated PyFlink config options
> --
[
https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36307:
---
Component/s: API / Python
Runtime / Configuration
Summary: Remove deprecated
[
https://issues.apache.org/jira/browse/FLINK-36304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su reassigned FLINK-36304:
--
Assignee: Zakelly Lan
> Remove deprecated Statebackend config options
> -
Xuannan Su created FLINK-36305:
--
Summary: Remove deprecated Table/SQL config options
Key: FLINK-36305
URL: https://issues.apache.org/jira/browse/FLINK-36305
Project: Flink
Issue Type: Sub-task
Xuannan Su created FLINK-36304:
--
Summary: Remove deprecated Statebackend config options
Key: FLINK-36304
URL: https://issues.apache.org/jira/browse/FLINK-36304
Project: Flink
Issue Type: Sub-tas
[
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
> ---
[
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-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-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-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-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-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 reassigned FLINK-34085:
--
Assignee: Xuannan Su (was: Xuannan Su)
> Remove deprecated string configuration keys in Flin
[
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-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-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
[
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-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:
---
Description:
As Flink moves toward 2.0, we have revisited all runtime configurations and
identified
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-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-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-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
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-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-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
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-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-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-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
[
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
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
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-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
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-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
[
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
[
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
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
[
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)
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632108#comment-17632108
]
Xuannan Su commented on FLINK-19200:
Any update on this issue? I am also looking for
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 T
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&focusedCommentId=17606950#comment-17606950
]
Xuannan Su commented on FLINK-29339:
[~gaoyunhaii] I will take a look. Could you ass
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
[
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
> --
[
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-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
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
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
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577084#comment-17577084
]
Xuannan Su commented on FLINK-28860:
[~hxbks2ks]I will take a look at it. Could you
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-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
C
[
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
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
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-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-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-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
Title: Message Title
Xuannan Su created an
Xuannan Su created FLINK-28126:
--
Summary: Iteration gets stuck when replayable datastream and its
downstream operator have different parallelism
Key: FLINK-28126
URL: https://issues.apache.org/jira/browse/FLINK-28126
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-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
[
https://issues.apache.org/jira/browse/FLINK-26171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493008#comment-17493008
]
Xuannan Su commented on FLINK-26171:
After some research, I found that the leading t
1 - 100 of 149 matches
Mail list logo
