sunjincheng created FLINK-6924:
--
Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI
Key: FLINK-6924
URL: https://issues.apache.org/jira/browse/FLINK-6924
Project: Flink
Issue Type: Sub-task
Hi Till,
Could you grant me the edit permission of Flink WIKI? My id is imjark.
Thanks,
Jark Wu
2017-06-15 0:07 GMT+08:00 Till Rohrmann :
> I think that the integration of SQL and CEP would make a good FLIP.
>
> Cheers,
> Till
>
> On Wed, Jun 14, 2017 at 2:40 PM, Jark Wu wrote:
>
> > Hi,
> >
>
Zhenzhong Xu created FLINK-6923:
---
Summary: Kafka connector needs to expose information about
in-flight record in AbstractFetcher base class
Key: FLINK-6923
URL: https://issues.apache.org/jira/browse/FLINK-6923
I think that the integration of SQL and CEP would make a good FLIP.
Cheers,
Till
On Wed, Jun 14, 2017 at 2:40 PM, Jark Wu wrote:
> Hi,
>
> Do you think whether we should create a FLIP for this proposal to track
> progress?
>
> Regards,
> Jark
>
> 2017-06-13 16:59 GMT+08:00 Dian Fu :
>
> > Hi Fa
Till Rohrmann created FLINK-6922:
Summary: Enum(Value)SerializerConfigSnapshot uses Java
serialization to store enum values
Key: FLINK-6922
URL: https://issues.apache.org/jira/browse/FLINK-6922
Projec
Till Rohrmann created FLINK-6921:
Summary: EnumValueSerializer cannot properly handle appended enum
values
Key: FLINK-6921
URL: https://issues.apache.org/jira/browse/FLINK-6921
Project: Flink
I've closed my emails, so I didn't see your messages anymore Fabian.
The RC1 for 1.3.1 is out now. I personally think we should not cancel it
because of these two issues.
If we find more stuff we can do it, but I would like to push out 1.3.1 soon
to make the ES5 connector and the fixes to the state
Dear Flink community,
Please vote on releasing the following candidate as Apache Flink version
1.3.1.
The commit to be voted on:
http://git-wip-us.apache.org/repos/asf/flink/commit/7cfe62b9
Branch:
release-1.3.1-rc1
The release artifacts to be voted on can be found at:
*http://people.apache.org
The DC does delete local files. The user requests the file through the
RuntimeContext, but
the download and local caching is completely handled by Flink.
The problems you mention is exactly why I'm suggesting to rebuild the DC
on-top of the Blob service.
If a user currently wants to use the f
Actually, I don't see the automatic cleanup you referred to but from what I
can see around the DistributedCache class and its use, it is simply a registry
for user-files whose life cycle is completely managed by the user (upload,
download, delete). Files may even reside outside of flink's contro
Chesnay Schepler created FLINK-6920:
---
Summary: Remove minor guava usages in several modules
Key: FLINK-6920
URL: https://issues.apache.org/jira/browse/FLINK-6920
Project: Flink
Issue Type:
Hi,
Do you think whether we should create a FLIP for this proposal to track
progress?
Regards,
Jark
2017-06-13 16:59 GMT+08:00 Dian Fu :
> Hi Fabian,
>
> Thanks a lot. Agree that we can start working by adding the missing
> features of the CEP library.
>
> Best regards,
> Dian
>
> On Tue, Jun 1
Greg Hogan created FLINK-6918:
-
Summary: Failing tests: ChainLengthDecreaseTest and
ChainLengthIncreaseTest
Key: FLINK-6918
URL: https://issues.apache.org/jira/browse/FLINK-6918
Project: Flink
I
Tzu-Li (Gordon) Tai created FLINK-6917:
--
Summary: Introduce test base for end-to-end testing serializer
config snapshotting, restoring, and compatibility check roundtrips
Key: FLINK-6917
URL: https://issues.
Hello,
I am trying to print which Flink API (e.g Complex Event Processing or
Streaming SQL) was called that resulted in a call down the function stack
in task handling code. Please tell me how it could be done using existing
code base (1.3.0).
Regards,
Ameet
One thing i was wondering for a long time now is why the distributed
cache is not implemented
via the blob store.
The DC is essentially just a copy routine with local caching and
automatic cleanup, so basically what
the blob store is supposed to do (i guess).
On 13.06.2017 16:31, Nico Kruber
Nico Kruber created FLINK-6916:
--
Summary: FLIP-19: Improved BLOB storage architecture
Key: FLINK-6916
URL: https://issues.apache.org/jira/browse/FLINK-6916
Project: Flink
Issue Type: Improvement
Hi John,
The semantics of a count window depend on the order of rows which is
specified by the "on" keyword.
Without the order of rows, a count window would not be fully specified and
might return arbitrary groups of rows.
Best, Fabian
2017-06-14 12:03 GMT+02:00 方孝健(玄弟) :
> Hi devs,The Row-
Hi devs, The Row-Count-Window must require proctime at Table API, and the
definiton for Row-Count-Window like the [1].In fact I don't understand it. The
countWindow is based on a window (range) of preceding and succeeding rows, but
not the time. Thedefinition [2] for Row-Count-Window maybe f
Hi @Robert,
I agree with @Fabian.
And thanks for review those PRs. @Fabian.
Cheers,
SunJincheng
2017-06-14 16:53 GMT+08:00 Fabian Hueske :
> I don't think that
>
> https://issues.apache.org/jira/browse/FLINK-6886
> https://issues.apache.org/jira/browse/FLINK-6896
>
> are blockers but it would be
I don't think that
https://issues.apache.org/jira/browse/FLINK-6886
https://issues.apache.org/jira/browse/FLINK-6896
are blockers but it would be good to include them.
I'll try to review the PRs today and merge them.
Cheers, Fabian
2017-06-13 11:48 GMT+02:00 Till Rohrmann :
> I've just merged
Till Rohrmann created FLINK-6915:
Summary: EnumValueSerializer broken
Key: FLINK-6915
URL: https://issues.apache.org/jira/browse/FLINK-6915
Project: Flink
Issue Type: Bug
Components
I looks like all blockers for the 1.3.1 release have been merged.
I'll now create the RC for it. I think we need to get the RC out asap. Many
users complained about the missing elasticsearch5 connector.
On Tue, Jun 13, 2017 at 11:48 AM, Till Rohrmann
wrote:
> I've just merged the fix for this
Till Rohrmann created FLINK-6914:
Summary: TrySerializer#ensureCompatibility causes
StackOverflowException
Key: FLINK-6914
URL: https://issues.apache.org/jira/browse/FLINK-6914
Project: Flink
Till Rohrmann created FLINK-6913:
Summary: Instable
StatefulJobSavepointMigrationITCase.testRestoreSavepoint
Key: FLINK-6913
URL: https://issues.apache.org/jira/browse/FLINK-6913
Project: Flink
Hi Meera,
You can emit a DataStream using a SinkFunction. Flink provides
SinkFunctions for a couple of systems but AFAIK, none to write data to a
relational database, i.e., a JdbcSinkFunction [1].
I think the right way to do this is to implement a JdbcSinkFunction. We
have a JdbcOutputFormat whic
Mikhail Pryakhin created FLINK-6912:
---
Summary: Consider changing the RichFunction#open method signature
to take no arguments.
Key: FLINK-6912
URL: https://issues.apache.org/jira/browse/FLINK-6912
Pr
27 matches
Mail list logo
