[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867405#comment-15867405
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Thanks for the review @rmetzger! The final 2 commits have addressed all
your comments.
I'll also wait for @kl0u to have a look at the changes in
`FlinkKafkaConsumerBaseMigration` before mer
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867368#comment-15867368
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867369#comment-15867369
]
Haohui Mai commented on FLINK-5655:
---
I'm particularly interested in the part that compil
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3266
@fhueske thanks for the review. you are right. I need rebase the code and
update the PR according your comments.
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867362#comment-15867362
]
sunjincheng commented on FLINK-5657:
Hi, [~fhueske] When I splitting FLINK-5657 into
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Component/s: Table API & SQL
> Flink SQL calling Hive User-Defined Functions
> -
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Labels: features (was: )
> Flink SQL calling Hive User-Defined Functions
>
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
GitHub user 501256092 opened a pull request:
https://github.com/apache/flink/pull/3315
Release 1.2.0 rc3
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items int
sunjincheng created FLINK-5804:
--
Summary: Add [non-partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5804
URL: https://issues.apache.org/jira/browse/FLINK-5804
sunjincheng created FLINK-5803:
--
Summary: Add [partitioned] processing time OVER RANGE BETWEEN
UNBOUNDED PRECEDING aggregation to SQL
Key: FLINK-5803
URL: https://issues.apache.org/jira/browse/FLINK-5803
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5657:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-4557)
> Add processing time O
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5802:
Description:
It's important to call hive udf in Flink SQL. A great many udfs were written in
hive s
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867288#comment-15867288
]
Haohui Mai commented on FLINK-5570:
---
We are interested in this feature as well. Just cur
[
https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867205#comment-15867205
]
ASF GitHub Bot commented on FLINK-5793:
---
Github user shuai-xu commented on the issue
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3306
@StephanEwen done, add unittest.
---
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 an
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867194#comment-15867194
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@StephanEwen @tillrohrmann I found a problem that is the packages
`ListTypeInfo` and `ListTypeSerializer` locate. Now `ListTypeInfo` is put in
package "org.apache.flink.api.java.typeutils" and `
Zhuoluo Yang created FLINK-5802:
---
Summary: Flink SQL calling Hive User-Defined Functions
Key: FLINK-5802
URL: https://issues.apache.org/jira/browse/FLINK-5802
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu resolved FLINK-5141.
-
Resolution: Fixed
> Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch
> -
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867155#comment-15867155
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@tillrohrmann Thanks for your review.
Sorry for the reformatted code. It seems that my IDE will automatically
reformat all the files I've edited. I will revert the reformatted code.
--
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867126#comment-15867126
]
Zhijiang Wang commented on FLINK-5799:
--
This fix is useful and the {{HeartbeatManager
[
https://issues.apache.org/jira/browse/FLINK-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867126#comment-15867126
]
Zhijiang Wang edited comment on FLINK-5799 at 2/15/17 2:56 AM:
-
[
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-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867116#comment-15867116
]
Zhijiang Wang commented on FLINK-5798:
--
That is good, and the heartbeat manager compo
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/15/17 2:09 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5792:
---
Summary: Improve “UDF/UDTF" to support constructor with parameter. (was:
Improve “UDF/UDTF" to suppor
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5795:
---
Summary: Improve “UDTF" to support constructor with parameter. (was:
Improve “UDTF" to support with p
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5794:
---
Summary: Improve “UDF" to support constructor with parameter. (was:
Improve “UDF" to support with par
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/3197
@fhueske , thanks for your review. I already modify code based on your
advice and rebase the pr.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15867089#comment-15867089
]
ASF GitHub Bot commented on FLINK-5567:
---
Github user beyond1920 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yelei Feng closed FLINK-5797.
-
Resolution: Not A Bug
> incorrect use of port range selector in BootstrapTool
> --
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:55 PM:
--
Patrick Lucas created FLINK-5801:
Summary: Queryable State from Scala job/client fails with key of
type Long
Key: FLINK-5801
URL: https://issues.apache.org/jira/browse/FLINK-5801
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrick Lucas updated FLINK-5801:
-
Attachment: OrderFulfillmentStateQuery.scala
OrderFulfillment.scala
> Queryable St
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:41 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-5773:
Assignee: Till Rohrmann
> Cannot cast scala.util.Failure to
> org.apache.flink.runtime.mes
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866933#comment-15866933
]
Till Rohrmann commented on FLINK-5773:
--
I think the problem is that we use the wrong
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3314
[FLINK-3679] DeserializationSchema should handle zero or more outputs
This PR adds a new interface, `RichKeyedDeserializationSchema`, to enable
the deserializer to produce zero or more outputs. The m
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866919#comment-15866919
]
ASF GitHub Bot commented on FLINK-3679:
---
GitHub user haohui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 10:17 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 10:15 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2908.
-
Resolution: Implemented
Implemented in d88c938cf04cd438db0f084bd670894d2eadcff2
> Web interface redraw we
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3251
---
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-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866803#comment-15866803
]
ASF GitHub Bot commented on FLINK-2908:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866801#comment-15866801
]
ASF GitHub Bot commented on FLINK-5588:
---
Github user skonto commented on the issue:
Github user skonto commented on the issue:
https://github.com/apache/flink/pull/3313
@thvasilo @tillrohrmann pls review.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866788#comment-15866788
]
ASF GitHub Bot commented on FLINK-5588:
---
GitHub user skonto opened a pull request:
GitHub user skonto opened a pull request:
https://github.com/apache/flink/pull/3313
[FLINK-5588][ml] add a data normalizer to ml library
- Adds a Normalizer.
- Still need to add the Unit Scaler for the features.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866737#comment-15866737
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user haohui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866736#comment-15866736
]
ASF GitHub Bot commented on FLINK-5800:
---
GitHub user StephanEwen opened a pull reque
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3252
Discussed with @fhueske offline. Thanks a lot for the comments. The V4 PR
implements the following:
* Rebased on top of #3101
* `LogicalWindowAggregateRule` implements `RelOptRule` instea
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3312
[FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per
operator
Previously, the factory was created once per checkpoint, and its repeated
initialization logic
(like ensuri
Stephan Ewen created FLINK-5800:
---
Summary: Make sure that the CheckpointStreamFactory is
instantiated once per operator only
Key: FLINK-5800
URL: https://issues.apache.org/jira/browse/FLINK-5800
Project
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866685#comment-15866685
]
Stavros Kontopoulos commented on FLINK-5588:
[~till.rohrmann] Have already imp
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866678#comment-15866678
]
Stephan Ewen commented on FLINK-4813:
-
[~NicoK] Do you want to go ahead and patch this
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866673#comment-15866673
]
Stephan Ewen commented on FLINK-5253:
-
That means we can drop it for all modes that do
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866672#comment-15866672
]
Stephan Ewen commented on FLINK-5253:
-
When the {{flink-conf.yaml}} is anyways generat
[
https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5239.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Old issue, fixed a while back already.
> Properly unpac
[
https://issues.apache.org/jira/browse/FLINK-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-5597:
--
Affects Version/s: 1.3.0
> Improve the LocalClusteringCoefficient documentation
> --
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3311
Let RpcService.scheduleRunnable return a ScheduledFuture
This PR is based #3310.
The returned ScheduledFuture instance allows to cancel a scheduled runnable
and obtain
the delay un
Till Rohrmann created FLINK-5799:
Summary: Let RpcService.scheduleRunnable return ScheduledFuture
Key: FLINK-5799
URL: https://issues.apache.org/jira/browse/FLINK-5799
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866466#comment-15866466
]
Stephan Ewen commented on FLINK-5778:
-
I am not sure about this design. State handle i
[
https://issues.apache.org/jira/browse/FLINK-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866450#comment-15866450
]
ASF GitHub Bot commented on FLINK-5798:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3310
[FLINK-5798] [rpc] Let the RpcService provide a ScheduledExecutorService
This PR adds the getScheduledExecutorService method to the RpcService
interface. So
henceforth all RpcService implem
Till Rohrmann created FLINK-5798:
Summary: Let the RPCService provide a ScheduledExecutorService
Key: FLINK-5798
URL: https://issues.apache.org/jira/browse/FLINK-5798
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-1612.
Resolution: Not A Problem
> Add guidelines to avoid duplicate class names and more JavaDoc for new
[
https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866439#comment-15866439
]
Till Rohrmann commented on FLINK-5239:
--
[~StephanEwen] this is done and can be closed
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866340#comment-15866340
]
Mariusz Wojakowski commented on FLINK-5253:
---
I have 2 questions:
* should we sto
[
https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5070:
---
Component/s: Type Serialization System
Scala API
> Unable to use Scala's BeanProperty
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866135#comment-15866135
]
Nico Kruber commented on FLINK-4813:
for documentation: until the minikdc dependency i
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866096#comment-15866096
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
Thanks Robert!
I'll let the test run again and will merge if everything passes. Thanks
@tonycox and @ramkrish86 for digging into this.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866112#comment-15866112
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2509
I've tested the change locally and with great success. So once my comments
are addressed, the change is good to be merged
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866114#comment-15866114
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866100#comment-15866100
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866101#comment-15866101
]
ASF GitHub Bot commented on FLINK-5277:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3309
[FLINK-5277] add unit tests for ResultPartition#add() in case of failures
This verifies that the given network buffer is recycled as expected and that
no notifiers are called upon failures to add a
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3149
I think its fine to change the JVM settings for the hbase module. Other
modules such as elasticsearch are also doing that.
---
If your project is set up for it, you can reply to this email and have
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
It's not only Java 7. For Hadoop 2.4.1 and Java 7, the builds pass. So it
seems to be a combination of both parameters. Anyway, I think we can configure
the JVM for the tests.
It would be g
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101075570
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode conta
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866051#comment-15866051
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866050#comment-15866050
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101075446
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@ -229,6
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866042#comment-15866042
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101074257
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@ -229,6
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866028#comment-15866028
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101070598
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866025#comment-15866025
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101070139
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
---
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866027#comment-15866027
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a dif
1 - 100 of 280 matches
Mail list logo
