[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=14699303#comment-14699303 ] Márton Balassi commented on FLINK-2491: --- Yes, it fixes it - that is why I rem

[jira] [Issue Comment Deleted] (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:all-tabpanel ] Márton Balassi updated FLINK-2491: -- Comment: was deleted (was: Yes, it fixes it - that is why I removed my previous comment that

[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=14699336#comment-14699336 ] Márton Balassi commented on FLINK-2491: --- That should be good enough. I was tes

[jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701196#comment-14701196 ] Márton Balassi commented on FLINK-2508: --- Thanks for both resports, Aljoscha.

[jira] [Closed] (FLINK-2532) The function name and the variable name are same, it is confusing

[ https://issues.apache.org/jira/browse/FLINK-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2532. - Resolution: Fixed Fix Version/s: 0.10 Via a9d55d3 > The function name and the varia

[jira] [Closed] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window

[ https://issues.apache.org/jira/browse/FLINK-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2286. - Resolution: Fixed Fix Version/s: 0.10 Via 143ec4f & 67087de. > Window Parall

[jira] [Resolved] (FLINK-1358) Add streaming to the quickstarts

[ https://issues.apache.org/jira/browse/FLINK-1358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1358. --- Resolution: Implemented Implemented via https://git-wip-us.apache.org/repos/asf?p=flink.git

[jira] [Resolved] (FLINK-1338) Remove incubating disclaimers and update version name

[ https://issues.apache.org/jira/browse/FLINK-1338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1338. --- Resolution: Fixed Implemented. > Remove incubating disclaimers and update version n

[jira] [Commented] (FLINK-1403) Streaming api doesn't support output file named with "file://" prefix

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

[jira] [Commented] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14281987#comment-14281987 ] Márton Balassi commented on FLINK-1414: --- When removing the scripts put some inf

[jira] [Assigned] (FLINK-1403) Streaming api doesn't support output file named with "file://" prefix

[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1403: - Assignee: Márton Balassi > Streaming api doesn't support output file named wi

[jira] [Created] (FLINK-1429) Add documentation for streaming scala api

Márton Balassi created FLINK-1429: - Summary: Add documentation for streaming scala api Key: FLINK-1429 URL: https://issues.apache.org/jira/browse/FLINK-1429 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1403) Streaming api doesn't support output file named with "file://" prefix

[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285987#comment-14285987 ] Márton Balassi commented on FLINK-1403: --- Implemented via dc0d81b. > Stream

[jira] [Resolved] (FLINK-1345) Add operator chaining to the streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1345. --- Resolution: Implemented Implemented via 26535c4...7dbb55e. > Add operator chaining to

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

Márton Balassi created FLINK-1430: - Summary: Add test for streaming scala api completeness Key: FLINK-1430 URL: https://issues.apache.org/jira/browse/FLINK-1430 Project: Flink Issue Type

[jira] [Resolved] (FLINK-1403) Streaming api doesn't support output file named with "file://" prefix

[ https://issues.apache.org/jira/browse/FLINK-1403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1403. --- Resolution: Implemented > Streaming api doesn't support output file named wi

[jira] [Closed] (FLINK-1449) Extend Streaming guide to include the Scala API

[ https://issues.apache.org/jira/browse/FLINK-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1449. - Resolution: Duplicate This is a duplicate of FlINK-1429. > Extend Streaming guide to include

[jira] [Created] (FLINK-1451) Enable parallel execution of streaming file sources

Márton Balassi created FLINK-1451: - Summary: Enable parallel execution of streaming file sources Key: FLINK-1451 URL: https://issues.apache.org/jira/browse/FLINK-1451 Project: Flink Issue

[jira] [Updated] (FLINK-1451) Enable parallel execution of streaming file sources

[ https://issues.apache.org/jira/browse/FLINK-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1451: -- Description: Currently the streaming FileSourceFunction does not support parallelism greater

[jira] [Created] (FLINK-1456) Projection to fieldnames, keyselectors

Márton Balassi created FLINK-1456: - Summary: Projection to fieldnames, keyselectors Key: FLINK-1456 URL: https://issues.apache.org/jira/browse/FLINK-1456 Project: Flink Issue Type: New

[jira] [Created] (FLINK-1493) Support for streaming jobs preserving global ordering of records

Márton Balassi created FLINK-1493: - Summary: Support for streaming jobs preserving global ordering of records Key: FLINK-1493 URL: https://issues.apache.org/jira/browse/FLINK-1493 Project: Flink

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311962#comment-14311962 ] Márton Balassi commented on FLINK-1493: --- Hey Matthias, Thanks for looking

[jira] [Created] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming

Márton Balassi created FLINK-1534: - Summary: GSoC project: Distributed pattern matching over Flink streaming Key: FLINK-1534 URL: https://issues.apache.org/jira/browse/FLINK-1534 Project: Flink

[jira] [Updated] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming

[ https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1534: -- Description: Pattern matching over streams is an important application. The general structure

[jira] [Closed] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible

[ https://issues.apache.org/jira/browse/FLINK-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1517. - Resolution: Fixed Implemented via cba7866 > Modify inputiterator for streaming so the chan

[jira] [Created] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

Márton Balassi created FLINK-1539: - Summary: Runtime context not initialized when running streaming PojoExample Key: FLINK-1539 URL: https://issues.apache.org/jira/browse/FLINK-1539 Project: Flink

[jira] [Created] (FLINK-1553) Kafka connectors rework

Gábor Hermann created FLINK-1553: Summary: Kafka connectors rework Key: FLINK-1553 URL: https://issues.apache.org/jira/browse/FLINK-1553 Project: Flink Issue Type: Bug Components

[jira] [Closed] (FLINK-1231) Add test for streaming remote execution

[ https://issues.apache.org/jira/browse/FLINK-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1231. - Resolution: Fixed Implemented via 26ae979 > Add test for streaming remote execut

[jira] [Closed] (FLINK-1176) Add operator for global reduce/aggregations

[ https://issues.apache.org/jira/browse/FLINK-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1176. - Resolution: Implemented Implemented via 1146f64 and c560d76. > Add operator for global red

[jira] [Closed] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

[ https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1539. - Resolution: Fixed Fixed via 4470207 > Runtime context not initialized when running stream

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

Márton Balassi created FLINK-1560: - Summary: Add ITCases for streaming examples Key: FLINK-1560 URL: https://issues.apache.org/jira/browse/FLINK-1560 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-1566) WindowIntegrationTest fails

[ https://issues.apache.org/jira/browse/FLINK-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14324135#comment-14324135 ] Márton Balassi commented on FLINK-1566: --- Most of the time the test pa

[jira] [Issue Comment Deleted] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1421: -- Comment: was deleted (was: When your program is distributed one of the workers does not have

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325808#comment-14325808 ] Márton Balassi commented on FLINK-1421: --- When your program is distributed on

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325807#comment-14325807 ] Márton Balassi commented on FLINK-1421: --- When your program is distributed on

[jira] [Updated] (FLINK-1582) SocketStream gets stuck when socket closes

[ https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1582: -- Labels: starter (was: ) > SocketStream gets stuck when socket clo

[jira] [Created] (FLINK-1582) SocketStream gets stuck when socket closes

Márton Balassi created FLINK-1582: - Summary: SocketStream gets stuck when socket closes Key: FLINK-1582 URL: https://issues.apache.org/jira/browse/FLINK-1582 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1553) Kafka connectors rework

[ https://issues.apache.org/jira/browse/FLINK-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann updated FLINK-1553: - Description: The Kafka connectors should be reworked and tested because it is not fully

[jira] [Assigned] (FLINK-1594) DataStreams don't support self-join

[ https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-1594: Assignee: Gábor Hermann > DataStreams don't support s

[jira] [Resolved] (FLINK-1582) SocketStream gets stuck when socket closes

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

[jira] [Created] (FLINK-1638) SimpleKafkaSource connector

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

[jira] [Assigned] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release

[ https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1639: - Assignee: Márton Balassi > Document the Flink deployment scripts to make sure oth

[jira] [Commented] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release

[ https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345634#comment-14345634 ] Márton Balassi commented on FLINK-1639: --- I do agree that a documentation is ne

[jira] [Created] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming

Márton Balassi created FLINK-1645: - Summary: Move StreamingClassloaderITCase to flink-streaming Key: FLINK-1645 URL: https://issues.apache.org/jira/browse/FLINK-1645 Project: Flink Issue

[jira] [Resolved] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation

[ https://issues.apache.org/jira/browse/FLINK-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1625. --- Resolution: Implemented Implemented via 3abd6c8, 8436e9c and 08ef02e. > Add cancel method

[jira] [Assigned] (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 ] Péter Szabó reassigned FLINK-1595: -- Assignee: Péter Szabó > Add a complex integration test for Streaming

[jira] [Assigned] (FLINK-1429) Add documentation for streaming scala api

[ https://issues.apache.org/jira/browse/FLINK-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1429: - Assignee: Márton Balassi > Add documentation for streaming scala

[jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming

[ https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14351975#comment-14351975 ] Márton Balassi commented on FLINK-1534: --- Dear Askhay, Thanks for your interes

[jira] [Resolved] (FLINK-1429) Add documentation for streaming scala api

[ https://issues.apache.org/jira/browse/FLINK-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1429. --- Resolution: Implemented Done via 8c9ab85e and 7582390. > Add documentation for stream

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

[ https://issues.apache.org/jira/browse/FLINK-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1560: -- Assignee: Péter Szabó (was: Márton Balassi) > Add ITCases for streaming examp

[jira] [Updated] (FLINK-1641) Make projection operator chainable

[ https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1641: -- Assignee: Gabor Gevay > Make projection operator chaina

[jira] [Created] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy

Péter Szabó created FLINK-1662: -- Summary: NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy Key: FLINK-1662 URL: https://issues.apache.org/jira/browse/FLINK-1662

[jira] [Created] (FLINK-1669) Streaming tests for recovery with distributed process failure

Márton Balassi created FLINK-1669: - Summary: Streaming tests for recovery with distributed process failure Key: FLINK-1669 URL: https://issues.apache.org/jira/browse/FLINK-1669 Project: Flink

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

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

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

Márton Balassi created FLINK-1673: - Summary: Colocate Flink Kafka consumer Key: FLINK-1673 URL: https://issues.apache.org/jira/browse/FLINK-1673 Project: Flink Issue Type: Improvement

[jira] [Assigned] (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 ] Péter Szabó reassigned FLINK-1544: -- Assignee: Péter Szabó > Extend streaming aggregation tests to include PO

[jira] [Created] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on

Gábor Hermann created FLINK-1684: Summary: Make Kafka connectors read/write a partition the worker is on Key: FLINK-1684 URL: https://issues.apache.org/jira/browse/FLINK-1684 Project: Flink

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

Gábor Hermann created FLINK-1687: Summary: Streaming file source API is not in sync with the batch API Key: FLINK-1687 URL: https://issues.apache.org/jira/browse/FLINK-1687 Project: Flink

[jira] [Closed] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on

[ https://issues.apache.org/jira/browse/FLINK-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1684. - Resolution: Duplicate > Make Kafka connectors read/write a partition the worker is

[jira] [Commented] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on

[ https://issues.apache.org/jira/browse/FLINK-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356961#comment-14356961 ] Márton Balassi commented on FLINK-1684: --- This is a duplicate of FLINK-1673. &g

[jira] [Created] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat

Márton Balassi created FLINK-1689: - Summary: Add documentation on streaming file sinks interaction with the batch outputformat Key: FLINK-1689 URL: https://issues.apache.org/jira/browse/FLINK-1689

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

Márton Balassi created FLINK-1688: - Summary: Add socket sink Key: FLINK-1688 URL: https://issues.apache.org/jira/browse/FLINK-1688 Project: Flink Issue Type: Sub-task Components

[jira] [Updated] (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 updated FLINK-1688: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-1687) > Add soc

[jira] [Updated] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat

[ https://issues.apache.org/jira/browse/FLINK-1689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-1689: -- Description: OutputFormats supported by the batch API are supported in streaming through the

[jira] [Updated] (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 ] Gábor Hermann updated FLINK-1687: - Description: Streaming environment is missing file inputs like readFile, readCsvFile and also the

[jira] [Created] (FLINK-1699) Co-task sometimes returns null

Gábor Hermann created FLINK-1699: Summary: Co-task sometimes returns null Key: FLINK-1699 URL: https://issues.apache.org/jira/browse/FLINK-1699 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann updated FLINK-1699: - Description: Connecting two grouped data stream coMapping them and sinking it in a custom sink

[jira] [Updated] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann updated FLINK-1699: - Description: Connecting two grouped data stream coMapping them and sinking it in a custom sink

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

Péter Szabó created FLINK-1701: -- Summary: Serialization problems with TestStreamEnvironment Key: FLINK-1701 URL: https://issues.apache.org/jira/browse/FLINK-1701 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-1699: Assignee: Gábor Hermann > Co-task sometimes returns n

[jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming

[ https://issues.apache.org/jira/browse/FLINK-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14363009#comment-14363009 ] Márton Balassi commented on FLINK-1534: --- Hey, FilterFunctions unfortuna

[jira] [Commented] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14363049#comment-14363049 ] Gábor Hermann commented on FLINK-1699: -- This was probably caused by using static

[jira] [Assigned] (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 ] Péter Szabó reassigned FLINK-1687: -- Assignee: Péter Szabó > Streaming file source/sink API is not in sync with the batch

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

[ https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14364833#comment-14364833 ] Péter Szabó commented on FLINK-1701: It solved the problem, thank you very

[jira] [Closed] (FLINK-1340) Project restructure

[ https://issues.apache.org/jira/browse/FLINK-1340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1340. - Resolution: Duplicate FLINK-1712 is an updated version of this issue. > Project restruct

[jira] [Updated] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35909: -- Attachment: screenshot-1.png > JdbcFilterPushdownPreparedStatementVisitorTest fa

[jira] [Commented] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869267#comment-17869267 ] João Boto commented on FLINK-35909: --- [~fanrui] sure, can you assign it to me?

[jira] [Updated] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35909: -- Attachment: screenshot-2.png > JdbcFilterPushdownPreparedStatementVisitorTest fa

[jira] [Commented] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869284#comment-17869284 ] João Boto commented on FLINK-35909: --- [~linshangquan], [~Leonard] can you help

[jira] [Comment Edited] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869284#comment-17869284 ] João Boto edited comment on FLINK-35909 at 7/29/24 9:3

[jira] [Comment Edited] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869284#comment-17869284 ] João Boto edited comment on FLINK-35909 at 7/29/24 9:3

[jira] [Commented] (FLINK-35628) Translate “DataGen Connector" of "DataStream Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869510#comment-17869510 ] 毛新伟 commented on FLINK-35628: - solved > Translate “DataGen Connector" of

[jira] [Commented] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869895#comment-17869895 ] João Boto commented on FLINK-35909: --- [~wanghe] the problem is that new class

[jira] [Created] (FLINK-35945) Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka

任铭睿 created FLINK-35945: --- Summary: Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka Key: FLINK-35945 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-35978) adapt labelling of boring cyborg

João Boto created FLINK-35978: - Summary: adapt labelling of boring cyborg Key: FLINK-35978 URL: https://issues.apache.org/jira/browse/FLINK-35978 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35979) Add flink version 2.0-SNAPSHOT to ci

João Boto created FLINK-35979: - Summary: Add flink version 2.0-SNAPSHOT to ci Key: FLINK-35979 URL: https://issues.apache.org/jira/browse/FLINK-35979 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35995) postgresql有字段限制了，全量期间需要select * 的权限

宇宙先生 created FLINK-35995: Summary: postgresql有字段限制了，全量期间需要select * 的权限 Key: FLINK-35995 URL: https://issues.apache.org/jira/browse/FLINK-35995 Project: Flink Issue Type: Bug Components

[jira] [Updated] (FLINK-35995) postgresql有字段限制了，全量期间需要select * 的权限

[ https://issues.apache.org/jira/browse/FLINK-35995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-35995: - Priority: Blocker (was: Major) > postgresql有字段限制了，全量期间需要select *

[jira] [Created] (FLINK-36005) Specify to get part of the potgresql field

宇宙先生 created FLINK-36005: Summary: Specify to get part of the potgresql field Key: FLINK-36005 URL: https://issues.apache.org/jira/browse/FLINK-36005 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36009) Change configs to use CondigOptions

João Boto created FLINK-36009: - Summary: Change configs to use CondigOptions Key: FLINK-36009 URL: https://issues.apache.org/jira/browse/FLINK-36009 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-33481) Why were checkpoints stored on zookeeper deleted when JobManager failures with Flink High Availability on yarn

[ https://issues.apache.org/jira/browse/FLINK-33481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874795#comment-17874795 ] 袁枫 commented on FLINK-33481: had Fixed? [~hansonhe] > Why were checkpoints st

[jira] [Updated] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors

[ https://issues.apache.org/jira/browse/FLINK-36138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jörn Kottmann updated FLINK-36138: -- Summary: KinesisStreamsSource.build() should have helpful null errors (was

[jira] [Created] (FLINK-36138) KinesisStreamsSource.buil() should have helpful null errors

Jörn Kottmann created FLINK-36138: - Summary: KinesisStreamsSource.buil() should have helpful null errors Key: FLINK-36138 URL: https://issues.apache.org/jira/browse/FLINK-36138 Project: Flink

[jira] [Created] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

Kim Gräsman created FLINK-36146: --- Summary: NoSuchElement exception from SingleThreadFetcherManager Key: FLINK-36146 URL: https://issues.apache.org/jira/browse/FLINK-36146 Project: Flink Issue

[jira] [Commented] (FLINK-36005) Specify to get part of the potgresql field

[ https://issues.apache.org/jira/browse/FLINK-36005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876569#comment-17876569 ] 宇宙先生 commented on FLINK-36005: -- who  focus on the issu？ thanks，I think it is a value

[jira] [Updated] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kim Gräsman updated FLINK-36146: Environment: AWS EMR/Yarn (was: N/A) > NoSuchElement exception from SingleThreadFetcherMana

[jira] [Closed] (FLINK-35809) Deploying Flink History Server and Flink SQL Gateway via Flink Operator.

[ https://issues.apache.org/jira/browse/FLINK-35809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 钟洋洋 closed FLINK-35809. --- Resolution: Fixed > Deploying Flink History Server and Flink SQL Gateway via Flink Opera

[jira] [Commented] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors

[ https://issues.apache.org/jira/browse/FLINK-36138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878125#comment-17878125 ] Jörn Kottmann commented on FLINK-36138: --- Can you assign he issue to me? Th

[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878746#comment-17878746 ] David Morávek commented on FLINK-36201: --- I think this makes sense, it&#x

[jira] [Resolved] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-36201. --- Fix Version/s: 2.0.0 Resolution: Fixed > StateLocalitySlotAssigner should be o

<    3   4   5   6   7   8   9   10   11   12   >