[jira] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749 ] 牛一凡 deleted comment on FLINK-34749: - was (Author: JIRAUSER304780): I am willing to do this.Can it be assigned to me?:) > "legacy-flink-cdc-sources" Page of SQLServer for Flin

[jira] [Commented] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837582#comment-17837582 ] 牛一凡 commented on FLINK-34749: - Hi [~kunni]  ，I am a Chinese Speaker and glad to take

[jira] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34735 ] 牛一凡 deleted comment on FLINK-34735: - was (Author: JIRAUSER304780): I am willing to do this.Can it be assigned to me?:) > "Developer Guide - Understanding Flink CDC API" Page for Flin

[jira] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747 ] 牛一凡 deleted comment on FLINK-34747: - was (Author: JIRAUSER304780): I am willing to do this.Can it be assigned to me?:) > "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese

[jira] [Comment Edited] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837579#comment-17837579 ] 牛一凡 edited comment on FLINK-34752 at 4/16/24 8:09 AM: -- Hi [~k

[jira] [Closed] (FLINK-32315) Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-32315. -- Resolution: Fixed [{{b3fdb07}}|https://github.com/apache/flink/commit

[jira] [Updated] (FLINK-32315) Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-32315: --- Fix Version/s: 1.20.0 > Support local file upload in K8s m

[jira] [Created] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator

Márton Balassi created FLINK-35183: -- Summary: Expose FlinkMinorVersion as metric for applications in operator Key: FLINK-35183 URL: https://issues.apache.org/jira/browse/FLINK-35183 Project: Flink

[jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell

[ https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705584#comment-14705584 ] Márton Balassi commented on FLINK-2522: --- Great feature. How are you planning t

[jira] [Assigned] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2499: - Assignee: Márton Balassi > start-cluster.sh can start multiple TaskManager on the s

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716640#comment-14716640 ] Márton Balassi commented on FLINK-2499: --- [~airbots] correct me if I am wrong

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716659#comment-14716659 ] Márton Balassi commented on FLINK-2499: --- Good point, will act accordingly. >

[jira] [Updated] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2499: -- Affects Version/s: (was: 0.8.1) 0.10 > start-cluster.sh can st

[jira] [Updated] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2499: -- Component/s: Start-Stop Scripts > start-cluster.sh can start multiple TaskManager on the s

[jira] [Closed] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2499. - Resolution: Fixed Fix Version/s: 0.10 Via 91069d1f73. > start-cluster.sh can st

[jira] [Commented] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727561#comment-14727561 ] Márton Balassi commented on FLINK-2474: --- I have not actually seen this test fai

[jira] [Assigned] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

[ https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2283: - Assignee: Márton Balassi > Make grouped reduce/fold/aggregations stateful us

[jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

[ https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14742907#comment-14742907 ] Márton Balassi commented on FLINK-2283: --- This issue caused me some inconvenie

[jira] [Created] (FLINK-2717) CombineTaskTest sometimes fails

Márton Balassi created FLINK-2717: - Summary: CombineTaskTest sometimes fails Key: FLINK-2717 URL: https://issues.apache.org/jira/browse/FLINK-2717 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2718) LeaserChangeCleanupTest sometimes fails

Márton Balassi created FLINK-2718: - Summary: LeaserChangeCleanupTest sometimes fails Key: FLINK-2718 URL: https://issues.apache.org/jira/browse/FLINK-2718 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2474. - Resolution: Fixed Fix Version/s: 0.10 Has not been observed for a long time. > Occasio

[jira] [Created] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

Márton Balassi created FLINK-2812: - Summary: KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible Key: FLINK-2812 URL: https://issues.apache.org/jira/browse/FLINK-2812

[jira] [Assigned] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

[ https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2812: - Assignee: Márton Balassi > KeySelectorUtil.getSelectorForKeys

[jira] [Updated] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

[ https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2812: -- Component/s: Streaming > KeySelectorUtil.getSelectorForKeys

[jira] [Created] (FLINK-2817) FileMonitoring function throws NPE when location is empty

Márton Balassi created FLINK-2817: - Summary: FileMonitoring function throws NPE when location is empty Key: FLINK-2817 URL: https://issues.apache.org/jira/browse/FLINK-2817 Project: Flink

[jira] [Commented] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic

[ https://issues.apache.org/jira/browse/FLINK-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093842#comment-15093842 ] Péter Szabó commented on FLINK-1274: As I know, yes, it was. Anyway, this issu

[jira] [Resolved] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic

[ https://issues.apache.org/jira/browse/FLINK-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó resolved FLINK-1274. Resolution: Resolved No longer an issue, API changed. > Make Flink Streaming's FileSource

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15105829#comment-15105829 ] Márton Balassi commented on FLINK-3257: --- Hey Paris, how urgent is this feature

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15106006#comment-15106006 ] Márton Balassi commented on FLINK-3257: --- No problem. It is great that you

[jira] [Created] (FLINK-3307) RMQSourceTest failure

Márton Balassi created FLINK-3307: - Summary: RMQSourceTest failure Key: FLINK-3307 URL: https://issues.apache.org/jira/browse/FLINK-3307 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ

[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135732#comment-15135732 ] Márton Balassi commented on FLINK-3297: --- Hey [~mohitsethi], we used to ha

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15151223#comment-15151223 ] Josep Rubió commented on FLINK-1707: Hi Vasia, I've been working with t

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152097#comment-15152097 ] Josep Rubió commented on FLINK-1707: Vasia, IMHO it makes the idea of the m

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152387#comment-15152387 ] Josep Rubió commented on FLINK-1707: Ok! I'll start doing a high lev

[jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Rubió updated FLINK-1707: --- Description: This issue proposes adding the an implementation of the Affinity Propagation algorithm

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167061#comment-15167061 ] Josep Rubió commented on FLINK-1707: Sorry, I did the document in sharelatex b

[jira] [Created] (FLINK-3511) Flink library examples not runnable withput adding dependencies

Márton Balassi created FLINK-3511: - Summary: Flink library examples not runnable withput adding dependencies Key: FLINK-3511 URL: https://issues.apache.org/jira/browse/FLINK-3511 Project: Flink

[jira] [Commented] (FLINK-3511) Flink library examples not runnable withput adding dependencies

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167416#comment-15167416 ] Márton Balassi commented on FLINK-3511: --- I am against moving the examples

[jira] [Comment Edited] (FLINK-3511) Flink library examples not runnable withput adding dependencies

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167446#comment-15167446 ] Márton Balassi edited comment on FLINK-3511 at 2/25/16 5:0

[jira] [Commented] (FLINK-3511) Flink library examples not runnable withput adding dependencies

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15167446#comment-15167446 ] Márton Balassi commented on FLINK-3511: --- Somewhat sensible for me, but it

[jira] [Commented] (FLINK-3511) Flink library examples not runnable without adding dependencies

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168955#comment-15168955 ] Márton Balassi commented on FLINK-3511: --- Now I get it, after the explanation

[jira] [Resolved] (FLINK-3422) Scramble HashPartitioner hashes

[ https://issues.apache.org/jira/browse/FLINK-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-3422. --- Resolution: Fixed Fixed via 0ff286d and f0f93c2. > Scramble HashPartitioner has

[jira] [Created] (FLINK-3583) Configuration not visible in gui when job is running

Michał Fijołek created FLINK-3583: - Summary: Configuration not visible in gui when job is running Key: FLINK-3583 URL: https://issues.apache.org/jira/browse/FLINK-3583 Project: Flink Issue

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Attachment: no-configuration-when-job-running.png configuration-available-when

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is running

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is running

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is running

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Fix Version/s: (was: 1.0.1) > Configuration not visible in gui when job is runn

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15185045#comment-15185045 ] Josep Rubió commented on FLINK-1707: Hi Vasia, First sorry for my delay, I ha

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15187494#comment-15187494 ] Josep Rubió commented on FLINK-1707: Thanks Vasia! I'll try to start

[jira] [Created] (FLINK-3599) GSoC: Code Generation in Serializers

Márton Balassi created FLINK-3599: - Summary: GSoC: Code Generation in Serializers Key: FLINK-3599 URL: https://issues.apache.org/jira/browse/FLINK-3599 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3606) Expose Configuration from RichFunctions

Márton Balassi created FLINK-3606: - Summary: Expose Configuration from RichFunctions Key: FLINK-3606 URL: https://issues.apache.org/jira/browse/FLINK-3606 Project: Flink Issue Type

[jira] [Created] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

Márton Balassi created FLINK-3610: - Summary: Scala DataStream#addSink returns Java DataStreamSink Key: FLINK-3610 URL: https://issues.apache.org/jira/browse/FLINK-3610 Project: Flink Issue

[jira] [Assigned] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-3610: - Assignee: Márton Balassi > Scala DataStream#addSink returns Java DataStreamS

[jira] [Commented] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193959#comment-15193959 ] Márton Balassi commented on FLINK-3610: --- It is an inconsistency primarily. As

[jira] [Updated] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-3610: -- Priority: Major (was: Critical) > Scala DataStream#addSink returns Java DataStreamS

[jira] [Updated] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-3610: -- Fix Version/s: (was: 1.0.1) 2.0.0 > Scala DataStream#addSink retu

[jira] [Created] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

Zoltán Zvara created FLINK-3636: --- Summary: NoClassDefFoundError while running WindowJoin example Key: FLINK-3636 URL: https://issues.apache.org/jira/browse/FLINK-3636 Project: Flink Issue Type

[jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15202754#comment-15202754 ] Zoltán Zvara commented on FLINK-3624: - I'd introduce a versioning for the RE

[jira] [Updated] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zoltán Zvara updated FLINK-3636: Assignee: Márton Balassi > NoClassDefFoundError while running WindowJoin exam

[jira] [Created] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

Zoltán Zvara created FLINK-3624: --- Summary: Use camelCase naming of JSON attributes generated by the REST API instead of dash Key: FLINK-3624 URL: https://issues.apache.org/jira/browse/FLINK-3624

[jira] [Commented] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201365#comment-15201365 ] Márton Balassi commented on FLINK-3636: --- Fortunately it does not affect

[jira] [Resolved] (FLINK-3636) NoClassDefFoundError while running WindowJoin example

[ https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-3636. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed via f09d68a. > NoClassDefFoundEr

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223953#comment-15223953 ] Josep Rubió commented on FLINK-1707: Hi Vasia, I'm still working on it a

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224218#comment-15224218 ] Josep Rubió commented on FLINK-1707: Hi Vasia, Yes, I'm working with scatt

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245431#comment-15245431 ] Josep Rubió commented on FLINK-1707: Hi Vasia, How should we test the implementa

[jira] [Created] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

Sergio Ramírez created FLINK-3784: - Summary: Unexpected results using collect() in RichMapPartitionFunction Key: FLINK-3784 URL: https://issues.apache.org/jira/browse/FLINK-3784 Project: Flink

[jira] [Closed] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible

[ https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2812. - Resolution: Fixed Fix Version/s: 0.10 Fixed via e494c27

[jira] [Closed] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state

[ https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2283. - Resolution: Fixed Fix Version/s: 0.10 Implemented via 225704b, a76d963 and c414ea9

[jira] [Updated] (FLINK-2817) FileMonitoring function throws NPE when location is empty

[ https://issues.apache.org/jira/browse/FLINK-2817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2817: -- Assignee: Zoltán Zvara > FileMonitoring function throws NPE when location is em

[jira] [Closed] (FLINK-2817) FileMonitoring function throws NPE when location is empty

[ https://issues.apache.org/jira/browse/FLINK-2817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2817. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 5dfc897 > FileMonitoring function thr

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967987#comment-14967987 ] Márton Balassi commented on FLINK-2491: --- Unfortunately it is. I did not find

[jira] [Created] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar.

Jan Thomä created FLINK-2975: Summary: Exclude logging dependencies from shaded Hadoop jar. Key: FLINK-2975 URL: https://issues.apache.org/jira/browse/FLINK-2975 Project: Flink Issue Type

[jira] [Commented] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar.

[ https://issues.apache.org/jira/browse/FLINK-2975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14991556#comment-14991556 ] Jan Thomä commented on FLINK-2975: -- Thank you very much, seems to be indeed a dupli

[jira] [Assigned] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

[ https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-3090: - Assignee: Márton Balassi > Create a Parcel Distribution for Cloudera Mana

[jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

[ https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264085#comment-15264085 ] Márton Balassi commented on FLINK-3090: --- Thanks, [~cos]. Fortunately [~mxm]

[jira] [Assigned] (FLINK-3190) Retry rate limits for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek reassigned FLINK-3190: - Assignee: Michał Fijołek > Retry rate limits for DataStream

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266863#comment-15266863 ] Josep Rubió commented on FLINK-1707: Hi Vasia, I could not work on it last wee

[jira] [Closed] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

[ https://issues.apache.org/jira/browse/FLINK-3784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Ramírez closed FLINK-3784. - Resolution: Not A Problem > Unexpected results using collect() in RichMapPartitionFunct

[jira] [Commented] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

[ https://issues.apache.org/jira/browse/FLINK-3784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268656#comment-15268656 ] Sergio Ramírez commented on FLINK-3784: --- Yes, it is solved. Thanks for the sup

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15306051#comment-15306051 ] Josep Rubió commented on FLINK-1707: Hey Vasia, https://github.com/joseprupi/f

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340447#comment-15340447 ] Anıl Chalil commented on FLINK-4094: https://github.com/capacman/flinkoffheap

[jira] [Created] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

Márton Balassi created FLINK-1740: - Summary: StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() Key: FLINK-1740 URL: https://issues.apache.org/jira/browse/FLINK-1740

[jira] [Assigned] (FLINK-1701) Serialization problems with TestStreamEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1701: -- Assignee: Péter Szabó > Serialization problems with TestStreamEnvironm

[jira] [Closed] (FLINK-1701) Serialization problems with TestStreamEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó closed FLINK-1701. -- Resolution: Fixed Anonymous inner classes are serializable only if the enclosing class is serilizable

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367905#comment-14367905 ] Márton Balassi commented on FLINK-1740: --- That is actually a good question whe

[jira] [Created] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

Péter Szabó created FLINK-1757: -- Summary: java.lang.ClassCastException is thrown while summing Short values on window Key: FLINK-1757 URL: https://issues.apache.org/jira/browse/FLINK-1757 Project: Flink

[jira] [Assigned] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

[ https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1756: - Assignee: Márton Balassi > Rename Stream Monitoring to Stream Checkpoint

[jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

[ https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371389#comment-14371389 ] Márton Balassi commented on FLINK-1756: --- +1 for the suggestion. > Rename

[jira] [Created] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult

Márton Balassi created FLINK-1767: - Summary: StreamExecutionEnvironment's execute should return JobExecutionResult Key: FLINK-1767 URL: https://issues.apache.org/jira/browse/FLINK-1767 Project:

[jira] [Closed] (FLINK-1763) Remove "cancel" from streaming SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1763. - Resolution: Implemented Implemented via 35f3416 > Remove "cancel" from streaming

[jira] [Resolved] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

[ https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1756. --- Resolution: Implemented Implemented via 2842e2f > Rename Stream Monitoring to Str

[jira] [Resolved] (FLINK-1688) Add socket sink

[ https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1688. --- Resolution: Implemented Fix Version/s: 0.9 Client version implemented via a3bc785 and

[jira] [Created] (FLINK-1772) Chain of split/select does not work

Gábor Hermann created FLINK-1772: Summary: Chain of split/select does not work Key: FLINK-1772 URL: https://issues.apache.org/jira/browse/FLINK-1772 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult

[ https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1767. --- Resolution: Implemented Fix Version/s: 0.9 Thanks, Gabor. Implemented via e83d1ec

[jira] [Resolved] (FLINK-1544) Extend streaming aggregation tests to include POJOs

[ https://issues.apache.org/jira/browse/FLINK-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1544. --- Resolution: Implemented Fix Version/s: 0.9 Implemented via 597d8b8 > Extend stream

[jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14383878#comment-14383878 ] Márton Balassi commented on FLINK-1793: --- Just cancelled a streaming

[jira] [Created] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied

Péter Szabó created FLINK-1798: -- Summary: Bug in IterateExample while running with parallelism > 1: broker slot is already occupied Key: FLINK-1798 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Updated] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied

[ https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó updated FLINK-1798: --- Component/s: Streaming > Bug in IterateExample while running with parallelism > 1: broker s

[jira] [Commented] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied

[ https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386448#comment-14386448 ] Péter Szabó commented on FLINK-1798: Cool, thanks! Peter > Bug in Iterate

<    1   2   3   4   5   6   7   8   9   10   >