Timo Walther created FLINK-4070:
---
Summary: Support literals on left side of binary expressions
Key: FLINK-4070
URL: https://issues.apache.org/jira/browse/FLINK-4070
Project: Flink
Issue Type: I
Can you add a flag to each element emitted by the CoGroupFunction that
indicates whether it was joined or not?
Then you can use split to distinguish between both cases and handle both
streams differently.
Best, Fabian
2016-06-15 6:45 GMT+02:00 Vinay Patil :
> Hi Jark,
>
> I am able to get the no
Till Rohrmann created FLINK-4071:
Summary: JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp
failed on Travis
Key: FLINK-4071
URL: https://issues.apache.org/jira/browse/FLINK-4071
Project: Flin
Till Rohrmann created FLINK-4072:
Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow
fails on Travis
Key: FLINK-4072
URL: https://issues.apache.org/jira/browse/FLINK-4072
Project: Flink
Till Rohrmann created FLINK-4073:
Summary: YARNSessionCapacitySchedulerITCase.testTaskManagerFailure
failed on Travis
Key: FLINK-4073
URL: https://issues.apache.org/jira/browse/FLINK-4073
Project: Fli
Chesnay Schepler created FLINK-4074:
---
Summary: Reporter can block TaskManager shutdown
Key: FLINK-4074
URL: https://issues.apache.org/jira/browse/FLINK-4074
Project: Flink
Issue Type: Impro
Till Rohrmann created FLINK-4075:
Summary: ContinuousFileProcessingCheckpointITCase failed on Travis
Key: FLINK-4075
URL: https://issues.apache.org/jira/browse/FLINK-4075
Project: Flink
Issue
Ted Yu created FLINK-4076:
-
Summary: BoltWrapper#dispose() should call
AbstractStreamOperator#dispose()
Key: FLINK-4076
URL: https://issues.apache.org/jira/browse/FLINK-4076
Project: Flink
Issue Typ
Fabian Hueske created FLINK-4077:
Summary: Register Pojo DataSet/DataStream as Table requires alias
expression.
Key: FLINK-4077
URL: https://issues.apache.org/jira/browse/FLINK-4077
Project: Flink
Ufuk Celebi created FLINK-4078:
--
Summary: Use ClosureCleaner for CoGroup where
Key: FLINK-4078
URL: https://issues.apache.org/jira/browse/FLINK-4078
Project: Flink
Issue Type: Bug
Affects Ve
Ufuk Celebi created FLINK-4079:
--
Summary: YARN properties file used for per-job cluster
Key: FLINK-4079
URL: https://issues.apache.org/jira/browse/FLINK-4079
Project: Flink
Issue Type: Bug
A
Hey Julius,
You have to wait or find someone to review it. The PR looks
interesting. The big question though is that who is going to maintain
it if we merge it.
An alternative would be to keep it in your GitHub repository and we
link it from the project page.
– Ufuk
On Mon, Jun 13, 2016 at 1:05
Tzu-Li (Gordon) Tai created FLINK-4080:
--
Summary: Kinesis consumer not exactly-once if stopped in the
middle of processing aggregated records
Key: FLINK-4080
URL: https://issues.apache.org/jira/browse/FLINK-4
I’ve made some code changes for this ticket and need some coaching on how to
test/verify before I commit/push.
· How to I build and installation package locally?
· What verification(s) do I need to do other than my own test case?
· Is there a code review process before
1:
https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/building.html
2: Generally none, provided the test cases are good.
Certain features require a test run on a cluster.
3: The code review will be done as part of the PR review.
On 15.06.2016 19:50, THORMAN, ROBERT D wrote:
I
Is there a way to check for code format violations in IntelliJ. I keep failing
the build on one format violation.
On 6/15/16, 1:21 PM, "Chesnay Schepler" wrote:
1:
https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/building.html
2: Generally none, provided the test cases are
Hi,
Flink 1.0.0 was released early March, so three months have passed and I
think we should start discussing the scope of the next major release
(1.1.0).
>From a high level point of view, we've added the following new features:
in master:
- Table API Refactoring, SQL, StreamSQL
- The metrics syst
Hi,
there is a Checkstyle Plugin for IntelliJ that allows you to load our
checkstyle configuration file. This will then show errors like parser
errors.
Regards,
Robert
On Wed, Jun 15, 2016 at 8:53 PM, THORMAN, ROBERT D wrote:
> Is there a way to check for code format violations in IntelliJ. I
I moved the State Backend to the Checkpointing and added the three of you
as shepherds.
We still need somebody for the client.
On Thu, Jun 9, 2016 at 11:41 AM, Till Rohrmann wrote:
> I agree. I could be the third backup if you need help with the component.
>
> On Thu, Jun 9, 2016 at 11:33 AM, A
You can run mvn checkstyle:check in the flink to search for codestyle
violations.
You should be able to define a maven build in intelliJ that does that.
(Run -> Edit configurations -> Maven)
On 15.06.2016 20:53, THORMAN, ROBERT D wrote:
Is there a way to check for code format violations in Inte
Hi Robert,
Thanks for staying the discussion.
Do you know if there any open tasks for the Resource Manager left?
That is probably needed for Mesos integration?
- Henry
On Wed, Jun 15, 2016 at 12:55 PM, Robert Metzger
wrote:
> Hi,
>
> Flink 1.0.0 was released early March, so three months have
21 matches
Mail list logo
