[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427909#comment-16427909
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5488
I put this upgrade dependency tree here for a reference.
```[INFO] -< org.apache.flink:flink-hbase_2.11
>--
[INFO] Building flink-hbase 1.6-SNAPSHOT
[
https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427873#comment-16427873
]
ASF GitHub Bot commented on FLINK-9068:
---
GitHub user shankarganesh1234 opened a pull request:
GitHub user shankarganesh1234 opened a pull request:
https://github.com/apache/flink/pull/5824
[FLINK-9068][docs] Fix for removing extra '' tag
## What is the purpose of the change
Removing an unclosed paragraph tag
## Brief change log
Closed the paragraph tags
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8335:
Summary: Upgrade hbase connector dependency to 1.4.3 (was: Upgrade hbase
connector dependency to
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427834#comment-16427834
]
mingleizhang commented on FLINK-8335:
-
Thanks [~yuzhih...@gmail.com]. I will apply 1.4.3 this to here
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8335:
---
Assignee: mingleizhang
> Upgrade hbase connector dependency to 1.4.1
>
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427664#comment-16427664
]
Ted Yu commented on FLINK-8037:
---
Please rebase PR.
> Missing cast in integer arithmetic in
>
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427636#comment-16427636
]
Ted Yu edited comment on FLINK-8335 at 4/5/18 10:05 PM:
Actually 1.4.3 has been
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427636#comment-16427636
]
Ted Yu commented on FLINK-8335:
---
+1 on upgrading to 1.4.2
> Upgrade hbase connector dependency to 1.4.1
>
[
https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9048:
--
Description:
As of commit e0bc37bef69f5376d03214578e9b95816add661b, I got the following :
{code}
[
https://issues.apache.org/jira/browse/FLINK-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-9135:
-
Assignee: Shuyi Chen
> Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed
>
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427293#comment-16427293
]
Narayanan Arunachalam commented on FLINK-9138:
--
[~glaksh100] are you considering the PR for
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427291#comment-16427291
]
Lakshmi Rao commented on FLINK-9138:
Agreed that event time is not applicable here. Yes, that's right,
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427287#comment-16427287
]
Narayanan Arunachalam commented on FLINK-9138:
--
This looks good. I suppose the event time is
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427254#comment-16427254
]
Lakshmi Rao commented on FLINK-9138:
[~narayaruna] [~fhueske] do you have thoughts on how to
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427227#comment-16427227
]
Narayanan Arunachalam commented on FLINK-9138:
--
Thanks [~glaksh100]
> Enhance BucketingSink
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427224#comment-16427224
]
Fabian Hueske commented on FLINK-9138:
--
Thank you [~glaksh100]!
> Enhance BucketingSink to also
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427220#comment-16427220
]
Lakshmi Rao commented on FLINK-9138:
Hi [~fhueske], I've marked FLINK-9118 as resolved (and duplicated
[
https://issues.apache.org/jira/browse/FLINK-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao resolved FLINK-9118.
Resolution: Duplicate
> Support a time based rollover of part file in Bucketing Sink
>
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427208#comment-16427208
]
Fabian Hueske commented on FLINK-9138:
--
Hi [~narayaruna] and [~glaksh100], can you check if you are
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427186#comment-16427186
]
Lakshmi Rao commented on FLINK-9138:
I had a similar request here:
[
https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427104#comment-16427104
]
Fabian Hueske commented on FLINK-9055:
--
TBH, I'm not familiar with the details of the job submission
[
https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9120.
Resolution: Invalid
> Task Manager Fault Tolerance issue
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427042#comment-16427042
]
Till Rohrmann commented on FLINK-9120:
--
I think we can close the issue because the behaviour is
[
https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427032#comment-16427032
]
Sihua Zhou commented on FLINK-9055:
---
Hi [~fhueske], thanks for your reply, I was thinking that changing
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427021#comment-16427021
]
ASF GitHub Bot commented on FLINK-9008:
---
GitHub user zhangminglei opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427022#comment-16427022
]
ASF GitHub Bot commented on FLINK-8699:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5705
Hi, @StefanRRichter thanks a lot.
---
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5823
[FLINK-9008] [e2e] Implements quickstarts end to end test
## What is the purpose of the change
Add an end-to-end test which verifies Flink's quickstarts.
## Brief change log
1.
[
https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427012#comment-16427012
]
ASF GitHub Bot commented on FLINK-8699:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5705
Thanks for the fixes. LGTM ð Will merge this. Sorry that this took so
long.
---
[
https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426937#comment-16426937
]
Julio Biason commented on FLINK-9141:
-
Just a note: We got a problem with split/side outputs too, but
Nico Kruber created FLINK-9142:
--
Summary: Lower the minimum number of buffers for incoming channels
to 1
Key: FLINK-9142
URL: https://issues.apache.org/jira/browse/FLINK-9142
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9087:
---
Component/s: Network
> Return value of broadcastEvent should be closed in
>
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9087:
---
Affects Version/s: 1.6.0
1.5.0
> Return value of broadcastEvent should be
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5672
ok, after fixing one typo, this should pass Travis now
---
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426911#comment-16426911
]
ASF GitHub Bot commented on FLINK-8872:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426882#comment-16426882
]
ASF GitHub Bot commented on FLINK-9087:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426883#comment-16426883
]
ASF GitHub Bot commented on FLINK-9087:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5802#discussion_r179453256
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterTest.java
---
@@ -309,8 +309,6 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5802#discussion_r179451610
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -164,7 +164,7 @@ public BufferConsumer
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426834#comment-16426834
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on the issue:
Github user pduveau commented on the issue:
https://github.com/apache/flink/pull/5410
Hi, Is there anyone to check this PR ? We have interest in getting an
official version including this.
---
[
https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426830#comment-16426830
]
ASF GitHub Bot commented on FLINK-8556:
---
Github user pduveau commented on the issue:
Github user pduveau commented on the issue:
https://github.com/apache/flink/pull/5411
Hi @tzulitai, Were you able to get time to check this PR ? We have interest
in an official version including this.
---
[
https://issues.apache.org/jira/browse/FLINK-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8742:
---
Assignee: Chesnay Schepler (was: Tuo Wang)
> Move ConfigDocsGenerator annotation to
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5822
[FLINK-8743][docs] Allow overriding documented default
Based on #5821.
## What is the purpose of the change
This PR adds an annotation to override the documented default.
[
https://issues.apache.org/jira/browse/FLINK-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426744#comment-16426744
]
ASF GitHub Bot commented on FLINK-8743:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426739#comment-16426739
]
ASF GitHub Bot commented on FLINK-8742:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5821
[FLINK-8742][docs] Move docs generator annotations to flink-annotations
## What is the purpose of the change
This PR moves the docs generator annotations to flink-docs, for
consolidation
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5818
---
[
https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426664#comment-16426664
]
ASF GitHub Bot commented on FLINK-8835:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5808
Thanks @zentol for review. ð
---
[
https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426651#comment-16426651
]
ASF GitHub Bot commented on FLINK-8961:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5730
@tillrohrmann I've rebased and update the PR.
I've added a `getClientConfiguration()` to the `MiniClusterResource`, and
converted the MiniCluster used in the test to the
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5818
Thanks for the fix @mayyamus!
Merging
---
[
https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9141:
Description:
Calling both {{getSideOutput()}} and {{split()}} on one DataStream causes a
[
https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9141:
Description:
Calling both {{getSideOutput()}} and {{split()}} on one DataStream causes a
Chesnay Schepler created FLINK-9141:
---
Summary: Calling getSideOutput() and split() on one DataStream
causes NPE
Key: FLINK-9141
URL: https://issues.apache.org/jira/browse/FLINK-9141
Project: Flink
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5820
[hotfix] removed unused scala imports
## What is the purpose of the change
removed unused scala imports
## Brief change log
removed unused scala imports
##
[
https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426596#comment-16426596
]
Fabian Hueske commented on FLINK-9056:
--
I assume that the following happens:
The client job
[
https://issues.apache.org/jira/browse/FLINK-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426590#comment-16426590
]
ASF GitHub Bot commented on FLINK-9140:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5819
[FLINK-9140] [Build System] [scalastyle] simplify scalastyle configurations
## What is the purpose of the change
Simplifying `` to ``
## Brief change log
Simplifying ``
Bowen Li created FLINK-9140:
---
Summary: simplify scalastyle configurations
Key: FLINK-9140
URL: https://issues.apache.org/jira/browse/FLINK-9140
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426548#comment-16426548
]
yuqi commented on FLINK-9056:
-
[~fhueske] Thank you for your reply, I will first reproduce it and try to
[
https://issues.apache.org/jira/browse/FLINK-8514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-8514.
---
Resolution: Won't Fix
> move flink-connector-wikiedits to Apache Bahir
>
[
https://issues.apache.org/jira/browse/FLINK-8188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li resolved FLINK-8188.
-
Resolution: Fixed
> Clean up flink-contrib
> --
>
> Key: FLINK-8188
>
[
https://issues.apache.org/jira/browse/FLINK-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7566.
---
Resolution: Won't Fix
> if there's only one checkpointing metadata file in , `flink run -s
> ` should
[
https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8837:
Affects Version/s: 1.5.0
> add @Experimental annotation and properly annotate some classes
>
[
https://issues.apache.org/jira/browse/FLINK-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426530#comment-16426530
]
ASF GitHub Bot commented on FLINK-9127:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5810
The original logging is correct - filesystem state backend is actually
memory state backend + filesystem checkpointing. No need to change the logging.
---
72 matches
Mail list logo
