[jira] [Resolved] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type

[ https://issues.apache.org/jira/browse/FLINK-4503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-4503. --- Resolution: Fixed Already done in FLINK-36355. > Remove with method from CoGroupedStream and JoinedS

[jira] [Closed] (FLINK-32383) 2.0 Breaking configuration changes

[ https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32383. Resolution: Fixed > 2.0 Breaking configuration changes > -- > >

[jira] [Updated] (FLINK-6375) Fix LongValue hashCode

[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-6375: -- Fix Version/s: 3.0.0 (was: 2.0.0) > Fix LongValue hashCode > ---

[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic

[ https://issues.apache.org/jira/browse/FLINK-13926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-13926: --- Parent: (was: FLINK-3957) Issue Type: Technical Debt (was: Sub-task) > `ProcessingTimeS

[jira] [Updated] (FLINK-6375) Fix LongValue hashCode

[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-6375: -- Parent: (was: FLINK-3957) Issue Type: Technical Debt (was: Sub-task) > Fix LongValue hashC

[jira] [Created] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader

Arvid Heise created FLINK-36434: --- Summary: Revise threading model of (KafkaPartition)SplitReader Key: FLINK-36434 URL: https://issues.apache.org/jira/browse/FLINK-36434 Project: Flink Issue Typ

[jira] [Resolved] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

[ https://issues.apache.org/jira/browse/FLINK-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-4675. --- Resolution: Done already done via FLINK-36355. > Remove Parameter from WindowAssigner.getDefaultTrig

[jira] [Updated] (FLINK-5875) Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-5875: -- Parent: (was: FLINK-3957) Issue Type: Technical Debt (was: Sub-task) > Use TypeComparator.

[jira] [Created] (FLINK-36433) non-keyed fullWindowPartition#reduce may throw NPE

xuhuang created FLINK-36433: --- Summary: non-keyed fullWindowPartition#reduce may throw NPE Key: FLINK-36433 URL: https://issues.apache.org/jira/browse/FLINK-36433 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic

[ https://issues.apache.org/jira/browse/FLINK-13926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-13926: --- Fix Version/s: 3.0.0 (was: 2.0.0) > `ProcessingTimeSessionWindows` and `Event

[jira] [Resolved] (FLINK-36360) Prepare release process and Scripts for the preview release

[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-36360. Resolution: Done > Prepare release process and Scripts for the preview release > -

[jira] [Assigned] (FLINK-36261) Revisit all breaking changes before Flink 2.0 Preview

[ 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

[jira] [Commented] (FLINK-36360) Prepare release process and Scripts for the preview release

[ https://issues.apache.org/jira/browse/FLINK-36360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887490#comment-17887490 ] Weijie Guo commented on FLINK-36360: apache/flink(master 2.0) via 2f6882796cd7971eb2

[jira] [Assigned] (FLINK-36261) Revisit all breaking changes before Flink 2.0 Preview

[ https://issues.apache.org/jira/browse/FLINK-36261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-36261: Assignee: Xuannan Su > Revisit all breaking changes before Flink 2.0 Preview > --

[jira] [Closed] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33747. Resolution: Done > Remove Sink V1 API in 2.0 > - > > Key:

[jira] [Assigned] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33747: Assignee: LvYanquan > Remove Sink V1 API in 2.0 > - > >

[jira] [Resolved] (FLINK-35411) Optimize buffer triggering of async state requests

[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35411. - Fix Version/s: 2.0-preview Resolution: Fixed > Optimize buffer triggering of async state

[jira] [Commented] (FLINK-33747) Remove Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887485#comment-17887485 ] LvYanquan commented on FLINK-33747: --- Removed together in the associated PR of this Jir

[jira] [Closed] (FLINK-14068) Use Java's Duration instead of Flink's Time

[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-14068. Resolution: Done > Use Java's Duration instead of Flink's Time > -

[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory

[ https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887479#comment-17887479 ] Zakelly Lan commented on FLINK-36421: - [~gaborgsomogyi] Thanks for the heads up~ [~

[jira] [Assigned] (FLINK-35393) Support flink kafka catalog

[ https://issues.apache.org/jira/browse/FLINK-35393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35393: -- Assignee: Hrushikesh Tilak > Support flink kafka catalog > --- > >

[jira] [Assigned] (FLINK-32766) Support kafka catalog

[ https://issues.apache.org/jira/browse/FLINK-32766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32766: -- Assignee: Hongshun Wang > Support kafka catalog > - > > K

[jira] [Commented] (FLINK-35751) Migrate SplitPythonConditionFromCorrelateRule

[ https://issues.apache.org/jira/browse/FLINK-35751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887464#comment-17887464 ] Jacky Lau commented on FLINK-35751: --- hi [~snuyanzin]  will you help review this? > Mi

[jira] (FLINK-35751) Migrate SplitPythonConditionFromCorrelateRule

[ https://issues.apache.org/jira/browse/FLINK-35751 ] Jacky Lau deleted comment on FLINK-35751: --- was (Author: jackylau): pr is here [https://github.com/apache/flink/pull/25014,] will you help review this [~snuyanzin] ? > Migrate SplitPythonCondi

[jira] [Closed] (FLINK-36332) Allow the Operator http client to be customised

[ https://issues.apache.org/jira/browse/FLINK-36332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36332. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Sam Barker Resolution: Fixed merge

[jira] [Closed] (FLINK-36392) Varying the Java version in the Operator CI has no effect

[ https://issues.apache.org/jira/browse/FLINK-36392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36392. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Sam Barker Resolution: Fixed merge

[jira] [Assigned] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36404: --- Assignee: Lorenzo Nicora > PrometheusSinkWriteException thrown by the response call

[jira] [Resolved] (FLINK-36427) Additional Integration Test cases for KDS source

[ https://issues.apache.org/jira/browse/FLINK-36427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36427. - Resolution: Fixed  merged commit [{{91381cd}}|https://github.com/apache/flink-connector

[jira] [Resolved] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36404. - Resolution: Fixed  merged commit [{{67da7df}}|https://github.com/apache/flink-connector

[jira] [Closed] (FLINK-35777) Observe session jobs during cleanup

[ https://issues.apache.org/jira/browse/FLINK-35777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35777. -- Resolution: Fixed fixed in https://issues.apache.org/jira/browse/FLINK-35414 > Observe session jobs d

[jira] [Assigned] (FLINK-35777) Observe session jobs during cleanup

[ https://issues.apache.org/jira/browse/FLINK-35777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35777: -- Assignee: Gyula Fora > Observe session jobs during cleanup >

[jira] [Commented] (FLINK-35777) Observe session jobs during cleanup

[ https://issues.apache.org/jira/browse/FLINK-35777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887344#comment-17887344 ] Gyula Fora commented on FLINK-35777: yes [~mateczagany] , thanks! > Observe session

[jira] [Assigned] (FLINK-36427) Additional Integration Test cases for KDS source

[ https://issues.apache.org/jira/browse/FLINK-36427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36427: --- Assignee: Elphas Toringepi > Additional Integration Test cases for KDS source > ---

[jira] [Created] (FLINK-36432) FLIP-438: Amazon SQS Source Connector

Saurabh created FLINK-36432: --- Summary: FLIP-438: Amazon SQS Source Connector Key: FLINK-36432 URL: https://issues.apache.org/jira/browse/FLINK-36432 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-35777) Observe session jobs during cleanup

[ https://issues.apache.org/jira/browse/FLINK-35777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887324#comment-17887324 ] Mate Czagany commented on FLINK-35777: -- I think this has been implemented in https

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887320#comment-17887320 ] Vineeth Naroju commented on FLINK-15571: Is this closed ?  > Create a Redis Str

[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory

[ https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887315#comment-17887315 ] Gabor Somogyi commented on FLINK-36421: --- As we're dealing with super huge states w

[jira] [Commented] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory

[ https://issues.apache.org/jira/browse/FLINK-36421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887306#comment-17887306 ] Marc Aurel Fritz commented on FLINK-36421: -- [~gaborgsomogyi] Are you using the

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36404: Fix Version/s: prometheus-connector-1.0.0 > PrometheusSinkWriteException thrown by the res

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36404: Affects Version/s: prometheus-connector-1.0.0 > PrometheusSinkWriteException thrown by the