Fang Yong created FLINK-6352:
Summary: FlinkKafkaConsumer should support to use timestamp to set
up start offset
Key: FLINK-6352
URL: https://issues.apache.org/jira/browse/FLINK-6352
Project: Flink
mingleizhang created FLINK-6351:
---
Summary: Refactoring YarnFlinkApplicationMasterRunner by combining
AbstractYarnFlinkApplicationMasterRunner in one class
Key: FLINK-6351
URL: https://issues.apache.org/jira/browse/F
Bowen Li created FLINK-6350:
---
Summary: Flink: Windowing does not work with streams from
collections and the local execution environment
Key: FLINK-6350
URL: https://issues.apache.org/jira/browse/FLINK-6350
Hello Beam, Calcite, and Flink dev lists!
Apologies for the big cross post, but I thought this might be something all
three communities would find relevant.
Beam is finally making progress on a SQL DSL utilizing Calcite, thanks to
Mingmin Xu. As you can imagine, we need to come to some conclusion
Tzu-Li (Gordon) Tai created FLINK-6349:
--
Summary: Enforce per-subtask record ordering on resharding for
FlinkKinesisConsumer
Key: FLINK-6349
URL: https://issues.apache.org/jira/browse/FLINK-6349
Tzu-Li (Gordon) Tai created FLINK-6348:
--
Summary: Migrate from Java serialization for RollingSink's state
Key: FLINK-6348
URL: https://issues.apache.org/jira/browse/FLINK-6348
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6347:
--
Summary: Migrate from Java serialization for
MessageAcknowledgingSourceBase's state
Key: FLINK-6347
URL: https://issues.apache.org/jira/browse/FLINK-6347
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:
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
Pr
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
Tzu-Li (Gordon) Tai created FLINK-6343:
--
Summary: Migrate from discouraged Java serialization for all
sources / sinks
Key: FLINK-6343
URL: https://issues.apache.org/jira/browse/FLINK-6343
Project
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 watch
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 Flink community,
>
> Plea
Till Rohrmann created FLINK-6342:
Summary: Start ZooKeeperLeaderElectionService under lock to avoid
race condition
Key: FLINK-6342
URL: https://issues.apache.org/jira/browse/FLINK-6342
Project: Flink
+1 (binding) for the release
- checked all checksums and signatures
- started standalone clusters and ran Gelly example
Greg
> On Apr 12, 2017, at 7:06 PM, Robert Metzger wrote:
>
> Dear Flink community,
>
> Please vote on releasing the following candidate as Apache Flink version 1.2
> .1.
>
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 implementatio
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
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
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: Impro
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: I
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 Type
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 the hash of the commit
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
@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: https://github.com/aljosc
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
25 matches
Mail list logo
