[jira] [Closed] (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ó closed FLINK-1798. -- Resolution: Done > Bug in IterateExample while running with parallelism > 1: broker slot is >

[jira] [Commented] (FLINK-1239) Fix iteration example getting stuck with large input

[ https://issues.apache.org/jira/browse/FLINK-1239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14390564#comment-14390564 ] Gábor Hermann commented on FLINK-1239: -- The IterationExample runs and termin

[jira] [Closed] (FLINK-1826) Remove the code never be executed in function getNumPages

[ https://issues.apache.org/jira/browse/FLINK-1826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1826. - Resolution: Not a Problem > Remove the code never be executed in function getNumPa

[jira] [Closed] (FLINK-1824) Allow missing types for DataStreams

[ https://issues.apache.org/jira/browse/FLINK-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1824. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 1cf49e9 > Allow missing ty

[jira] [Closed] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

[ https://issues.apache.org/jira/browse/FLINK-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1808. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 1da4b64 > Omit send

[jira] [Closed] (FLINK-1825) Fix the constructor comments with correct parameter in DefaultMemoryManager

[ https://issues.apache.org/jira/browse/FLINK-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1825. - Resolution: Fixed Fix Version/s: (was: master) 0.9 Fixed via

[jira] [Created] (FLINK-1831) runtime.taskmanager.RegistrationTests fails sporiously

Márton Balassi created FLINK-1831: - Summary: runtime.taskmanager.RegistrationTests fails sporiously Key: FLINK-1831 URL: https://issues.apache.org/jira/browse/FLINK-1831 Project: Flink Issue

[jira] [Updated] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1831: -- Summary: runtime.taskmanager.RegistrationTests fails spuriously (was

[jira] [Created] (FLINK-1837) Throw an exceptions for iterative streaming programs with checkpointing enabled

Márton Balassi created FLINK-1837: - Summary: Throw an exceptions for iterative streaming programs with checkpointing enabled Key: FLINK-1837 URL: https://issues.apache.org/jira/browse/FLINK-1837

[jira] [Closed] (FLINK-1560) Add ITCases for streaming examples

[ https://issues.apache.org/jira/browse/FLINK-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1560. - Resolution: Implemented Fix Version/s: 0.9 Implemented via ed7d165, 464e782 and 954beca

[jira] [Closed] (FLINK-1837) Throw an exceptions for iterative streaming programs with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1837. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 52ebb29 > Throw an excepti

[jira] [Assigned] (FLINK-1839) Failures in TwitterStreamITCase

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

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14483537#comment-14483537 ] Márton Balassi commented on FLINK-1839: --- My bad, I thought I have fixed it alr

[jira] [Assigned] (FLINK-1841) WindowJoinITCase fails

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

[jira] [Closed] (FLINK-1839) Failures in TwitterStreamITCase

[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1839. - Resolution: Fixed Fix Version/s: 0.9 Fixd via 5dd42c1 > Failures in TwitterStreamITC

[jira] [Closed] (FLINK-1841) WindowJoinITCase fails

[ https://issues.apache.org/jira/browse/FLINK-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1841. - Resolution: Fixed Fix Version/s: 0.9 Fixed via b566884 > WindowJoinITCase fa

[jira] [Assigned] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1793: - Assignee: Márton Balassi > Streaming File Source cannot be cance

[jira] [Commented] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485355#comment-14485355 ] Márton Balassi commented on FLINK-1793: --- Ok, let me look into it. > Streami

[jira] [Created] (FLINK-1849) Refactor StreamingRuntimeContext

Márton Balassi created FLINK-1849: - Summary: Refactor StreamingRuntimeContext Key: FLINK-1849 URL: https://issues.apache.org/jira/browse/FLINK-1849 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1449#comment-1449 ] Márton Balassi commented on FLINK-1865: --- It looks like it is the same i

[jira] [Assigned] (FLINK-1865) Unstable test KafkaITCase

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

[jira] [Closed] (FLINK-1660) MultiTriggerPolicyTest timeout during test

[ https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1660. - Resolution: Fixed Assignee: Ufuk Celebi Fixed via e5a3b95 > MultiTriggerPolicyT

[jira] [Closed] (FLINK-1866) In StreamConfig IN_STREAM_EDGES and OUT_STREAM_EDGES have same config key

[ https://issues.apache.org/jira/browse/FLINK-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1866. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 54d5662 > In StreamConfig IN_STREAM_ED

[jira] [Created] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN

Zoltán Zvara created FLINK-1902: --- Summary: Web interface reports false (the default) jobmanager.rpc.port on YARN Key: FLINK-1902 URL: https://issues.apache.org/jira/browse/FLINK-1902 Project: Flink

[jira] [Closed] (FLINK-1887) Fix the message in runtime exception

[ https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1887. - Resolution: Fixed Fix Version/s: 0.9 Fixed via f7ec859. > Fix the message in runt

[jira] [Assigned] (FLINK-1911) DataStream and DataSet projection is out of sync

[ https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1911: -- Assignee: Péter Szabó > DataStream and DataSet projection is out of s

[jira] [Created] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

Zoltán Zvara created FLINK-1914: --- Summary: Wrong FS while starting YARN session without correct HADOOP_HOME Key: FLINK-1914 URL: https://issues.apache.org/jira/browse/FLINK-1914 Project: Flink

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502932#comment-14502932 ] Zoltán Zvara commented on FLINK-1914: - There is a warn! Thanks! > Wrong F

[jira] [Created] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

https://issues.apache.org/jira/browse/FLINK-1918 Project: Flink Issue Type: Bug Components: YARN Client Reporter: Zoltán Zvara Trace: {code} Exception in thread "main" java.lang.NullPointerException at org.apache.flink.client.program.Client.(

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14507361#comment-14507361 ] Márton Balassi commented on FLINK-1865: --- Go ahead. > Unstable test Kafk

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14507359#comment-14507359 ] Márton Balassi commented on FLINK-1865: --- Go ahead. > Unstable test Kafk

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14507360#comment-14507360 ] Márton Balassi commented on FLINK-1865: --- Go ahead. > Unstable test Kafk

[jira] [Issue Comment Deleted] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1865: -- Comment: was deleted (was: Go ahead.) > Unstable test KafkaITC

[jira] [Issue Comment Deleted] (FLINK-1865) Unstable test KafkaITCase

[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1865: -- Comment: was deleted (was: Go ahead.) > Unstable test KafkaITC

[jira] [Commented] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512380#comment-14512380 ] Zoltán Zvara commented on FLINK-1918: - Thanks, it really was a failed lo

[jira] [Assigned] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1956: - Assignee: Márton Balassi (was: Marton Balassi) > Runtime context not initialized

[jira] [Closed] (FLINK-1948) Add manual task slot handling for streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-1948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1948. - Resolution: Implemented Fix Version/s: 0.9 Implemented via ca82b0c > Add manual task s

[jira] [Closed] (FLINK-1911) DataStream and DataSet projection is out of sync

[ https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1911. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 8c46155 and 40be172. > DataStream

[jira] [Updated] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path

[ https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1964: -- Labels: starter (was: ) > Rework TwitterSource to use a Properties object instead of a f

[jira] [Commented] (FLINK-1284) Uniform random sampling operator over windows

[ https://issues.apache.org/jira/browse/FLINK-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14525890#comment-14525890 ] Tamás Krutki commented on FLINK-1284: - Hi, I'd like to try this, can y

[jira] [Issue Comment Deleted] (FLINK-1284) Uniform random sampling operator over windows

[ https://issues.apache.org/jira/browse/FLINK-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamás Krutki updated FLINK-1284: Comment: was deleted (was: Hi, I'd like to try this, can you please assign it to me?) >

[jira] [Closed] (FLINK-1855) SocketTextStreamWordCount example cannot be run from the webclient

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

[jira] [Closed] (FLINK-1670) Collect method for streaming

[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1670. - Resolution: Implemented Fix Version/s: 0.9 Implemented via c9c9450 > Collect method

[jira] [Commented] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14526737#comment-14526737 ] Tamás Krutki commented on FLINK-1673: - Hi, I'm new to Flink, I'

[jira] [Assigned] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1673: - Assignee: Márton Balassi > Colocate Flink Kafka consu

[jira] [Updated] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1673: -- Assignee: Tamás Krutki (was: Márton Balassi) > Colocate Flink Kafka consu

[jira] [Commented] (FLINK-1673) Colocate Flink Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14528090#comment-14528090 ] Márton Balassi commented on FLINK-1673: --- Hi, Thanks for getting started with F

[jira] [Closed] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction

[ https://issues.apache.org/jira/browse/FLINK-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1956. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 912edbc > Runtime context not initiali

[jira] [Created] (FLINK-1979) Implement Loss Functions

Johannes Günther created FLINK-1979: --- Summary: Implement Loss Functions Key: FLINK-1979 URL: https://issues.apache.org/jira/browse/FLINK-1979 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14530425#comment-14530425 ] Johannes Günther commented on FLINK-1979: - We are two Students part of the

[jira] [Comment Edited] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14530484#comment-14530484 ] Johannes Günther edited comment on FLINK-1979 at 5/6/15 1:0

[jira] [Commented] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14530484#comment-14530484 ] Johannes Günther commented on FLINK-1979: - Yes that would be great ! > Im

[jira] [Commented] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14532380#comment-14532380 ] Johannes Günther commented on FLINK-1979: - We added Logistics loss and Hinge

[jira] [Commented] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14532401#comment-14532401 ] Johannes Günther commented on FLINK-1979: - Okay I changed the Pull request to

[jira] [Commented] (FLINK-1979) Implement Loss Functions

[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14536365#comment-14536365 ] Johannes Günther commented on FLINK-1979: - Okay I will adjust the code so tha

[jira] [Created] (FLINK-1999) TF-IDF transformer

Ronny Bräunlich created FLINK-1999: -- Summary: TF-IDF transformer Key: FLINK-1999 URL: https://issues.apache.org/jira/browse/FLINK-1999 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-1999) TF-IDF transformer

[ https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14537822#comment-14537822 ] Ronny Bräunlich commented on FLINK-1999: Are you sure that the input type sh

[jira] [Created] (FLINK-2002) Iterative test fails when ran with other tests in the same environment

Péter Szabó created FLINK-2002: -- Summary: Iterative test fails when ran with other tests in the same environment Key: FLINK-2002 URL: https://issues.apache.org/jira/browse/FLINK-2002 Project: Flink

[jira] [Commented] (FLINK-1986) Group by fails on iterative data streams

[ https://issues.apache.org/jira/browse/FLINK-1986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539589#comment-14539589 ] Péter Szabó commented on FLINK-1986: The problem is that the the StreamIteration

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539887#comment-14539887 ] Márton Balassi commented on FLINK-1764: --- One lingering symptom of this issu

[jira] [Created] (FLINK-2007) Initial data point in Delta function needs to be serializable

Márton Balassi created FLINK-2007: - Summary: Initial data point in Delta function needs to be serializable Key: FLINK-2007 URL: https://issues.apache.org/jira/browse/FLINK-2007 Project: Flink

[jira] [Commented] (FLINK-2007) Initial data point in Delta function needs to be serializable

[ https://issues.apache.org/jira/browse/FLINK-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541668#comment-14541668 ] Márton Balassi commented on FLINK-2007: --- I have a working prototype, the API n

[jira] [Closed] (FLINK-1595) Add a complex integration test for Streaming API

[ https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1595. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 4786b56 and 48e21a1. > Ad

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547103#comment-14547103 ] Márton Balassi commented on FLINK-1985: --- Thanks Matthias, I have tested it, l

[jira] [Created] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

Márton Balassi created FLINK-2036: - Summary: StreamExecutionEnvironment usage in KafkaITcase Key: FLINK-2036 URL: https://issues.apache.org/jira/browse/FLINK-2036 Project: Flink Issue Type

[jira] [Commented] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase

[ https://issues.apache.org/jira/browse/FLINK-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550076#comment-14550076 ] Márton Balassi commented on FLINK-2036: --- You can submit multiple diffe

[jira] [Created] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

Márton Balassi created FLINK-2051: - Summary: Fix disabled test in ComplexIntegrationTest Key: FLINK-2051 URL: https://issues.apache.org/jira/browse/FLINK-2051 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

[ https://issues.apache.org/jira/browse/FLINK-2051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2051: -- Assignee: Péter Szabó > Fix disabled test in ComplexIntegrationT

[jira] [Updated] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

[ https://issues.apache.org/jira/browse/FLINK-2051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2051: -- Assignee: Péter Szabó (was: Márton Balassi) > Fix disabled test in ComplexIntegrationT

[jira] [Assigned] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1874: - Assignee: Márton Balassi > Break up streaming connectors into submodu

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14557243#comment-14557243 ] Márton Balassi commented on FLINK-1874: --- Sorry, [~lokeshrajaram] - I did not c

[jira] [Closed] (FLINK-2007) Initial data point in Delta function needs to be serializable

[ https://issues.apache.org/jira/browse/FLINK-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2007. - Resolution: Fixed Fixed via 7e4c562 > Initial data point in Delta function needs to

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562442#comment-14562442 ] Márton Balassi commented on FLINK-2088: --- Thanks for the report, fixin

[jira] [Assigned] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2088: - Assignee: Márton Balassi > change return type of name function in DataStream scala cl

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562448#comment-14562448 ] Márton Balassi commented on FLINK-2088: --- We could do it, but currently strea

[jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562464#comment-14562464 ] Márton Balassi commented on FLINK-1430: --- Hey, [~qmlmoon] are you working on

[jira] [Resolved] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-2088. --- Resolution: Fixed Fixed via 31efaa1 > change return type of name function in DataStr

[jira] [Resolved] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1874. --- Resolution: Fixed Fix Version/s: 0.9 Fixed via 665bcec and a302817. > Break

[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API

[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563759#comment-14563759 ] Márton Balassi commented on FLINK-2103: --- Why is this needed, why wouldn't

[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API

[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564372#comment-14564372 ] Márton Balassi commented on FLINK-2103: --- I see that the batch API also has it

[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API

[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564379#comment-14564379 ] Márton Balassi commented on FLINK-2103: --- One slight difference is that

[jira] [Closed] (FLINK-2112) Wrong package statement in KafkaITCase and KafkaLocalSystemTime

[ https://issues.apache.org/jira/browse/FLINK-2112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2112. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 0fd6023. > Wrong package statement

[jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

[ https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564843#comment-14564843 ] Márton Balassi commented on FLINK-1687: --- Implemented via 1c3b67e and 120

[jira] [Issue Comment Deleted] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

[ https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1687: -- Comment: was deleted (was: Implemented via 1c3b67e and 120bd0f.) > Streaming file source/s

[jira] [Closed] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API

[ https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1687. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 1c3b67e and 120bd0f

[jira] [Created] (FLINK-2125) String delimiter for SocketTextStream

Márton Balassi created FLINK-2125: - Summary: String delimiter for SocketTextStream Key: FLINK-2125 URL: https://issues.apache.org/jira/browse/FLINK-2125 Project: Flink Issue Type

[jira] [Assigned] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1430: - Assignee: Márton Balassi (was: Mingliang Qi) > Add test for streaming scala

[jira] [Closed] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1430. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 50c818d > Add test

[jira] [Commented] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14569096#comment-14569096 ] Márton Balassi commented on FLINK-2130: --- This was a conscious design choice, s

[jira] [Created] (FLINK-2136) Test the streaming scala API

Márton Balassi created FLINK-2136: - Summary: Test the streaming scala API Key: FLINK-2136 URL: https://issues.apache.org/jira/browse/FLINK-2136 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-2137) Expose partitionByHash for WindowedDataStream

Márton Balassi created FLINK-2137: - Summary: Expose partitionByHash for WindowedDataStream Key: FLINK-2137 URL: https://issues.apache.org/jira/browse/FLINK-2137 Project: Flink Issue Type

[jira] [Created] (FLINK-2138) PartitionCustom for streaming

Márton Balassi created FLINK-2138: - Summary: PartitionCustom for streaming Key: FLINK-2138 URL: https://issues.apache.org/jira/browse/FLINK-2138 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2139) Test Streaming Outputformats

Márton Balassi created FLINK-2139: - Summary: Test Streaming Outputformats Key: FLINK-2139 URL: https://issues.apache.org/jira/browse/FLINK-2139 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14570515#comment-14570515 ] Márton Balassi commented on FLINK-2130: --- Fair enough. > RabbitMQ source d

[jira] [Assigned] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2130: - Assignee: Márton Balassi > RabbitMQ source does not fail when failing to retri

[jira] [Commented] (FLINK-2137) Expose partitionByHash for WindowedDataStream

[ https://issues.apache.org/jira/browse/FLINK-2137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14570528#comment-14570528 ] Márton Balassi commented on FLINK-2137: --- I am personally fine with not havin

[jira] [Assigned] (FLINK-2136) Test the streaming scala API

[ https://issues.apache.org/jira/browse/FLINK-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-2136: Assignee: Gábor Hermann > Test the streaming scala

[jira] [Closed] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2130. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 39ec54f > RabbitMQ source does not f

[jira] [Closed] (FLINK-2103) Expose partitionBy to the user in Stream API

[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2103. - Resolution: Implemented Fix Version/s: 0.9 Implemented via a43e0de and 6b28bdf. > Exp

[jira] [Commented] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows

[ https://issues.apache.org/jira/browse/FLINK-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14570785#comment-14570785 ] Márton Balassi commented on FLINK-2142: --- Thanks, for adding the tickets to t

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