[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490254#comment-16490254
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on the issue:
Github user cjolif commented on the issue:
https://github.com/apache/flink/pull/6043
> When planning to switch to REST, are we speaking of an implementation
that works directly against Elasticsearch's REST API? Or are we thinking of
using Elasticsearch's RestHighLevelClient?
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490241#comment-16490241
]
ASF GitHub Bot commented on FLINK-9407:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6075
[FLINK-9407] [hdfs connector] Support orc rolling sink writer
## What is the purpose of the change
In production environment, we often write file in orc format. So, this PR
support a
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490212#comment-16490212
]
ASF GitHub Bot commented on FLINK-8985:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5863#discussion_r190788353
--- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh ---
@@ -0,0 +1,196 @@
+#!/usr/bin/env bash
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6072
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6072
Will only merge the Kinesis doc fix, as the classloading docs already has a
substantial fix meanwhile in master.
---
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490200#comment-16490200
]
ASF GitHub Bot commented on FLINK-9429:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6074#discussion_r190786548
--- Diff: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ---
@@ -61,8 +61,9 @@ function verify_result {
rm $TEST_DATA_DIR/output
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6043
One more thing to clarify:
When planning to switch to REST, are we speaking of an implementation that
works directly against Elasticsearch's REST API? Or are we thinking of using
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490198#comment-16490198
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6043
The main reason why the discussion leaned towards the current proposed
change by this PR, was that only Elasticsearch 5.6+ supports REST.
Only working towards a clean-cut module that uses
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490193#comment-16490193
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490187#comment-16490187
]
vinoyang commented on FLINK-9352:
-
[~StephanEwen] delay random is a way to handle this issue. We provide a
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8836:
---
Fix Version/s: (was: 1.4.0)
1.4.3
> Duplicating a
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-8836.
--
Resolution: Fixed
> Duplicating a KryoSerializer does not duplicate registered default
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-8836:
> Duplicating a KryoSerializer does not duplicate registered default serializers
>
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490185#comment-16490185
]
Tzu-Li (Gordon) Tai commented on FLINK-8836:
Reopening to fix incorrect fix version.
1.4.0
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490174#comment-16490174
]
ASF GitHub Bot commented on FLINK-9429:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6074
[FLINK-9429] [test] Fix does not properly terminate with control-C
## What is the purpose of the change
Fix the test does not terminate with control-C.
## Verifying this
[
https://issues.apache.org/jira/browse/FLINK-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490157#comment-16490157
]
ASF GitHub Bot commented on FLINK-1044:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6044
@zentol Thanks for the review.
Make sense to build this `quickstarts.zip` package on Jenkins but the main
concern was test the `.zip` package (included all dependencies) before
uploading it on
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490142#comment-16490142
]
mingleizhang commented on FLINK-9429:
-
I will give a PR to fix this soon.
> Quickstart E2E not
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490026#comment-16490026
]
Shuyi Chen commented on FLINK-9430:
---
The JSON object can be a int, float, double, boolean, array, map or
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-8933.
---
Resolution: Later
> Avoid calling Class#newInstance
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489803#comment-16489803
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5857
I think it's fine to be in the same project.
---
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489735#comment-16489735
]
ASF GitHub Bot commented on FLINK-8744:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5843
For `env.java.opts` we have a `ConfigOption` in the `CoreOptions` class.
They are documented like any other option (and technically they are also usable
like any other option).
---
[
https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489646#comment-16489646
]
ASF GitHub Bot commented on FLINK-3952:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6071#discussion_r190705206
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -247,7 +249,15 @@ public void shutdown(Time timeout) {
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489529#comment-16489529
]
Stephan Ewen commented on FLINK-9352:
-
Okay, I see that this can be a problem.
Would it help to make
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489516#comment-16489516
]
ASF GitHub Bot commented on FLINK-8744:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5843
One could add an int to the annotation, as "priority / position" and sort
by that.
Not sure nice, but could be okay.
I think it was nice for users that the most common options (the
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9088.
---
> Upgrade Nifi connector dependency to 1.6.0
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9286.
---
> Update classloading debugging page
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9088.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via a202d747cbd7c49ecd4f8f01b4007350c4327b94
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9305.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.6.0 via
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489501#comment-16489501
]
ASF GitHub Bot commented on FLINK-9305:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-9286.
-
Resolution: Fixed
Fixed in
- 1.4.3 via 5cc869c353619388c199fb7b13813d24e3b5bcfa and
[
https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489503#comment-16489503
]
ASF GitHub Bot commented on FLINK-9286:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489502#comment-16489502
]
ASF GitHub Bot commented on FLINK-9088:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-9305.
---
> Register flink-s3-fs-hadoop for the s3a:// scheme as well
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5963
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5891
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5948
---
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489409#comment-16489409
]
Tzu-Li (Gordon) Tai commented on FLINK-9349:
[~pnowojski] thanks for the reminder. Yes, I will
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489403#comment-16489403
]
ASF GitHub Bot commented on FLINK-8744:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5843
they _should_ be sorted alphabetically based on the key, but i now see that
this isn't actually the case.
I'm not sure if I can easily add the kind of sorting you're asking for as
that would
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6007
> Just because DOW is in the reserved keywords section doesn't mean that we
support it.
Definitely agree however my point was that the same situation is for DOY,
CENTURY and others...
Now
[
https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489399#comment-16489399
]
ASF GitHub Bot commented on FLINK-8518:
---
Github user snuyanzin commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489387#comment-16489387
]
ASF GitHub Bot commented on FLINK-3952:
---
zentol closed pull request #41: [FLINK-3952] Bump Netty to
[
https://issues.apache.org/jira/browse/FLINK-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489330#comment-16489330
]
ASF GitHub Bot commented on FLINK-9420:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6065
---
[
https://issues.apache.org/jira/browse/FLINK-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9420.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.6.0:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6072
+1, thanks for the fixes @pnowojski.
Will merge this ..
---
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8468:
---
Assignee: (was: Gary Yao)
> Make the connector to take advantage of AMQP features (routing key,
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8468:
---
Assignee: Gary Yao
> Make the connector to take advantage of AMQP features (routing key, exchange
>
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489261#comment-16489261
]
Hequn Cheng commented on FLINK-9422:
Thanks for your explanation. :)
> Dedicated operator for UNION
[
https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-9435:
Comment: was deleted
(was: I think an even more performant way would be a set of Java
[
https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489226#comment-16489226
]
Ted Yu commented on FLINK-8554:
---
We can resolve this JIRA as duplicate of FLINK-9266
> Upgrade AWS SDK
>
[
https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489222#comment-16489222
]
Timo Walther commented on FLINK-9435:
-
I think an even more performant way would be a set of Java
[
https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489218#comment-16489218
]
ASF GitHub Bot commented on FLINK-8554:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5978
@StephanEwen close this or not?
---
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489213#comment-16489213
]
ASF GitHub Bot commented on FLINK-9091:
---
Github user pnowojski commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489214#comment-16489214
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6043
@cjolif I agree, let's do something here.
@tzulitai what do you think about trying to use the switch to REST to make
a clean cut and start a new connector project (without dependency on
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/6073
Ok, I see it now. This pull request's title is just a tad misleading (it
doesn't fix all of the convergence for this module, just some selection of them)
---
Nico Kruber created FLINK-9435:
--
Summary: Remove per-key selection Tuple instantiation via
reflection in KeySelectorUtil#ComparableKeySelector
Key: FLINK-9435
URL: https://issues.apache.org/jira/browse/FLINK-9435
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489191#comment-16489191
]
vinoyang commented on FLINK-9352:
-
[~StephanEwen] can you look at this?
> In Standalone checkpoint
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5963
Merging this...
---
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489182#comment-16489182
]
ASF GitHub Bot commented on FLINK-9305:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489180#comment-16489180
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5954
This looks fine from my side.
Would like to get a +1 from @tillrohrmann before merging this...
---
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489157#comment-16489157
]
ASF GitHub Bot commented on FLINK-8933:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489158#comment-16489158
]
ASF GitHub Bot commented on FLINK-8933:
---
Github user yanghua closed the pull request at:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6016
agree, closing this...
---
Github user yanghua closed the pull request at:
https://github.com/apache/flink/pull/6016
---
[
https://issues.apache.org/jira/browse/FLINK-9434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9434:
---
Labels: test-stability (was: )
> Test instability in YARNSessionCapacitySchedulerITCase#
>
Nico Kruber created FLINK-9434:
--
Summary: Test instability in YARNSessionCapacitySchedulerITCase#
Key: FLINK-9434
URL: https://issues.apache.org/jira/browse/FLINK-9434
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9427.
--
Resolution: Fixed
Fixed via
master: 47dc69970996aa2a57c0dbfde866d3dac6d53001
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-9416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9416.
Resolution: Fixed
Fix Version/s: (was: 1.5.1)
(was: 1.6.0)
[
https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9421.
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
master:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6015
OK, agree, closing this PR~
---
[
https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489140#comment-16489140
]
ASF GitHub Bot commented on FLINK-9421:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489144#comment-16489144
]
ASF GitHub Bot commented on FLINK-8933:
---
Github user yanghua closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489139#comment-16489139
]
ASF GitHub Bot commented on FLINK-9427:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6068
---
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489143#comment-16489143
]
ASF GitHub Bot commented on FLINK-8933:
---
Github user yanghua commented on the issue:
Github user yanghua closed the pull request at:
https://github.com/apache/flink/pull/6015
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6069
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6067
---
[
https://issues.apache.org/jira/browse/FLINK-9416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489141#comment-16489141
]
ASF GitHub Bot commented on FLINK-9416:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489136#comment-16489136
]
ASF GitHub Bot commented on FLINK-9091:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6073
It only fixes the issues discussed in the corresponding JIRA. Dependency
convergence issues with `flink-runtime` are a different topic.
---
[
https://issues.apache.org/jira/browse/FLINK-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-7130.
---
Resolution: Won't Fix
> Remove eventSerializer from NFA
> ---
>
>
Github user dawidwys closed the pull request at:
https://github.com/apache/flink/pull/4610
---
[
https://issues.apache.org/jira/browse/FLINK-7130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489128#comment-16489128
]
ASF GitHub Bot commented on FLINK-7130:
---
Github user dawidwys closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489121#comment-16489121
]
ASF GitHub Bot commented on FLINK-9427:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 299 matches
Mail list logo
