[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028352#comment-16028352
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4009
Right, but won't there be any serialization issues? I found a comment like
which made me ask that question:
`// Nested classes are only "public static" for Kryo serialization,
otherwise they'd b
[
https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028361#comment-16028361
]
Chesnay Schepler commented on FLINK-6734:
-
With so few affected classes I would li
[
https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028362#comment-16028362
]
Dawid Wysakowicz commented on FLINK-6734:
-
Ok, but then we would need to expand th
[
https://issues.apache.org/jira/browse/FLINK-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028363#comment-16028363
]
Stefan Richter commented on FLINK-6761:
---
Opened a corresponding issue in the RocksDB
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118939832
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/LocalCollectionOutputFormat.java
---
@@ -33,7 +33,7 @@
import java.util.Map;
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118940089
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java
---
@@ -114,41 +114,41 @@ public O withBroadcastSet(DataSe
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118940280
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java
---
@@ -192,41 +192,41 @@ public O withForwardedFieldsFirst(S
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118941471
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java ---
@@ -141,7 +141,7 @@ public void mapPartition(Iterable values,
Collec
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118940189
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java
---
@@ -114,41 +114,41 @@ public O withBroadcastSet(DataSe
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118940257
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java
---
@@ -117,41 +117,41 @@ public O withBroadcastSet(DataSet d
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028365#comment-16028365
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028368#comment-16028368
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028366#comment-16028366
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028369#comment-16028369
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028367#comment-16028367
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028364#comment-16028364
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4009
eh...the commits just jumped around so i assume you just force pushed? From
this point on please don't.
As for kryo, well you got me there. Frankly i don't know where we use kryo
or something
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028376#comment-16028376
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028378#comment-16028378
]
Chesnay Schepler commented on FLINK-6734:
-
yes, they will have to be expanded.
>
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028379#comment-16028379
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4009
Yes sorry for that, Just wanted to remove the `AvoidStarImport` commit from
in the middle. Any further changes will do with new commits.
---
If your project is set up for it, you can reply to this
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4008
---
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, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028380#comment-16028380
]
ASF GitHub Bot commented on FLINK-6736:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-6736.
-
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
Fixed in 1.4.0: 64ca0fa22ac
[
https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028394#comment-16028394
]
Dawid Wysakowicz commented on FLINK-6734:
-
Ok, so I will close this issue.
> Excl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4000
---
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, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028396#comment-16028396
]
ASF GitHub Bot commented on FLINK-6737:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-6734.
---
Resolution: Not A Problem
> Exclude org.apache.flink.api.java.tuple from checkstyle AvoidStarI
[
https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-6737.
-
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
Fixed in 1.4.0: 391d305848a
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3984
Yes, a generic JsonInputFormat would be a nice addition.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028399#comment-16028399
]
ASF GitHub Bot commented on FLINK-6710:
---
Github user twalthr commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4009
I've noticed some `` tags here and there, could replace those as well.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028401#comment-16028401
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118943716
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -1666,29 +1666,29 @@ public void printToErr() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028402#comment-16028402
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118946288
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/aggregation/UnsupportedAggregationTypeException.java
---
@@ -20,6 +20,9 @@
import org
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118948338
--- Diff:
flink-java/src/test/java/org/apache/flink/api/common/operators/base/ReduceOperatorTest.java
---
@@ -47,6 +47,9 @@
import static org.junit.Asse
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118947281
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/GroupReduceIterator.java
---
@@ -24,6 +24,11 @@
import java.util.Iterator;
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118946203
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/aggregation/SumAggregationFunction.java
---
@@ -26,6 +26,10 @@
import org.apache.flink.type
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118946093
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/aggregation/Aggregations.java
---
@@ -20,6 +20,9 @@
import org.apache.flink.annotatio
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118948292
--- Diff:
flink-java/src/test/java/org/apache/flink/api/common/operators/base/InnerJoinOperatorBaseTest.java
---
@@ -45,6 +45,9 @@
import static org.jun
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118946444
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/FirstReducer.java
---
@@ -23,6 +23,10 @@
import org.apache.flink.api.common.funct
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4009#discussion_r118946760
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/FormattingMapper.java
---
@@ -23,6 +23,10 @@
import org.apache.flink.api.java.io.
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028421#comment-16028421
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028417#comment-16028417
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028419#comment-16028419
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028418#comment-16028418
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028420#comment-16028420
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028416#comment-16028416
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028422#comment-16028422
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028415#comment-16028415
]
ASF GitHub Bot commented on FLINK-6732:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-6753:
---
Assignee: Timo Walther
> Flaky SqlITCase
> ---
>
> Key: FLINK-675
[
https://issues.apache.org/jira/browse/FLINK-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028427#comment-16028427
]
Timo Walther commented on FLINK-6753:
-
I also had this issue once. But it is hard to r
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/4010
[FLINK-6753] [table] Fix flaky SqlITCase due to Janino bug
I hope this fixes the flaky test. Otherwise we have to ask the Janino guys
about this error.
You can merge this pull request into a Git re
Gyula Fora created FLINK-6762:
-
Summary: Cannot rescale externalized incremental checkpoints
Key: FLINK-6762
URL: https://issues.apache.org/jira/browse/FLINK-6762
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028434#comment-16028434
]
ASF GitHub Bot commented on FLINK-6753:
---
GitHub user twalthr opened a pull request:
Till Rohrmann created FLINK-6763:
Summary: Inefficient PojoSerializerConfigSnapshot serialization
format
Key: FLINK-6763
URL: https://issues.apache.org/jira/browse/FLINK-6763
Project: Flink
Till Rohrmann created FLINK-6764:
Summary: Deduplicate stateless TypeSerializers when serializing
composite TypeSerializers
Key: FLINK-6764
URL: https://issues.apache.org/jira/browse/FLINK-6764
Projec
[
https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028449#comment-16028449
]
Stefan Richter commented on FLINK-6762:
---
Officially, we currently do not want to sup
[
https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028449#comment-16028449
]
Stefan Richter edited comment on FLINK-6762 at 5/29/17 3:19 PM:
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028458#comment-16028458
]
radu commented on FLINK-6075:
-
TOP syntax is not supported by Calcite. Basically top is obtain
Till Rohrmann created FLINK-6765:
Summary: PojoSerializer returns wrong ConvertDeserializer when
migration is required
Key: FLINK-6765
URL: https://issues.apache.org/jira/browse/FLINK-6765
Project: Fl
Stefan Richter created FLINK-6766:
-
Summary: Update documentation with async backends and incremental
checkpoints
Key: FLINK-6766
URL: https://issues.apache.org/jira/browse/FLINK-6766
Project: Flink
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4011
[FLINK-6766] Update documentation about async backends and incrementaâ¦
â¦l checkpoints
This PR introduces some documentation about async heap backends and
incremental snapshots wi
[
https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028467#comment-16028467
]
ASF GitHub Bot commented on FLINK-6766:
---
GitHub user StefanRRichter opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028487#comment-16028487
]
Stefan Richter commented on FLINK-6762:
---
FYI, I think we can can ALMOST support this
[
https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028487#comment-16028487
]
Stefan Richter edited comment on FLINK-6762 at 5/29/17 4:02 PM:
[
https://issues.apache.org/jira/browse/FLINK-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028503#comment-16028503
]
sunjincheng commented on FLINK-6753:
Can you tell me what you did to get this exceptio
[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028506#comment-16028506
]
Andrea Spina commented on FLINK-6756:
-
Ok, thank you. I'll provide an implementation o
[
https://issues.apache.org/jira/browse/FLINK-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028629#comment-16028629
]
Chesnay Schepler commented on FLINK-6735:
-
I'm unassigning myself as i couldn't fi
[
https://issues.apache.org/jira/browse/FLINK-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6735:
---
Assignee: (was: Chesnay Schepler)
> Add a checkbox to hide the plan visualizer
>
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt updated FLINK-6767:
Description:
This bug was discussed in [1], and a fix was proposed in [2].
In summary the fix requires replacing li
Matt created FLINK-6767:
---
Summary: Cannot load user class on local environment
Key: FLINK-6767
URL: https://issues.apache.org/jira/browse/FLINK-6767
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt updated FLINK-6767:
Description:
This bug was discussed in [1], and a fix was proposed in [2].
In summary the fix requires replacing li
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt updated FLINK-6767:
Description:
There is a bug in Flink 1.2.1 that results in a "cannot load user class"
exception even when the class
[
https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt updated FLINK-6767:
Description:
There is a bug in Flink 1.2.1 that results in a "cannot load user class"
exception even when the class
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3993
Hi @shaoxuan-wang, the suggestions of @fhueske make sense to me.
---
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 pro
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028649#comment-16028649
]
ASF GitHub Bot commented on FLINK-6725:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-5354:
Assignee: Fabian Hueske
> Split up Table API documentation into multiple pages
> -
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4012
[FLINK-6746] [docs] Updated Table API / SQL docs: Common API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink tableDocs-common
Alt
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4013
[FLINK-6745] [docs] Updated Table API / SQL docs: Overview
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink tableDocs-overview
Alt
[
https://issues.apache.org/jira/browse/FLINK-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028654#comment-16028654
]
ASF GitHub Bot commented on FLINK-6746:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028655#comment-16028655
]
ASF GitHub Bot commented on FLINK-6745:
---
GitHub user fhueske opened a pull request:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3943
@twalthr I have rebased code against master.
Best,
SunJincheng
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028665#comment-16028665
]
ASF GitHub Bot commented on FLINK-6617:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6493:
--
Description:
{code}
&& ((partitionStateSerializer == null && ((Snapshot)
obj).getPartitionStateSerializ
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4014
[FLINK-6763] [core] Make serialization of composite serializer configs more
efficient
This PR affects the serialization formats of configuration snapshots of
composite serializers, most notably th
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028755#comment-16028755
]
ASF GitHub Bot commented on FLINK-6763:
---
GitHub user tzulitai opened a pull request:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
@nragon
I agree. But your use case does it have increments/appends?
---
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 pro
GitHub user vidhu5269 opened a pull request:
https://github.com/apache/flink/pull/4015
[FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka clients version
to 0.10.2.0
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vidhu52
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028768#comment-16028768
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028769#comment-16028769
]
ASF GitHub Bot commented on FLINK-6301:
---
GitHub user vidhu5269 opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rahul Yadav updated FLINK-6301:
---
Fix Version/s: 1.4.0
> Flink KafkaConnector09 leaks memory on reading compressed messages due to a
>
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4015
Hi @vidhu5269, thanks for the PR!
I agree that we should bump the Kafka 0.10 version, for various reasons
(JAAS security feature enhancements, as well as the memory leak you mentioned
in the JIR
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028774#comment-16028774
]
ASF GitHub Bot commented on FLINK-6301:
---
Github user tzulitai commented on the issue
Till Rohrmann created FLINK-6768:
Summary: Quadratic/Inefficient field lookup in
PojoSerializer#ensureCompatibility
Key: FLINK-6768
URL: https://issues.apache.org/jira/browse/FLINK-6768
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028791#comment-16028791
]
ASF GitHub Bot commented on FLINK-6301:
---
Github user vidhu5269 commented on the issu
Github user vidhu5269 commented on the issue:
https://github.com/apache/flink/pull/4015
Hi @tzulitai
Thanx for the quick reply. So far I have only gone through Kafka release
notes for api compatibility check and worked with flink unit/integration tests
to verify that nothing break
101 - 199 of 199 matches
Mail list logo
