[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

mingleizhang created FLINK-6351: --- Summary: Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class Key: FLINK-6351 URL:

[jira] [Created] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

Tzu-Li (Gordon) Tai created FLINK-6346: -- Summary: Migrate from Java serialization for GenericWriteAheadSink's state Key: FLINK-6346 URL: https://issues.apache.org/jira/browse/FLINK-6346 Project:

[jira] [Created] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state

Tzu-Li (Gordon) Tai created FLINK-6345: -- Summary: Migrate from Java serialization for ContinuousFileReaderOperator's state Key: FLINK-6345 URL: https://issues.apache.org/jira/browse/FLINK-6345

[jira] [Created] (FLINK-6344) Migrate from Java serialization for `BucketingSink`'s state

Tzu-Li (Gordon) Tai created FLINK-6344: -- Summary: Migrate from Java serialization for `BucketingSink`'s state Key: FLINK-6344 URL: https://issues.apache.org/jira/browse/FLINK-6344 Project: Flink

Idempotent Job Submission

Hey all, I have been doing some digging to see if there is a good way to do an idempotent job submission. I was hoping to write a job submission agent that does the following: 1. Checks to see if the cluster is running yet (can contact a JobManager) 2. Checks to see if the job it is

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

LICENSE file exists NOTICE file looks good Signature files look good Hash files look good No 3rd party exes in source artifact Source compiled and pass tests Local run work Run simple job on YARN +1 - Henry On Wed, Apr 12, 2017 at 4:06 PM, Robert Metzger wrote: > Dear

Why TimerService interface in ProcessFunction doesn't have deleteEventTimeTimer

Hi I am working on a use case where I want to start a timer for a given event type and when that timer expires it will perform certain action. This can be done using Process Function. But I also want to cancel scheduled timer in case of some other types of events. I also checked the

[jira] [Created] (FLINK-6341) JobManager can go to definite message sending loop when TaskManager registered

Tao Wang created FLINK-6341: --- Summary: JobManager can go to definite message sending loop when TaskManager registered Key: FLINK-6341 URL: https://issues.apache.org/jira/browse/FLINK-6341 Project: Flink

[jira] [Created] (FLINK-6340) Introduce a TerminationFuture for Execution

Stephan Ewen created FLINK-6340: --- Summary: Introduce a TerminationFuture for Execution Key: FLINK-6340 URL: https://issues.apache.org/jira/browse/FLINK-6340 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6339) Remove useless and unused class ConnectorSource

Stephan Ewen created FLINK-6339: --- Summary: Remove useless and unused class ConnectorSource Key: FLINK-6339 URL: https://issues.apache.org/jira/browse/FLINK-6339 Project: Flink Issue Type:

[jira] [Created] (FLINK-6338) SimpleStringUtils should be called StringValueUtils

Stephan Ewen created FLINK-6338: --- Summary: SimpleStringUtils should be called StringValueUtils Key: FLINK-6338 URL: https://issues.apache.org/jira/browse/FLINK-6338 Project: Flink Issue Type:

[jira] [Created] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

zhijiang created FLINK-6337: --- Summary: Remove the buffer provider from PartitionRequestServerHandler Key: FLINK-6337 URL: https://issues.apache.org/jira/browse/FLINK-6337 Project: Flink Issue

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

I downloaded and expanded flink-1.2.1-src.tgz one more time. The failed tests are not in source tar ball. Looks like I expanded the tar ball into the same directory for previous RC last week. Cheers On Thu, Apr 20, 2017 at 1:32 AM, Aljoscha Krettek wrote: > @Ted What is

[jira] [Created] (FLINK-6336) Placement Constraints for Mesos

Stephen Gran created FLINK-6336: --- Summary: Placement Constraints for Mesos Key: FLINK-6336 URL: https://issues.apache.org/jira/browse/FLINK-6336 Project: Flink Issue Type: New Feature

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

@Ted What is the hash of the commit where you saw the failing test? I think it might have been some intermediate commit because these tests are not in the code anymore on the release branch. > On 19. Apr 2017, at 18:35, Henry Saputra wrote: > > This should be the one:

[jira] [Created] (FLINK-6335) Support DISTINCT over grouped window in stream SQL

Haohui Mai created FLINK-6335: - Summary: Support DISTINCT over grouped window in stream SQL Key: FLINK-6335 URL: https://issues.apache.org/jira/browse/FLINK-6335 Project: Flink Issue Type: Bug