[
https://issues.apache.org/jira/browse/FLINK-9370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9370:
Fix Version/s: (was: 1.5.0)
1.6.0
> Activate distributed cache
[
https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477312#comment-16477312
]
Fabian Hueske commented on FLINK-8918:
--
Hi [~sihuazhou], thanks for this proposal!
I see a few
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477333#comment-16477333
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477330#comment-16477330
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477334#comment-16477334
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477336#comment-16477336
]
ASF GitHub Bot commented on FLINK-8135:
---
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/5985#discussion_r188604472
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/AllowNonRestoredStateQueryParameter.java
---
@@ -42,4 +42,10 @@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188604063
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188603266
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477332#comment-16477332
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477337#comment-16477337
]
ASF GitHub Bot commented on FLINK-8135:
---
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/5985#discussion_r188603431
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188603410
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188604321
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188604517
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/EntryClassQueryParameter.java
---
@@ -28,4 +28,10 @@
public
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477331#comment-16477331
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477335#comment-16477335
]
ASF GitHub Bot commented on FLINK-8135:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477329#comment-16477329
]
ASF GitHub Bot commented on FLINK-8135:
---
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/5985#discussion_r188603310
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5985#discussion_r188603356
--- Diff: flink-core/src/main/java/org/apache/flink/util/StringUtils.java
---
@@ -348,6 +350,21 @@ public static String concatenateWithAnd(@Nullable
String
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477385#comment-16477385
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user kl0u commented on a diff in the pull request:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6020
That is a good question, and I'm not sure...but I think that seems to be...
---
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477409#comment-16477409
]
ASF GitHub Bot commented on FLINK-9373:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477429#comment-16477429
]
Sihua Zhou commented on FLINK-8918:
---
Hi [~fhueske], sorry that I'm definitely not asked you to promise
Piotr Nowojski created FLINK-9386:
-
Summary: Remove netty-router dependency
Key: FLINK-9386
URL: https://issues.apache.org/jira/browse/FLINK-9386
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477818#comment-16477818
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on the issue:
Github user ctamisier commented on the issue:
https://github.com/apache/flink/pull/5964
I pushed the changes about renaming the method to setDefaultKeyspace() and
the message in the exception. The field is still 'keyspace', we dont rename it
to 'defaultKeyspace' right ?
---
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477865#comment-16477865
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477867#comment-16477867
]
ASF GitHub Bot commented on FLINK-9070:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477891#comment-16477891
]
ASF GitHub Bot commented on FLINK-9312:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477682#comment-16477682
]
ASF GitHub Bot commented on FLINK-9384:
---
GitHub user tragicjun opened a pull request:
GitHub user tragicjun opened a pull request:
https://github.com/apache/flink/pull/6026
[FLINK-9384]KafkaAvroTableSource failed to work due to type mismatch
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477783#comment-16477783
]
Aris Koliopoulos commented on FLINK-9043:
-
To be honest I am not sure how Flink should be
Github user ctamisier commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188717750
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -381,6
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477814#comment-16477814
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477860#comment-16477860
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6001
Looks good, thanks, merging this...
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5966
I would move ahead with this PR as follows:
- Separate internal and external SSL config
- Activate SSL client auth for akka, netty, and blob server (pure
internal communication)
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477362#comment-16477362
]
Stephan Ewen edited comment on FLINK-9043 at 5/16/18 5:51 PM:
--
Thank you for
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477362#comment-16477362
]
Stephan Ewen edited comment on FLINK-9043 at 5/16/18 5:51 PM:
--
Thank you for
Github user ctamisier commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188727153
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -381,6
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5979
Could you share some micro-benchmark numbers?
When we change something that we know works well to something new, would be
good to understand what benefits we are talking about.
---
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477362#comment-16477362
]
Stephan Ewen edited comment on FLINK-9043 at 5/16/18 5:50 PM:
--
Thank you for
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477855#comment-16477855
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r188725700
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
[
https://issues.apache.org/jira/browse/FLINK-9379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9379.
-
Resolution: Fixed
Fixed on master with cddb65abe3a7b82ffb3235800903c016fdc38877
and on 1.5 with
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188722661
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -381,6 +393,9
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477840#comment-16477840
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5970
Merging this...
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477879#comment-16477879
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476987#comment-16476987
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user yanghua commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477014#comment-16477014
]
ASF GitHub Bot commented on FLINK-9374:
---
GitHub user fmthoma opened a pull request:
GitHub user yuqi1129 opened a pull request:
https://github.com/apache/flink/pull/6022
[FLINK-9283] Update cluster execution docs
## What is the purpose of the change
This pull request is to fix port error in example about using
`RemoteStreamEnvironment`
##
[
https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477026#comment-16477026
]
ASF GitHub Bot commented on FLINK-9283:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477033#comment-16477033
]
ASF GitHub Bot commented on FLINK-9284:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6013
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477103#comment-16477103
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477104#comment-16477104
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-9376:
---
Description:
Currently, users have access to upgrade state serializers on the restore
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5954
hi @StephanEwen this PR also reviewed by you, yesterday it has a conflicts
with master branch, I have fixed, would you please review it again, thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478358#comment-16478358
]
vinoyang commented on FLINK-9352:
-
and [~till.rohrmann] any idea about this issue?
> In Standalone
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478356#comment-16478356
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user yanghua commented on the issue:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r188786194
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@ -81,7
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478189#comment-16478189
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r188786307
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -110,6 +116,8 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478190#comment-16478190
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9381:
-
Fix Version/s: 1.5.0
> BlobServer data for a job is not getting cleaned up at JM
>
[
https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478440#comment-16478440
]
ASF GitHub Bot commented on FLINK-9182:
---
Github user makeyang commented on the issue:
Github user makeyang closed the pull request at:
https://github.com/apache/flink/pull/6019
---
[
https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478441#comment-16478441
]
ASF GitHub Bot commented on FLINK-9182:
---
Github user makeyang closed the pull request at:
Github user makeyang commented on the issue:
https://github.com/apache/flink/pull/6019
@StefanRRichter & @sihuazhou thanks u guys
---
[
https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7814:
--
Summary: Add BETWEEN and NOT BETWEEN expression to Table API (was: Add
BETWEEN expression to Table API
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478438#comment-16478438
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user tragicjun commented on the issue:
Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6026
Thanks @suez1224 for reviewing. I've committed a new patch as per your
suggestions. As for the unit test, the issue was exposed in my integration
tests which requires a kafka setup, any advice on
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/6027
[FLINK-7814][TableAPI && SQL] Add BETWEEN and NOT BETWEEN expression to
Table API
## What is the purpose of the change
Add BETWEEN expression to Table API
## Brief
[
https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478451#comment-16478451
]
ASF GitHub Bot commented on FLINK-7814:
---
GitHub user Xpray opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478489#comment-16478489
]
ASF GitHub Bot commented on FLINK-9343:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/5996
@tzulitai I would appreciate if you review this.
---
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478522#comment-16478522
]
ASF GitHub Bot commented on FLINK-9070:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5979
@StephanEwen , I had a micro-benchmark, here is the result
```
-> Batch VS Put <
BATCH: end insert - duration:255
PUT: end insert - duration:545
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6020
Have't received any response from RocksDB yet, but I found this example
with using `RocksIterator#stats()`:
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478558#comment-16478558
]
ASF GitHub Bot commented on FLINK-9373:
---
Github user sihuazhou commented on the issue:
201 - 282 of 282 matches
Mail list logo
