[
https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6178:
---
Description:
Currently, users are locked in with the serializer implementation used to
[
https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942742#comment-15942742
]
Anton Mushin commented on FLINK-3320:
-
Hi [~dawidwys],
I am not working on the issue.
[
https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855653#comment-15855653
]
Anton Mushin edited comment on FLINK-5435 at 3/27/17 6:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin reassigned FLINK-3320:
---
Assignee: (was: Anton Mushin)
> Add not operator to CEP's pattern API
> -
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942740#comment-15942740
]
Anton Mushin commented on FLINK-4604:
-
Hi everyone,
Calcite 1.12 has been release:
ht
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
[
https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6190:
---
Description:
In order for serializers to be able to be reconfigured on restore, we nee
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
[
https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942695#comment-15942695
]
ramkrishna.s.vasudevan commented on FLINK-5752:
---
Wil start working on this s
[
https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6191:
---
Description:
This sub-task follows after FLINK-6190.
For non-primitive type serialize
Tzu-Li (Gordon) Tai created FLINK-6191:
--
Summary: Make non-primitive, internal built-in serializers
reconfigurable
Key: FLINK-6191
URL: https://issues.apache.org/jira/browse/FLINK-6191
Project: F
[
https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6190:
---
Description:
In order for serializers to be able to be reconfigured on restore, we nee
[
https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6190:
---
Description:
In order for serializers to be able to be reconfigured on restore, we nee
Tzu-Li (Gordon) Tai created FLINK-6190:
--
Summary: Write "Serializer Configurations" metainfo along with
state
Key: FLINK-6190
URL: https://issues.apache.org/jira/browse/FLINK-6190
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942598#comment-15942598
]
zhangrucong1982 commented on FLINK-6151:
Yes, I agree with you. May be the ZK clie
[
https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942564#comment-15942564
]
ASF GitHub Bot commented on FLINK-2720:
---
Github user RalphSu commented on the issue:
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/1157
I added https://github.com/apache/flink/pull/3615, welcome for comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your projec
Github user RalphSu commented on the issue:
https://github.com/apache/flink/pull/3615
Referring to https://github.com/apache/flink/pull/1157. Not sure how to
have two PR for one jira? Any suggestion
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942552#comment-15942552
]
Yuhong Hong commented on FLINK-6187:
Yes, i have configure HA, the problem seems to be
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942518#comment-15942518
]
Ted Yu commented on FLINK-5987:
---
Actually 3.4.10 is being voted on.
We can upgrade to 3.4.1
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG.
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5943:
--
Description:
{code}
protected void shutdown(ApplicationStatus status, String msg) {
// Need to clear the j
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854366#comment-15854366
]
Ted Yu edited comment on FLINK-5629 at 3/27/17 12:51 AM:
-
RandomAc
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDu
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/27/17 12:52 AM:
-
Lock on
[
https://issues.apache.org/jira/browse/FLINK-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942433#comment-15942433
]
ASF GitHub Bot commented on FLINK-5911:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3433#discussion_r108069363
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Parameter.java
---
@@ -0,0 +1,55 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-6176:
-
Assignee: Greg Hogan
> Add JARs to CLASSPATH deterministically
>
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3590
Hi @rtudoran,
thanks for doing the benchmark and posting the numbers! The recommended
state backend for production settings is the RocksDB backend (see
[production-readiness
docs](https://c
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942407#comment-15942407
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942398#comment-15942398
]
ASF GitHub Bot commented on FLINK-5911:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/3433#discussion_r108067501
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/parameter/Parameter.java
---
@@ -0,0 +1,55 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942344#comment-15942344
]
Greg Hogan commented on FLINK-6115:
---
Java 8 has {{Optional}} but I'm not seeing support
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942299#comment-15942299
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3607
@sunjincheng121 i will take a look - although the branch was created
friday morning - there should not be any conflicts or anything...
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942298#comment-15942298
]
ASF GitHub Bot commented on FLINK-6073:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3609#discussion_r108062687
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,241 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942297#comment-15942297
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3590
Hi @aljoscha sorry for not being more clear in presenting the benchamrk
/evaluation - i used in-memory state backend (for us the key scenario is to
support high performance so that is why i consider
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3567
Google's style seems sensible since IntelliJ's style cannot be modeled in
Checkstyle, the import listing is folded by default, and developers will need
to load other non-default configuration setti
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942266#comment-15942266
]
ASF GitHub Bot commented on FLINK-6073:
---
Github user shijinkui commented on a diff i
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3609#discussion_r108059835
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,241 @@
+/*
+
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3615
Is there a Jira ticket for this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enable
[
https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942267#comment-15942267
]
ASF GitHub Bot commented on FLINK-6073:
---
Github user shijinkui commented on a diff i
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3609#discussion_r108059875
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,241 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942264#comment-15942264
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on the issu
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3567
@greghogan Now I'm confused. ð
Are you suggesting we use the Google
style or switch to the default IntelliJ style?
---
If your project is set up for it, you can reply to this email and have your
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3567#discussion_r108058013
--- Diff: tools/maven/strict-checkstyle.xml ---
@@ -0,0 +1,550 @@
+
+
+http://www.puppycrawl.com/dtds/configuration_1_3.dtd";>
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942240#comment-15942240
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942238#comment-15942238
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3479
Hehe, thanks! ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942231#comment-15942231
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942230#comment-15942230
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3590
@rtudoran Which state backend did you use? I think this can have a great
impact on performance.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942226#comment-15942226
]
ASF GitHub Bot commented on FLINK-6188:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3616
[FLINK-6188] Correctly handle PARALLELISM_DEFAULT in stream operator
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerat
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-6188:
---
Assignee: Aljoscha Krettek
> Some setParallelism() methods can't cope with default pa
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6188:
Summary: Some setParallelism() methods can't cope with default parallelism
(was: Some setPa
61 matches
Mail list logo
