[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22678: -- Component/s: Runtime / State Backends > Hide ChangelogStateBackend From Users > -

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Created] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

Jin Xing created FLINK-23030: Summary: PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure Key: FLINK-23030 URL: https://issues.apache.org/jira/browse/FLINK-23030

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Commented] (FLINK-23026) OVER WINDOWS function lost data

[ https://issues.apache.org/jira/browse/FLINK-23026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365286#comment-17365286 ] Jark Wu commented on FLINK-23026: - This is as expected, because your watermark value is

[jira] [Closed] (FLINK-23026) OVER WINDOWS function lost data

[ https://issues.apache.org/jira/browse/FLINK-23026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23026. --- Resolution: Not A Problem > OVER WINDOWS function lost data > --- > >

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

[ https://issues.apache.org/jira/browse/FLINK-23030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jin Xing updated FLINK-23030: - Description: In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#aw

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365301#comment-17365301 ] Wenlong Lyu commented on FLINK-22954: - [~godfreyhe] thanks for correct me, you are

[jira] [Created] (FLINK-23031) Support to emit window result with periodic or non_periodic

Aitozi created FLINK-23031: -- Summary: Support to emit window result with periodic or non_periodic Key: FLINK-23031 URL: https://issues.apache.org/jira/browse/FLINK-23031 Project: Flink Issue Type:

[jira] [Reopened] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-22815: -- Reopen to add release notes. > Disable unaligned checkpoints for broadcast partitioning >

[jira] [Closed] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

[ https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22815. Release Note: Unaligned checkpoints were disabled for BROADCAST exchanges. Broadcast part

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365306#comment-17365306 ] Aitozi commented on FLINK-23031: In flink sql, we can use EmitStrategy to set an early o

[jira] [Assigned] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22625: -- Assignee: Anton Kalashnikov (was: Yun Gao) > FileSinkMigrationITCase unstable >

[jira] [Closed] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22625. -- Fix Version/s: 1.14.0 Resolution: Fixed Probable fix merged to master as 3ae6801f6e3 >

[jira] [Closed] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22593. -- Resolution: Fixed Merged to master as 3fa69829517 > SavepointITCase.testShouldAddEntropyToSav

[jira] [Updated] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable

[ https://issues.apache.org/jira/browse/FLINK-23024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-23024: --- Labels: pull-request-available (was: ) > RPC result TaskManagerInfoWithSlots not serializable > ---

[jira] [Assigned] (FLINK-18783) Load AkkaRpcService through separate class loader

[ https://issues.apache.org/jira/browse/FLINK-18783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-18783: Assignee: Chesnay Schepler > Load AkkaRpcService through separate class loader >

[jira] [Updated] (FLINK-18783) Load AkkaRpcService through separate class loader

[ https://issues.apache.org/jira/browse/FLINK-18783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18783: - Parent: FLINK-14105 Issue Type: Sub-task (was: Improvement) > Load AkkaRpcServi

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21952: Labels: (was: auto-deprioritized-major) > Make all the "Connection reset by peer" exception wrapped as

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21952: Labels: auto-deprioritized-major (was: auto-deprioritized-major stale-assigned) > Make all the "Connecti

[jira] [Commented] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365374#comment-17365374 ] Maciej Bryński commented on FLINK-23020: I'm not sure how kernel interrupt is wo

[jira] [Updated] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22518: - Fix Version/s: 1.14.0 > Translate the page of "High Availability (HA)" into Chinese > --

[jira] [Commented] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365377#comment-17365377 ] Yun Tang commented on FLINK-22518: -- Merged master: fc73b3fe99951c91459842cad60236c537cd

[jira] [Comment Edited] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365374#comment-17365374 ] Maciej Bryński edited comment on FLINK-23020 at 6/18/21, 9:01 AM:

[jira] [Created] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

Rui Li created FLINK-23032: -- Summary: Refactor HiveSource to make it usable in data stream job Key: FLINK-23032 URL: https://issues.apache.org/jira/browse/FLINK-23032 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals

[ https://issues.apache.org/jira/browse/FLINK-22967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365381#comment-17365381 ] Maciej Bryński commented on FLINK-22967: I'm closing this as fixed in 1.13.1 >

[jira] [Updated] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals

[ https://issues.apache.org/jira/browse/FLINK-22967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-22967: --- Fix Version/s: 1.13.1 > CodeGenException: Unsupported cast for nested Decimals > ---

[jira] [Closed] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals

[ https://issues.apache.org/jira/browse/FLINK-22967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński closed FLINK-22967. -- Resolution: Fixed > CodeGenException: Unsupported cast for nested Decimals > -

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365382#comment-17365382 ] Cooper Luan edited comment on FLINK-22955 at 6/18/21, 9:05 AM: ---

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365382#comment-17365382 ] Cooper Luan commented on FLINK-22955: - actually it's not possible for us to implemen

[jira] [Resolved] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22518. -- Resolution: Fixed > Translate the page of "High Availability (HA)" into Chinese >

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365384#comment-17365384 ] Yun Gao commented on FLINK-22625: - Hi [~akalashnikov], does the original issue happens d

[jira] [Comment Edited] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365384#comment-17365384 ] Yun Gao edited comment on FLINK-22625 at 6/18/21, 9:09 AM: --- Hi

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365382#comment-17365382 ] Cooper Luan edited comment on FLINK-22955 at 6/18/21, 9:10 AM: ---

[jira] [Closed] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15752. -- Resolution: Duplicate I have independently discovered this issue and fixed it sometime ago as

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365389#comment-17365389 ] Anton Kalashnikov commented on FLINK-22625: --- ??a single sink task might count

[jira] [Comment Edited] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365386#comment-17365386 ] Piotr Nowojski edited comment on FLINK-15752 at 6/18/21, 9:15 AM:

[jira] [Updated] (FLINK-22489) subtask backpressure indicator shows value for entire job

[ https://issues.apache.org/jira/browse/FLINK-22489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22489: --- Description: In the backpressure tab of the web UI, the OK/LOW/HIGH indication is displaying

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365382#comment-17365382 ] Cooper Luan edited comment on FLINK-22955 at 6/18/21, 9:16 AM: ---

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365391#comment-17365391 ] Emre Kartoglu commented on FLINK-23009: --- release 1.12: https://github.com/apache/f

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365390#comment-17365390 ] Yun Gao commented on FLINK-22625: - Got it, very thanks for the fix and the explanation~

[jira] [Commented] (FLINK-22995) Failed to acquire lease 'ConfigMapLock: .... retrying...

[ https://issues.apache.org/jira/browse/FLINK-22995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365402#comment-17365402 ] Till Rohrmann commented on FLINK-22995: --- Could it then be that the lease did not t

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22662: - Affects Version/s: 1.14.0 > YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22662: - Affects Version/s: (was: 1.13.0) 1.13.1 > YARNHighAvailabilityITCase.

[jira] [Commented] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365414#comment-17365414 ] Xintong Song commented on FLINK-22662: -- Unfortunately, I'm not able to confirm our

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Summary: State factories should handle extended state descriptors (was: TTL state factory should handle

[jira] [Commented] (FLINK-16090) Translate "Table API" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365419#comment-17365419 ] ji yinglong commented on FLINK-16090: - [~jark] ,  could you assign it to me? I'd lik

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Description: Currently, {{TtlStateFactory}} and other state factories can only handle fixed type of sta

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365421#comment-17365421 ] guxiang commented on FLINK-18464: - Hi,  I ran into the same problem, and I can reproduce

[jira] [Commented] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365423#comment-17365423 ] zhangzhl commented on FLINK-12941: -- hi [~jark] I'm willing to translate this page. Coul

[jira] [Closed] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable

[ https://issues.apache.org/jira/browse/FLINK-23024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23024. - Resolution: Fixed Fixed via master: 1a3c797ea3f20efff9246d30c76fbdd6a45e9030 1.13.2: 9f90d4b31f

[jira] [Created] (FLINK-23033) Support object array in Python DataStream API

Dian Fu created FLINK-23033: --- Summary: Support object array in Python DataStream API Key: FLINK-23033 URL: https://issues.apache.org/jira/browse/FLINK-23033 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-11733) Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

[ https://issues.apache.org/jira/browse/FLINK-11733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11733: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs

[ https://issues.apache.org/jira/browse/FLINK-11698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11698: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11672) Add example for streaming operators's connect

[ https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11672: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11673) add example for streaming operators's broadcast

[ https://issues.apache.org/jira/browse/FLINK-11673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11673: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11695) Make sharedStateDir could create sub-directories to avoid MaxDirectoryItemsExceededException

[ https://issues.apache.org/jira/browse/FLINK-11695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11695: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11616) Flink official document has an error

[ https://issues.apache.org/jira/browse/FLINK-11616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11616: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11734) Provide HadoopReduceFunction for org.apache.hadoop.mapreduce.Reducer

[ https://issues.apache.org/jira/browse/FLINK-11734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11734: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

[ https://issues.apache.org/jira/browse/FLINK-11697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11697: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11470) LocalEnvironment doesn't call FileSystem.initialize()

[ https://issues.apache.org/jira/browse/FLINK-11470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11470: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11639) Provide readSequenceFile for Hadoop new API

[ https://issues.apache.org/jira/browse/FLINK-11639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11639: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11619: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11569: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-11620) table example add kafka

[ https://issues.apache.org/jira/browse/FLINK-11620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11620: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11454: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-11543) Type mismatch AssertionError in FilterJoinRule

[ https://issues.apache.org/jira/browse/FLINK-11543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11543: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365457#comment-17365457 ] JING ZHANG commented on FLINK-22955: Hi [~gsavl]. You could disable `CoreRules.FILT

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365474#comment-17365474 ] Igal Shilman commented on FLINK-21308: -- Hi [~stephanpelikan], I think that, in the

[jira] [Comment Edited] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365474#comment-17365474 ] Igal Shilman edited comment on FLINK-21308 at 6/18/21, 12:10 PM: -

[jira] [Created] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState

Anton Kalashnikov created FLINK-23034: - Summary: NPE in JobDetailsDeserializer during the reading old version of ExecutionState Key: FLINK-23034 URL: https://issues.apache.org/jira/browse/FLINK-23034

[jira] [Updated] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState

[ https://issues.apache.org/jira/browse/FLINK-23034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-23034: -- Description: There is no compatibility for ExecutionState: {noformat} java.lang.NullPo

[jira] [Assigned] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-22678: - Assignee: Zakelly Lan (was: Yuan Mei) > Hide ChangelogStateBackend From Users > -

[jira] [Updated] (FLINK-23028) Improve documentation for pages of SQL.

[ https://issues.apache.org/jira/browse/FLINK-23028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-23028: - Component/s: Table SQL / API > Improve documentation for pages of SQL. > ---

[jira] [Assigned] (FLINK-21831) Add Changelog state for timers (PQ)

[ https://issues.apache.org/jira/browse/FLINK-21831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-21831: - Assignee: Piotr Nowojski > Add Changelog state for timers (PQ) >

[jira] [Created] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

Roman Khachatryan created FLINK-23035: - Summary: Add explicit method to StateChangelogWriter to write metadata Key: FLINK-23035 URL: https://issues.apache.org/jira/browse/FLINK-23035 Project: Flin

[jira] [Closed] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11569. Resolution: Duplicate Fixed as part of FLINK-18090. > Row type does not serialize in to readable

[jira] [Issue Comment Deleted] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11569: - Comment: was deleted (was: This issue was labeled "stale-major" 7 ago and has not received any

[jira] [Created] (FLINK-23037) Document limitations of UC

Dawid Wysakowicz created FLINK-23037: Summary: Document limitations of UC Key: FLINK-23037 URL: https://issues.apache.org/jira/browse/FLINK-23037 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23036) org.apache.flink.util.FlinkRuntimeException: Error while adding data to RocksDB

guxiang created FLINK-23036: --- Summary: org.apache.flink.util.FlinkRuntimeException: Error while adding data to RocksDB Key: FLINK-23036 URL: https://issues.apache.org/jira/browse/FLINK-23036 Project: Flink

[jira] [Issue Comment Deleted] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11569: - Comment: was deleted (was: This issue was marked "stale-assigned" and has not received an update

[jira] [Updated] (FLINK-23037) Document limitations of UC

[ https://issues.apache.org/jira/browse/FLINK-23037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23037: - Description: The goal of the task is to document limitations of UC and make it better d

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365485#comment-17365485 ] Timo Walther commented on FLINK-19830: -- I was also approached by a customer why we

[jira] [Issue Comment Deleted] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11569: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Issue Comment Deleted] (FLINK-11569) Row type does not serialize in to readable format when invoke "toString" method

[ https://issues.apache.org/jira/browse/FLINK-11569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11569: - Comment: was deleted (was: This issue is assigned but has not received an update in 7 days so it

[jira] [Reopened] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reopened FLINK-18464: --- Thanks for reporting, reopening the ticket. > ClassCastException during namespace seria

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18464: -- Summary: ClassCastException during namespace serialization for checkpoint (Heap and Ro

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18464: -- Component/s: (was: Runtime / Task) > ClassCastException during namespace serializa

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18464: -- Component/s: Runtime / State Backends > ClassCastException during namespace serializat

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18464: -- Affects Version/s: 1.13.1 > ClassCastException during namespace serialization for chec

[jira] [Closed] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22946. -- Resolution: Fixed Merged to master as 903de19442b Merged to release-1.13 as 59322aef23c Merged

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22946: --- Fix Version/s: 1.12.5 1.11.4 > Network buffer deadlock introduced by unal

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22946: --- Affects Version/s: (was: 1.13.0) 1.11.3 1.1

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365491#comment-17365491 ] Jark Wu commented on FLINK-19830: - [~twalthr] IIRC, the old temporal table function stil

[jira] [Assigned] (FLINK-16090) Translate "Table API" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16090: --- Assignee: ji yinglong > Translate "Table API" page of "Table API & SQL" into Chinese > ---

[jira] [Updated] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-22698: Affects Version/s: 1.13.1 1.12.4 > RabbitMQ source does not stop unless mes

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365494#comment-17365494 ] Jark Wu commented on FLINK-23031: - [~aitozi] what do you mean about "non_periodic"? We h

[jira] [Updated] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-22698: Affects Version/s: (was: 1.12.0) 1.12.4 > RabbitMQ source does not stop

[jira] [Updated] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-22698: Affects Version/s: (was: 1.12.4) > RabbitMQ source does not stop unless message arrives in que

[jira] [Created] (FLINK-23038) Broken link in Documentation Style Guide

Daisy Tsang created FLINK-23038: --- Summary: Broken link in Documentation Style Guide Key: FLINK-23038 URL: https://issues.apache.org/jira/browse/FLINK-23038 Project: Flink Issue Type: Bug

  1   2   3   4   >