Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5614
+1
---
[
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/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-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 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-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
>
[
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-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-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
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
---
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
[
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
[
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-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
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-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
> -
[
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
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
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
[
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
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
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:
[
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=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=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
[
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
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 @@
+/*
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_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_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_r172303671
--- 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-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 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-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:
[
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
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5636
---
[
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 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-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
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
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
[
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
[
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
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-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 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-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
[
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-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-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-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
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/5592
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5607
---
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/5630
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5627
---
[
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 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-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
[
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
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=16386252#comment-16386252
]
ASF GitHub Bot commented on FLINK-8807:
---
Github user aljoscha commented on the issue
[
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
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5623
Thanks for the comments! I'll incorporate them and merge.
---
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/5623
---
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
[
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
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-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:
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.
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
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
[
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
[
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:
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-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8860:
Priority: Blocker (was: Critical)
> SlotManager spamming log files
> --
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-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
[
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
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
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:
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
[
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
> ---
[
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
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
> ---
>
>
Xu Zhang created FLINK-8862:
---
Summary: Support HBase snapshot read
Key: FLINK-8862
URL: https://issues.apache.org/jira/browse/FLINK-8862
Project: Flink
Issue Type: Improvement
Components:
Timo Walther created FLINK-8861:
---
Summary: Add support for batch queries in SQL Client
Key: FLINK-8861
URL: https://issues.apache.org/jira/browse/FLINK-8861
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8853:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-7594
> SQL Client cannot emit query results t
[
https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8852:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-7594
> SQL Client does not work with new FLIP
[
https://issues.apache.org/jira/browse/FLINK-8850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8850:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-7594
> SQL Client does not support Event-time
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8686:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-7594
> Improve basic embedded SQL cli
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386109#comment-16386109
]
ASF GitHub Bot commented on FLINK-8274:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5613
@Xpray and @hequn8128 are you fine with merging this PR for now and then
open follow-up issues for more splitting (unboxing, expression, class)?
---
[
https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16386093#comment-16386093
]
ASF GitHub Bot commented on FLINK-6924:
---
GitHub user buptljy opened a pull request:
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5638
[FLINK-6924][table]ADD LOG(X) supported in TableAPI
## What is the purpose of the change
* Add LOG(X) function in TableAPI.
## Brief change log
* Add LOG(X) function in TableAPI.
1 - 100 of 190 matches
Mail list logo
