[jira] [Created] (FLINK-19575) Create the LegacySourceTransformation translator

Kostas Kloudas created FLINK-19575: -- Summary: Create the LegacySourceTransformation translator Key: FLINK-19575 URL: https://issues.apache.org/jira/browse/FLINK-19575 Project: Flink Issue

[jira] [Created] (FLINK-19577) Create the UnionTransformation translator

Kostas Kloudas created FLINK-19577: -- Summary: Create the UnionTransformation translator Key: FLINK-19577 URL: https://issues.apache.org/jira/browse/FLINK-19577 Project: Flink Issue Type

[jira] [Created] (FLINK-19578) Create the PartitionTransformation translator

Kostas Kloudas created FLINK-19578: -- Summary: Create the PartitionTransformation translator Key: FLINK-19578 URL: https://issues.apache.org/jira/browse/FLINK-19578 Project: Flink Issue Type

[jira] [Created] (FLINK-19579) Create the SideOutputTransformation translator

Kostas Kloudas created FLINK-19579: -- Summary: Create the SideOutputTransformation translator Key: FLINK-19579 URL: https://issues.apache.org/jira/browse/FLINK-19579 Project: Flink Issue

[jira] [Created] (FLINK-19583) Expose the execution.runtime-mode to the users

Kostas Kloudas created FLINK-19583: -- Summary: Expose the execution.runtime-mode to the users Key: FLINK-19583 URL: https://issues.apache.org/jira/browse/FLINK-19583 Project: Flink Issue

[jira] [Created] (FLINK-19729) Create the FeedbackTransformation translator

Kostas Kloudas created FLINK-19729: -- Summary: Create the FeedbackTransformation translator Key: FLINK-19729 URL: https://issues.apache.org/jira/browse/FLINK-19729 Project: Flink Issue Type

[jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator

Kostas Kloudas created FLINK-19730: -- Summary: Create the CoFeedbackTransformation translator Key: FLINK-19730 URL: https://issues.apache.org/jira/browse/FLINK-19730 Project: Flink Issue

[jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode

Kostas Kloudas created FLINK-19732: -- Summary: Disable Checkpointing when in BATCH mode Key: FLINK-19732 URL: https://issues.apache.org/jira/browse/FLINK-19732 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-19814) Disable FeedbackTransformation for BATCH mode

Kostas Kloudas created FLINK-19814: -- Summary: Disable FeedbackTransformation for BATCH mode Key: FLINK-19814 URL: https://issues.apache.org/jira/browse/FLINK-19814 Project: Flink Issue Type

[jira] [Created] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode

Kostas Kloudas created FLINK-19815: -- Summary: Disable CoFeedbackTransformation for BATCH mode Key: FLINK-19815 URL: https://issues.apache.org/jira/browse/FLINK-19815 Project: Flink Issue

[jira] [Created] (FLINK-19993) Remove the flink-connector-filesystem module

Kostas Kloudas created FLINK-19993: -- Summary: Remove the flink-connector-filesystem module Key: FLINK-19993 URL: https://issues.apache.org/jira/browse/FLINK-19993 Project: Flink Issue Type

[jira] [Created] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

Kostas Kloudas created FLINK-20020: -- Summary: Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract. Key: FLINK-20020 URL: https://issues.apache.org/jira/browse/FLINK-20020

[jira] [Created] (FLINK-20141) Add documentation about the FileSink

Kostas Kloudas created FLINK-20141: -- Summary: Add documentation about the FileSink Key: FLINK-20141 URL: https://issues.apache.org/jira/browse/FLINK-20141 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode`

Kostas Kloudas created FLINK-20240: -- Summary: Add setter in the environment for the `execution.runtime-mode` Key: FLINK-20240 URL: https://issues.apache.org/jira/browse/FLINK-20240 Project: Flink

[jira] [Created] (FLINK-17515) Move file uploading functionality to a separate class

Kostas Kloudas created FLINK-17515: -- Summary: Move file uploading functionality to a separate class Key: FLINK-17515 URL: https://issues.apache.org/jira/browse/FLINK-17515 Project: Flink

[jira] [Created] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

Kostas Kloudas created FLINK-17620: -- Summary: Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint Key: FLINK-17620 URL: https://issues.apache.org/jira/browse/FLINK-17620

[jira] [Created] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

Kostas Kloudas created FLINK-17639: -- Summary: Document which FileSystems are supported by the StreamingFileSink Key: FLINK-17639 URL: https://issues.apache.org/jira/browse/FLINK-17639 Project: Flink

[jira] [Created] (FLINK-17729) Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs

Kostas Kloudas created FLINK-17729: -- Summary: Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs Key: FLINK-17729 URL: https://issues.apache.org/jira/browse/FLINK-17729 Project

[jira] [Created] (FLINK-18084) Create documentation for the Application Mode

Kostas Kloudas created FLINK-18084: -- Summary: Create documentation for the Application Mode Key: FLINK-18084 URL: https://issues.apache.org/jira/browse/FLINK-18084 Project: Flink Issue Type

[jira] [Created] (FLINK-18469) Add Application Mode to release notes.

Kostas Kloudas created FLINK-18469: -- Summary: Add Application Mode to release notes. Key: FLINK-18469 URL: https://issues.apache.org/jira/browse/FLINK-18469 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-18519) Propagate exception to client when execution fails for REST submission

Kostas Kloudas created FLINK-18519: -- Summary: Propagate exception to client when execution fails for REST submission Key: FLINK-18519 URL: https://issues.apache.org/jira/browse/FLINK-18519 Project

[jira] [Created] (FLINK-6356) Make times() eager and enable allowing combinations.

Kostas Kloudas created FLINK-6356: - Summary: Make times() eager and enable allowing combinations. Key: FLINK-6356 URL: https://issues.apache.org/jira/browse/FLINK-6356 Project: Flink Issue

[jira] [Created] (FLINK-6371) Return matched patterns as Map> instead of Map

Kostas Kloudas created FLINK-6371: - Summary: Return matched patterns as Map> instead of Map Key: FLINK-6371 URL: https://issues.apache.org/jira/browse/FLINK-6371 Project: Flink Issue T

[jira] [Created] (FLINK-6445) Fix behavior when condition is null.

Kostas Kloudas created FLINK-6445: - Summary: Fix behavior when condition is null. Key: FLINK-6445 URL: https://issues.apache.org/jira/browse/FLINK-6445 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6458) Support NOT patterns with preceding OPTIONALS

Kostas Kloudas created FLINK-6458: - Summary: Support NOT patterns with preceding OPTIONALS Key: FLINK-6458 URL: https://issues.apache.org/jira/browse/FLINK-6458 Project: Flink Issue Type

[jira] [Created] (FLINK-6463) Throw exception when NOT-NEXT is after OPTIONAL

Kostas Kloudas created FLINK-6463: - Summary: Throw exception when NOT-NEXT is after OPTIONAL Key: FLINK-6463 URL: https://issues.apache.org/jira/browse/FLINK-6463 Project: Flink Issue Type

[jira] [Created] (FLINK-6536) Improve error message in SharedBuffer::put()

Kostas Kloudas created FLINK-6536: - Summary: Improve error message in SharedBuffer::put() Key: FLINK-6536 URL: https://issues.apache.org/jira/browse/FLINK-6536 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6538) Emit late elements as Side Outputs

Kostas Kloudas created FLINK-6538: - Summary: Emit late elements as Side Outputs Key: FLINK-6538 URL: https://issues.apache.org/jira/browse/FLINK-6538 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

Kostas Kloudas created FLINK-6578: - Summary: SharedBuffer creates self-loops when having elements with same value/timestamp. Key: FLINK-6578 URL: https://issues.apache.org/jira/browse/FLINK-6578

[jira] [Created] (FLINK-6604) Remove Java Serialization from the CEP library.

Kostas Kloudas created FLINK-6604: - Summary: Remove Java Serialization from the CEP library. Key: FLINK-6604 URL: https://issues.apache.org/jira/browse/FLINK-6604 Project: Flink Issue Type

[jira] [Created] (FLINK-6634) NFA serializer does not serialize the ValueTimeWrapper counter.

Kostas Kloudas created FLINK-6634: - Summary: NFA serializer does not serialize the ValueTimeWrapper counter. Key: FLINK-6634 URL: https://issues.apache.org/jira/browse/FLINK-6634 Project: Flink

[jira] [Created] (FLINK-6656) Migrate CEP PriorityQueue to MapState

Kostas Kloudas created FLINK-6656: - Summary: Migrate CEP PriorityQueue to MapState Key: FLINK-6656 URL: https://issues.apache.org/jira/browse/FLINK-6656 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6897) Re-add support for Java 8 lambdas.

Kostas Kloudas created FLINK-6897: - Summary: Re-add support for Java 8 lambdas. Key: FLINK-6897 URL: https://issues.apache.org/jira/browse/FLINK-6897 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7008) Update NFA state only when the NFA changes.

Kostas Kloudas created FLINK-7008: - Summary: Update NFA state only when the NFA changes. Key: FLINK-7008 URL: https://issues.apache.org/jira/browse/FLINK-7008 Project: Flink Issue Type

[jira] [Created] (FLINK-7043) Optimize state handling in NFA

Kostas Kloudas created FLINK-7043: - Summary: Optimize state handling in NFA Key: FLINK-7043 URL: https://issues.apache.org/jira/browse/FLINK-7043 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7044) Add methods to the client API that take the stateDescriptor itself.

Kostas Kloudas created FLINK-7044: - Summary: Add methods to the client API that take the stateDescriptor itself. Key: FLINK-7044 URL: https://issues.apache.org/jira/browse/FLINK-7044 Project: Flink

[jira] [Created] (FLINK-7059) Queryable state does not work with ListState

Kostas Kloudas created FLINK-7059: - Summary: Queryable state does not work with ListState Key: FLINK-7059 URL: https://issues.apache.org/jira/browse/FLINK-7059 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7060) Change annotation in TypeInformation subclasses

Kostas Kloudas created FLINK-7060: - Summary: Change annotation in TypeInformation subclasses Key: FLINK-7060 URL: https://issues.apache.org/jira/browse/FLINK-7060 Project: Flink Issue Type

[jira] [Created] (FLINK-7379) Remove `HighAvailabilityServices` from client constructor.

Kostas Kloudas created FLINK-7379: - Summary: Remove `HighAvailabilityServices` from client constructor. Key: FLINK-7379 URL: https://issues.apache.org/jira/browse/FLINK-7379 Project: Flink

[jira] [Created] (FLINK-7384) Unify event and processing time handling in the AbstractKeyedCEPPatternOperator.

Kostas Kloudas created FLINK-7384: - Summary: Unify event and processing time handling in the AbstractKeyedCEPPatternOperator. Key: FLINK-7384 URL: https://issues.apache.org/jira/browse/FLINK-7384

[jira] [Created] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

Kostas Kloudas created FLINK-7521: - Summary: Remove the 10MB limit from the current REST implementation. Key: FLINK-7521 URL: https://issues.apache.org/jira/browse/FLINK-7521 Project: Flink

[jira] [Created] (FLINK-7543) Simplify REST parameter access.

Kostas Kloudas created FLINK-7543: - Summary: Simplify REST parameter access. Key: FLINK-7543 URL: https://issues.apache.org/jira/browse/FLINK-7543 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7550) Give names to REST client/server for clearer logging.

Kostas Kloudas created FLINK-7550: - Summary: Give names to REST client/server for clearer logging. Key: FLINK-7550 URL: https://issues.apache.org/jira/browse/FLINK-7550 Project: Flink Issue

[jira] [Created] (FLINK-7551) Add VERSION to the REST urls.

Kostas Kloudas created FLINK-7551: - Summary: Add VERSION to the REST urls. Key: FLINK-7551 URL: https://issues.apache.org/jira/browse/FLINK-7551 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7770) Hide Queryable State behind a proxy.

Kostas Kloudas created FLINK-7770: - Summary: Hide Queryable State behind a proxy. Key: FLINK-7770 URL: https://issues.apache.org/jira/browse/FLINK-7770 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7769) Move Queryable State outside the runtime.

Kostas Kloudas created FLINK-7769: - Summary: Move Queryable State outside the runtime. Key: FLINK-7769 URL: https://issues.apache.org/jira/browse/FLINK-7769 Project: Flink Issue Type

[jira] [Created] (FLINK-7771) Make the operator state queryable

Kostas Kloudas created FLINK-7771: - Summary: Make the operator state queryable Key: FLINK-7771 URL: https://issues.apache.org/jira/browse/FLINK-7771 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7788) Allow port range for queryable state client proxy.

Kostas Kloudas created FLINK-7788: - Summary: Allow port range for queryable state client proxy. Key: FLINK-7788 URL: https://issues.apache.org/jira/browse/FLINK-7788 Project: Flink Issue

[jira] [Created] (FLINK-7822) Add documentation for the new queryable state client.

Kostas Kloudas created FLINK-7822: - Summary: Add documentation for the new queryable state client. Key: FLINK-7822 URL: https://issues.apache.org/jira/browse/FLINK-7822 Project: Flink Issue

[jira] [Created] (FLINK-7823) Adjust queryable state configuration parameters

Kostas Kloudas created FLINK-7823: - Summary: Adjust queryable state configuration parameters Key: FLINK-7823 URL: https://issues.apache.org/jira/browse/FLINK-7823 Project: Flink Issue Type

[jira] [Created] (FLINK-7824) Put the queryable state jars in the opt folder.

Kostas Kloudas created FLINK-7824: - Summary: Put the queryable state jars in the opt folder. Key: FLINK-7824 URL: https://issues.apache.org/jira/browse/FLINK-7824 Project: Flink Issue Type

[jira] [Created] (FLINK-7825) Change the `QueryableStateClient` to use a builder pattern.

Kostas Kloudas created FLINK-7825: - Summary: Change the `QueryableStateClient` to use a builder pattern. Key: FLINK-7825 URL: https://issues.apache.org/jira/browse/FLINK-7825 Project: Flink

[jira] [Created] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

Kostas Kloudas created FLINK-7826: - Summary: Add support for all types of state to the QueryableStateClient. Key: FLINK-7826 URL: https://issues.apache.org/jira/browse/FLINK-7826 Project: Flink

[jira] [Created] (FLINK-7835) Fix duplicate() method in NFASerializer

Kostas Kloudas created FLINK-7835: - Summary: Fix duplicate() method in NFASerializer Key: FLINK-7835 URL: https://issues.apache.org/jira/browse/FLINK-7835 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7908) Restructure the QS module to reduce client deps.

Kostas Kloudas created FLINK-7908: - Summary: Restructure the QS module to reduce client deps. Key: FLINK-7908 URL: https://issues.apache.org/jira/browse/FLINK-7908 Project: Flink Issue Type

[jira] [Created] (FLINK-7933) Test instability PrometheusReporterTest

Kostas Kloudas created FLINK-7933: - Summary: Test instability PrometheusReporterTest Key: FLINK-7933 URL: https://issues.apache.org/jira/browse/FLINK-7933 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8050) RestServer#shutdown() ignores exceptions thrown when shutting down netty.

Kostas Kloudas created FLINK-8050: - Summary: RestServer#shutdown() ignores exceptions thrown when shutting down netty. Key: FLINK-8050 URL: https://issues.apache.org/jira/browse/FLINK-8050 Project

[jira] [Created] (FLINK-8049) RestClient#shutdown() ignores exceptions thrown when shutting down netty.

Kostas Kloudas created FLINK-8049: - Summary: RestClient#shutdown() ignores exceptions thrown when shutting down netty. Key: FLINK-8049 URL: https://issues.apache.org/jira/browse/FLINK-8049 Project

[jira] [Created] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

Kostas Kloudas created FLINK-8073: - Summary: Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() Key: FLINK-8073 URL: https://issues.apache.org/jira/browse/FLINK-8073

[jira] [Created] (FLINK-8090) An operator should not be able to register two states with the same name.

Kostas Kloudas created FLINK-8090: - Summary: An operator should not be able to register two states with the same name. Key: FLINK-8090 URL: https://issues.apache.org/jira/browse/FLINK-8090 Project

[jira] [Created] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast.

Kostas Kloudas created FLINK-8345: - Summary: Iterate over keyed state on broadcast side of connect with broadcast. Key: FLINK-8345 URL: https://issues.apache.org/jira/browse/FLINK-8345 Project: Flink

[jira] [Created] (FLINK-8446) Add support for multiple broadcast states.

Kostas Kloudas created FLINK-8446: - Summary: Add support for multiple broadcast states. Key: FLINK-8446 URL: https://issues.apache.org/jira/browse/FLINK-8446 Project: Flink Issue Type: New

[jira] [Created] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read.

Kostas Kloudas created FLINK-8522: - Summary: DefaultOperatorStateBackend writes data in checkpoint that is never read. Key: FLINK-8522 URL: https://issues.apache.org/jira/browse/FLINK-8522 Project

[jira] [Created] (FLINK-8561) SharedBuffer line 573 uses == to compare BufferEntries instead of .equals.

Kostas Kloudas created FLINK-8561: - Summary: SharedBuffer line 573 uses == to compare BufferEntries instead of .equals. Key: FLINK-8561 URL: https://issues.apache.org/jira/browse/FLINK-8561 Project

[jira] [Created] (FLINK-8597) Add examples for Connected Streams with Broadcast State.

Kostas Kloudas created FLINK-8597: - Summary: Add examples for Connected Streams with Broadcast State. Key: FLINK-8597 URL: https://issues.apache.org/jira/browse/FLINK-8597 Project: Flink

[jira] [Created] (FLINK-8642) Initialize descriptors before use at getBroadcastState().

Kostas Kloudas created FLINK-8642: - Summary: Initialize descriptors before use at getBroadcastState(). Key: FLINK-8642 URL: https://issues.apache.org/jira/browse/FLINK-8642 Project: Flink

[jira] [Created] (FLINK-8659) Add migration tests for Broadcast state.

Kostas Kloudas created FLINK-8659: - Summary: Add migration tests for Broadcast state. Key: FLINK-8659 URL: https://issues.apache.org/jira/browse/FLINK-8659 Project: Flink Issue Type

[jira] [Created] (FLINK-8722) Refactor BroadcastState examples.

Kostas Kloudas created FLINK-8722: - Summary: Refactor BroadcastState examples. Key: FLINK-8722 URL: https://issues.apache.org/jira/browse/FLINK-8722 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8723) Remove existing BroadcastState examples.

Kostas Kloudas created FLINK-8723: - Summary: Remove existing BroadcastState examples. Key: FLINK-8723 URL: https://issues.apache.org/jira/browse/FLINK-8723 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-8724) Add BroadcastState examples with predetermined state transitions for the broadcast state

Kostas Kloudas created FLINK-8724: - Summary: Add BroadcastState examples with predetermined state transitions for the broadcast state Key: FLINK-8724 URL: https://issues.apache.org/jira/browse/FLINK-8724

[jira] [Created] (FLINK-8780) Add Broadcast State documentation.

Kostas Kloudas created FLINK-8780: - Summary: Add Broadcast State documentation. Key: FLINK-8780 URL: https://issues.apache.org/jira/browse/FLINK-8780 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8802) Concurrent serialization without duplicating serializers in state server.

Kostas Kloudas created FLINK-8802: - Summary: Concurrent serialization without duplicating serializers in state server. Key: FLINK-8802 URL: https://issues.apache.org/jira/browse/FLINK-8802 Project

[jira] [Created] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer.

Kostas Kloudas created FLINK-8841: - Summary: Duplicate MapSerializer and HashMapSerializer. Key: FLINK-8841 URL: https://issues.apache.org/jira/browse/FLINK-8841 Project: Flink Issue Type

[jira] [Created] (FLINK-8908) MapSerializer creates new serializer even if key and value serializers are stateless

Kostas Kloudas created FLINK-8908: - Summary: MapSerializer creates new serializer even if key and value serializers are stateless Key: FLINK-8908 URL: https://issues.apache.org/jira/browse/FLINK-8908

[jira] [Created] (FLINK-8926) Shutdown client proxy on test end.

Kostas Kloudas created FLINK-8926: - Summary: Shutdown client proxy on test end. Key: FLINK-8926 URL: https://issues.apache.org/jira/browse/FLINK-8926 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8928) Improve error message on server binding error.

Kostas Kloudas created FLINK-8928: - Summary: Improve error message on server binding error. Key: FLINK-8928 URL: https://issues.apache.org/jira/browse/FLINK-8928 Project: Flink Issue Type

[jira] [Created] (FLINK-9046) Improve error messages when receiving unexpected messages.

Kostas Kloudas created FLINK-9046: - Summary: Improve error messages when receiving unexpected messages. Key: FLINK-9046 URL: https://issues.apache.org/jira/browse/FLINK-9046 Project: Flink

<    1   2   3   4   5