[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457915#comment-16457915
]
ASF GitHub Bot commented on FLINK-9181:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5913#discussion_r184872369
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: tr
[
https://issues.apache.org/jira/browse/FLINK-9272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457827#comment-16457827
]
Elias Levy commented on FLINK-9272:
---
I tried to find out before opening the issue, but I
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457821#comment-16457821
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457820#comment-16457820
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5940#discussion_r184866337
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonAggregate.scala
---
@@ -49,11 +49,16 @@ trait CommonAggregate
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5940#discussion_r184866214
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalAggregate.scala
---
@@ -82,7 +82,7 @@ private cl
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Moser updated FLINK-9266:
Priority: Minor (was: Trivial)
> Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis desc
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Moser updated FLINK-9266:
Affects Version/s: 1.4.2
> Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe
>
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Moser updated FLINK-9266:
Labels: pull-request-available usability (was: pull-request-available)
> Upgrade AWS Kinesis Client
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Moser updated FLINK-9266:
Labels: pull-request-available (was: )
> Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kine
[
https://issues.apache.org/jira/browse/FLINK-9272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457778#comment-16457778
]
Chesnay Schepler commented on FLINK-9272:
-
Do you know what the actual difference
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457730#comment-16457730
]
ASF GitHub Bot commented on FLINK-9181:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457733#comment-16457733
]
ASF GitHub Bot commented on FLINK-9181:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457731#comment-16457731
]
ASF GitHub Bot commented on FLINK-9181:
---
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/5913#discussion_r184861354
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457734#comment-16457734
]
ASF GitHub Bot commented on FLINK-9181:
---
Github user walterddr commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457732#comment-16457732
]
ASF GitHub Bot commented on FLINK-9181:
---
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/5913#discussion_r184860963
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5913#discussion_r184861107
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
[
https://issues.apache.org/jira/browse/FLINK-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457735#comment-16457735
]
ASF GitHub Bot commented on FLINK-9181:
---
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/5913#discussion_r184860924
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,538 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5913#discussion_r184860868
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,538 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5913#discussion_r184860810
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
+is_beta: t
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457695#comment-16457695
]
ASF GitHub Bot commented on FLINK-9270:
---
Github user bowenli86 closed the pull reque
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/5937
---
Elias Levy created FLINK-9272:
-
Summary: DataDog API "counter" metric type is deprecated
Key: FLINK-9272
URL: https://issues.apache.org/jira/browse/FLINK-9272
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457685#comment-16457685
]
Rong Rong commented on FLINK-7144:
--
FLINK-8689 has been merged and FLINK-8690 is on the w
[
https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7144:
Assignee: Rong Rong
> Optimize multiple LogicalAggregate into one
> ---
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457679#comment-16457679
]
Rong Rong commented on FLINK-8690:
--
Thanks for the suggestion [~fhueske]. I think this is
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457676#comment-16457676
]
ASF GitHub Bot commented on FLINK-8690:
---
GitHub user walterddr opened a pull request
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/5940
[FLINK-8690][table]Support DistinctAgg on DataStream
## What is the purpose of the change
* Allow FlinkLogicalAggregate to support distinct aggregations on
DataStream, while keeping DataS
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457672#comment-16457672
]
Narayanan Arunachalam commented on FLINK-9268:
--
Looks like I can't control us
Github user W4anD0eR96 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5924#discussion_r184857746
--- Diff: README.md ---
@@ -67,10 +67,10 @@ counts.writeAsCsv(outputPath)
Prerequisites for building Flink:
-* Unix-like environment (
[
https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457648#comment-16457648
]
Stephan Ewen commented on FLINK-9233:
-
Let's try upgrading for the {{master}} branch (
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5924#discussion_r184856717
--- Diff: README.md ---
@@ -67,10 +67,10 @@ counts.writeAsCsv(outputPath)
Prerequisites for building Flink:
-* Unix-like environment
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457643#comment-16457643
]
Sergey Nuyanzin commented on FLINK-8255:
Hello [~twalthr]
Could I pick this issue
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457641#comment-16457641
]
Narayanan Arunachalam commented on FLINK-9268:
--
One possibility is that upon
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Narayanan Arunachalam updated FLINK-9268:
-
Affects Version/s: 1.4.2
> RockDB errors from WindowOperator
> ---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457600#comment-16457600
]
Fred Teunissen commented on FLINK-8500:
---
I've created a [pull request|https://github
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457587#comment-16457587
]
ASF GitHub Bot commented on FLINK-8500:
---
GitHub user FredTing opened a pull request:
GitHub user FredTing opened a pull request:
https://github.com/apache/flink/pull/5939
[FLINK-8500] [Kafka Connector] Get the timestamp of the Kafka message from
kafka consumer
## What is the purpose of the change
This pull request make the Kafka timestamp and timestampType
Martin Grigorov created FLINK-9271:
--
Summary: flink-1.4.2-bin-scala_2.11.tgz is not in gzip format
Key: FLINK-9271
URL: https://issues.apache.org/jira/browse/FLINK-9271
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457539#comment-16457539
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5934
I am also a bit torn. Sometimes I am thinking we might just have a pool
with as many serializer copies as se can have concurrent checkpoints +
savepoints. But then again, it is borderline to p
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457528#comment-16457528
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5934
About the serializer duplication problem, I think you are right,
duplicating a serialize is not always super cheap, so I think maybe the best
tradeoff is to not duplicate the serializer to save the
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457526#comment-16457526
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on the issu
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5934
Hi @StefanRRichter sorry for the unclearly description here. What this PR
trying to fix is the mainly relate to the below code which run async:
```java
for (Map.Entry> kvState :
stateTables
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457525#comment-16457525
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5934
Hi, can you give some more detail about the actual problem you are trying
to fix here? To me it looks like duplicating the serializer only for the meta
data should not be required, because the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5937
@bowenli86 I already wanted to do this for some time but unfortunately we
currently cannot upgrade RocksDB to any higher version than what is used in
master. It seems like there is again a per
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457520#comment-16457520
]
ASF GitHub Bot commented on FLINK-9270:
---
Github user StefanRRichter commented on the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5938#discussion_r184848405
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java ---
@@ -265,6 +264,20 @@ public void waitForClusterToBeReady() {
[
https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457513#comment-16457513
]
ASF GitHub Bot commented on FLINK-9196:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457510#comment-16457510
]
ASF GitHub Bot commented on FLINK-9196:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457511#comment-16457511
]
ASF GitHub Bot commented on FLINK-9196:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5938#discussion_r184848340
--- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java ---
@@ -18,227 +18,35 @@
package org.apache.flink.yarn;
-import org.a
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5938#discussion_r184848354
--- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java ---
@@ -18,227 +18,35 @@
package org.apache.flink.yarn;
-import org.a
[
https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457508#comment-16457508
]
ASF GitHub Bot commented on FLINK-9196:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5938
[FLINK-9196][flip6, yarn] Cleanup application files when deregistering YARN
AM
## What is the purpose of the change
*Ensure that YARN application files are removed if cluster is shutdown.*
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457505#comment-16457505
]
Stefan Richter commented on FLINK-9268:
---
This is a known issue with RocksDB, see
[h
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457476#comment-16457476
]
Tzu-Li (Gordon) Tai commented on FLINK-8715:
Merged.
1.6.0: 07aa2d469e34884d7
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8715.
Resolution: Fixed
> RocksDB does not propagate reconfiguration of serializer to the
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457473#comment-16457473
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457474#comment-16457474
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5885
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5885
Thanks for the reviews @bowenli86 @StefanRRichter! I've merged this.
---
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457468#comment-16457468
]
ASF GitHub Bot commented on FLINK-8715:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184846476
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
---
@@ -190,4 +1
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-9270:
Description:
Upgrade RocksDB to 5.11.3 to take latest bug fixes
Besides, I found that unit tests annotated
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457453#comment-16457453
]
ASF GitHub Bot commented on FLINK-9270:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5937
[FLINK-9270] Upgrade RocksDB to 5.11.3, and resolve concurrent test
invocation problem of @RetryOnFailure
## What is the purpose of the change
- Upgrade RocksDB to 5.11.3 to take latest b
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-9270:
Description:
Upgrade RocksDB to 5.11.3
Besides, I found that unit tests annotated with {{@RetryOnFailure}}
Bowen Li created FLINK-9270:
---
Summary: Upgrade RocksDB to 5.11.3, and resolve concurrent test
invocation problem of @RetryOnFailure
Key: FLINK-9270
URL: https://issues.apache.org/jira/browse/FLINK-9270
Proj
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16457446#comment-16457446
]
Sihua Zhou commented on FLINK-9268:
---
Hi [~narayaruna] which version are you using?
> Ro
76 matches
Mail list logo
