Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5621
---
[
https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xu Zhang updated FLINK-8862:
Attachment: FLINK-8862-DesignDoc.pdf
> Support HBase snapshot read
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-8517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386129#comment-16386129
]
ASF GitHub Bot commented on FLINK-8517:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xu Zhang updated FLINK-8862:
Attachment: FLINK-8862-Design-Class-Diagram.png
> Support HBase snapshot read
> ---
Timo Walther created FLINK-8863:
---
Summary: Add user-defined function support in SQL Client
Key: FLINK-8863
URL: https://issues.apache.org/jira/browse/FLINK-8863
Project: Flink
Issue Type: Sub-t
Timo Walther created FLINK-8864:
---
Summary: Add CLI query history
Key: FLINK-8864
URL: https://issues.apache.org/jira/browse/FLINK-8864
Project: Flink
Issue Type: Sub-task
Components:
GitHub user neoremind opened a pull request:
https://github.com/apache/flink/pull/5639
[FLINK-8862] [HBase] Support HBase snapshot read
## What is the purpose of the change
*Flink-hbase connector only supports reading/scanning HBase over region
server scanner, there is also
[
https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386135#comment-16386135
]
ASF GitHub Bot commented on FLINK-8862:
---
GitHub user neoremind opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8864:
Summary: Add CLI query history in SQL Client (was: Add CLI query history)
> Add CLI query history i
Timo Walther created FLINK-8865:
---
Summary: Add CLI query code completion in SQL Client
Key: FLINK-8865
URL: https://issues.apache.org/jira/browse/FLINK-8865
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8860:
Priority: Blocker (was: Critical)
> SlotManager spamming log files
> --
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8858:
Summary: Add support for INSERT INTO in SQL Client (was: SQL Client to
submit long running query in
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386138#comment-16386138
]
Aljoscha Krettek commented on FLINK-7756:
-
[~shashank734] Yes, because that should
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8858:
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-7594
> Add support for INSERT INTO in
Timo Walther created FLINK-8866:
---
Summary: Create unified interfaces to configure and instatiate
TableSinks
Key: FLINK-8866
URL: https://issues.apache.org/jira/browse/FLINK-8866
Project: Flink
Shashank Agarwal created FLINK-8867:
---
Summary: Rocksdb checkpointing failing with fs.default-scheme:
hdfs:// config
Key: FLINK-8867
URL: https://issues.apache.org/jira/browse/FLINK-8867
Project: Fli
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5640
[FLINK-8839] [sql-client] Fix table source factory discovery
## What is the purpose of the change
This PR fixes the table source factory discovery by adding dependencies to
the classloader.
[
https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386152#comment-16386152
]
ASF GitHub Bot commented on FLINK-8839:
---
GitHub user twalthr opened a pull request:
Ruidong Li created FLINK-8868:
-
Summary: Support Table Function as Table
Key: FLINK-8868
URL: https://issues.apache.org/jira/browse/FLINK-8868
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386197#comment-16386197
]
Aljoscha Krettek commented on FLINK-8807:
-
Fixed on release-1.5 in
f8681a9d7732f6f
aitozi created FLINK-8869:
-
Summary: Kafka restore from checkpoint without react to the new
add partition to kafka server
Key: FLINK-8869
URL: https://issues.apache.org/jira/browse/FLINK-8869
Project: Flink
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/5623
---
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5623
Thanks for the comments! I'll incorporate them and merge.
---
[
https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386253#comment-16386253
]
ASF GitHub Bot commented on FLINK-8807:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386252#comment-16386252
]
ASF GitHub Bot commented on FLINK-8807:
---
Github user aljoscha commented on the issue
Florian Schmidt created FLINK-8870:
--
Summary: End-to-end tests wrongly pass if md5sum is not installed
Key: FLINK-8870
URL: https://issues.apache.org/jira/browse/FLINK-8870
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386260#comment-16386260
]
Aljoscha Krettek commented on FLINK-8807:
-
Fixed on release-1.4 in
64adf4bcfa38704
[
https://issues.apache.org/jira/browse/FLINK-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt closed FLINK-8870.
--
Resolution: Invalid
Behaves as expected, I just misinterpreted the output
> End-to-end tests wr
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5601
S3 is actually strongly consistent when reading newly created objects, just
not in listing or renaming objects (files).
The test seems to actually use reads of full paths, so wondering wh
[
https://issues.apache.org/jira/browse/FLINK-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386341#comment-16386341
]
ASF GitHub Bot commented on FLINK-8818:
---
Github user StephanEwen commented on the is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5627
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5630
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5590
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5633
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5592
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5607
---
[
https://issues.apache.org/jira/browse/FLINK-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386349#comment-16386349
]
ASF GitHub Bot commented on FLINK-7226:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386351#comment-16386351
]
ASF GitHub Bot commented on FLINK-8857:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386350#comment-16386350
]
ASF GitHub Bot commented on FLINK-8849:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-8337.
Resolution: Fixed
Assignee: Nico Kruber
Fix Version/s: (was: 1.4.3)
Should be fi
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386361#comment-16386361
]
ASF GitHub Bot commented on FLINK-8601:
---
GitHub user sihuazhou opened a pull request
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5641
[FLINK-8601][WIP] Introduce PartitionedBloomFilter for Approximate
calculation and other situations of performance optimization
This PR introduce PartitionedBloomFilter which support rescaling and
[
https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8857.
---
Resolution: Fixed
Fix Version/s: 1.4.3
1.5.0
master: 72bba50aa3382db
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5641
For the sake of easy to discussion later..
---
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386365#comment-16386365
]
ASF GitHub Bot commented on FLINK-8601:
---
Github user sihuazhou commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8849.
---
Resolution: Fixed
Assignee: Ken Krugler
Fix Version/s: 1.4.2
Nico Kruber created FLINK-8872:
--
Summary: Yarn detached mode via -yd does not detach
Key: FLINK-8872
URL: https://issues.apache.org/jira/browse/FLINK-8872
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-8871:
-
Summary: Checkpoint cancellation is not propagated to stop
checkpointing threads on the task manager
Key: FLINK-8871
URL: https://issues.apache.org/jira/browse/FLINK-8871
[
https://issues.apache.org/jira/browse/FLINK-8757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8757.
---
Resolution: Duplicate
Fix Version/s: (was: 1.5.0)
> Add MiniClusterResource.getClus
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5601
The main issue was actually described in FLINK-8801:
According to
https://docs.aws.amazon.com/AmazonS3/latest/dev/Introduction.html#ConsistencyModel:
> Amazon S3 provides read-after-wr
[
https://issues.apache.org/jira/browse/FLINK-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386398#comment-16386398
]
ASF GitHub Bot commented on FLINK-8818:
---
Github user NicoK commented on the issue:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5636
---
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386404#comment-16386404
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386414#comment-16386414
]
ASF GitHub Bot commented on FLINK-8091:
---
GitHub user fnk opened a pull request:
GitHub user fnk opened a pull request:
https://github.com/apache/flink/pull/5642
[FLINK-8091] [flink-dist] Support running historyserver in foreground
## Brief change log
*Allow historyserver to run in foreground*
- The scripts "flink-console.sh" and "historyserver.sh"
[
https://issues.apache.org/jira/browse/FLINK-8829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Filichkin updated FLINK-8829:
---
Description:
Hi,
We have running Flink 1.3.2 app in Amazon EMR with YARN. Every week
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5482#discussion_r172303671
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,480 @@
+/*
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5482#discussion_r172302583
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
---
@@ -137,6 +158,151 @@ public EqualTo equalTo
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5482#discussion_r172302147
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
---
@@ -137,6 +158,151 @@ public EqualTo equalTo
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5482#discussion_r172303424
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
---
@@ -137,6 +158,151 @@ public EqualTo equalTo
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5482#discussion_r172306197
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java
---
@@ -0,0 +1,480 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386639#comment-16386639
]
ASF GitHub Bot commented on FLINK-8480:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386640#comment-16386640
]
ASF GitHub Bot commented on FLINK-8480:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386643#comment-16386643
]
ASF GitHub Bot commented on FLINK-8480:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386641#comment-16386641
]
ASF GitHub Bot commented on FLINK-8480:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386642#comment-16386642
]
ASF GitHub Bot commented on FLINK-8480:
---
Github user bowenli86 commented on a diff i
Bowen Li created FLINK-8873:
---
Summary: move unit tests of KeyedStream.scala from
DataStreamTest.scala to KeyedStreamTest.scala
Key: FLINK-8873
URL: https://issues.apache.org/jira/browse/FLINK-8873
Project:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/5634
I think the ideal would be that idleness would occur only for tail reads,
i.e. due to a timeout from `kafkaConsumer.poll(pollTimeout)`.In other
words, an intermittent connection issue would id
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386676#comment-16386676
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user EronWright commented on the iss
Bowen Li created FLINK-8874:
---
Summary: rewrite Flink
docs/dev/stream/operators/process_function.md to recommend using
KeyedProcessFunction
Key: FLINK-8874
URL: https://issues.apache.org/jira/browse/FLINK-8874
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/
@hequn8128 @fhueske Thanks for the feedback. I have updated the diff to
directly use DistinctAccumulator for filtering and modified the
`generateAggregation` API. Please kindly take another look wh
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387014#comment-16387014
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user walterddr commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-8861:
--
Assignee: Xingcan Cui
> Add support for batch queries in SQL Client
> -
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5327#discussion_r172408402
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/NonWindowLeftJoinWithNonEquiPredicates.scala
---
@@ -0,0 +1,228 @
[
https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387275#comment-16387275
]
ASF GitHub Bot commented on FLINK-8428:
---
Github user walterddr commented on a diff i
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5327#discussion_r172408177
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/NonWindowJoin.scala
---
@@ -0,0 +1,271 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387274#comment-16387274
]
ASF GitHub Bot commented on FLINK-8428:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955
]
Ted Yu edited comment on FLINK-7795 at 3/6/18 4:48 AM:
---
error-prone
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5481
@kl0u @aljoscha I added the scala example, and I believe the only build
failure in Travis is irrelevant
---
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387304#comment-16387304
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user bowenli86 commented on the issu
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5440
@tillrohrmann Could you please take a look on this when available ? Thanks
---
[
https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387316#comment-16387316
]
ASF GitHub Bot commented on FLINK-6160:
---
Github user zhangminglei commented on the i
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387335#comment-16387335
]
Sihua Zhou commented on FLINK-8871:
---
[~srichter] Have you already work on this or decide
[
https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8687:
Priority: Major (was: Minor)
> MaterializedCollectStreamResult#retrievePage should take resultLock
[
https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-5621:
---
Assignee: vinoyang
> Flink should provide a mechanism to prevent scheduling tasks on TaskManagers
>
GitHub user qi20088 opened a pull request:
https://github.com/apache/flink/pull/5643
can integrate and support on apache kudu ?
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contributio
[
https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387372#comment-16387372
]
mingleizhang commented on FLINK-8687:
-
[~yuzhih...@gmail.com] Shouldn't we lock {{writ
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5643
Pull Requests are not meant to ask question, please head to the [mailing
lists](http://flink.apache.org/community.html#mailing-lists) or open a
[JIRA](https://issues.apache.org/jira/projects/FLINK).
[
https://issues.apache.org/jira/browse/FLINK-8827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387428#comment-16387428
]
ASF GitHub Bot commented on FLINK-8827:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5614
+1
---
101 - 190 of 190 matches
Mail list logo
