[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488431#comment-16488431
]
Chesnay Schepler edited comment on FLINK-9091 at 5/24/18 5:18 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488431#comment-16488431
]
Chesnay Schepler commented on FLINK-9091:
-
Another option would be to disable the enforcer by
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488417#comment-16488417
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190463723
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java
---
@@ -0,0 +1,235 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488406#comment-16488406
]
ASF GitHub Bot commented on FLINK-8390:
---
Github user suez1224 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488407#comment-16488407
]
ASF GitHub Bot commented on FLINK-8390:
---
Github user suez1224 closed the pull request at:
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5306
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5306
@zentol , you are right, https://issues.apache.org/jira/browse/FLINK-8286
already did the removal.
---
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488360#comment-16488360
]
ASF GitHub Bot commented on FLINK-8790:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5582
Unfortunately, after confirming with RocksDB, the `deleteRange()` is still
an experimental feature, it may have impact on read performance currently(event
thought we could use the ReadOption to
[
https://issues.apache.org/jira/browse/FLINK-9425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488347#comment-16488347
]
ASF GitHub Bot commented on FLINK-9425:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6061
+1, thanks for the compliance updates. LGTM.
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6058
+1, LGTM
Merging this ..
---
[
https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488325#comment-16488325
]
ASF GitHub Bot commented on FLINK-9415:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488314#comment-16488314
]
mingleizhang commented on FLINK-9429:
-
Hi, [~till.rohrmann]. Have you build flink again ? I tested on
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488298#comment-16488298
]
Hequn Cheng edited comment on FLINK-9422 at 5/24/18 1:54 AM:
-
Hi, I agree that
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488298#comment-16488298
]
Hequn Cheng commented on FLINK-9422:
Hi, I agree that we need a dedicated operator. But I think adding
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488225#comment-16488225
]
ASF GitHub Bot commented on FLINK-8985:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5863#discussion_r190433925
--- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh ---
@@ -0,0 +1,155 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-8622:
Fix Version/s: (was: 1.5.0)
> flink-mesos: High memory usage of scheduler + job manager. GC
[
https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488212#comment-16488212
]
vinoyang commented on FLINK-9421:
-
[~till.rohrmann] I have releases the assignee, please go ahead thanks.
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488213#comment-16488213
]
Keda Ruan commented on FLINK-7477:
--
Hey, just curious whether this commit will be merged into 1.5.x
[
https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9421:
---
Assignee: (was: vinoyang)
> RunningJobsRegistry entries are not cleaned up after job termination
[
https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488203#comment-16488203
]
ASF GitHub Bot commented on FLINK-9415:
---
Github user tweise commented on the issue:
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/6058
@tzulitai PTAL
---
[
https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488085#comment-16488085
]
Till Rohrmann commented on FLINK-9421:
--
Sorry [~yanghua], I actually have a fix ready but did not see
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487968#comment-16487968
]
Rong Rong commented on FLINK-9422:
--
+1 on "can apply windowed aggregates on the result". This would make
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487863#comment-16487863
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on a diff in the pull request:
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190364900
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487833#comment-16487833
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on a diff in the pull request:
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190359388
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java
---
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190359413
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487834#comment-16487834
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487832#comment-16487832
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on a diff in the pull request:
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190359344
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487750#comment-16487750
]
ASF GitHub Bot commented on FLINK-9428:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6066#discussion_r190342404
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
---
@@ -93,6 +93,20 @@
// state
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487585#comment-16487585
]
Fabian Hueske commented on FLINK-9422:
--
I think a dedicated operator would be good, esp. because we
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487575#comment-16487575
]
Hequn Cheng commented on FLINK-9422:
Hi [~fhueske] [~RuidongLi] , I am not sure if we need to add a
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487565#comment-16487565
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190311650
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9419.
Resolution: Duplicate
Duplicate of FLINK-8594
> UNION should not be treated as retraction
[
https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487539#comment-16487539
]
Fabian Hueske commented on FLINK-9419:
--
Yes, you are right [~hequn8128]. This is a duplicate of
[
https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487523#comment-16487523
]
Hequn Cheng commented on FLINK-9419:
Hi, [~fhueske], same problem as
[
https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-9419:
--
Assignee: Hequn Cheng
> UNION should not be treated as retraction producing operator
>
[
https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-9429:
---
Assignee: mingleizhang
> Quickstart E2E not working locally
>
[
https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487507#comment-16487507
]
ASF GitHub Bot commented on FLINK-9428:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/6066
[FLINK-9428] [checkpointing] Allow operators to flush data on checkpoint
pre-barrier
## What is the purpose of the change
Some operators maintain some small transient state that may be
[
https://issues.apache.org/jira/browse/FLINK-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487503#comment-16487503
]
ASF GitHub Bot commented on FLINK-9420:
---
GitHub user Xpray opened a pull request:
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/6065
[FLINK-9420][TableAPI & SQL] Add tests for SQL IN sub-query operator in
streaming
## What is the purpose of the change
Add tests for SQL IN sub-query operator in streaming
##
[
https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487499#comment-16487499
]
ASF GitHub Bot commented on FLINK-8518:
---
Github user snuyanzin commented on a diff in the pull
Github user snuyanzin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6007#discussion_r190299515
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -1473,6 +1473,14 @@ class
Till Rohrmann created FLINK-9429:
Summary: Quickstart E2E not working locally
Key: FLINK-9429
URL: https://issues.apache.org/jira/browse/FLINK-9429
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487486#comment-16487486
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190296235
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487481#comment-16487481
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190295347
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487473#comment-16487473
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190294307
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487470#comment-16487470
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190293752
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487469#comment-16487469
]
ASF GitHub Bot commented on FLINK-9384:
---
Github user tragicjun commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487468#comment-16487468
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190293256
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6026
@twalthr Thanks for the comment. I've commited a new version as per your
suggestion. Particularly, I agree that TypeInfomation should always be derived
from the 'avroRecrodClass', but the
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9427:
-
Affects Version/s: 1.6.0
> Cannot download from BlobServer, because the server address is
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487461#comment-16487461
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190290965
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9427:
Assignee: Till Rohrmann
> Cannot download from BlobServer, because the server address is
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487458#comment-16487458
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190289953
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
Stephan Ewen created FLINK-9428:
---
Summary: Allow operators to flush data on checkpoint pre-barrier
Key: FLINK-9428
URL: https://issues.apache.org/jira/browse/FLINK-9428
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487451#comment-16487451
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190288320
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487445#comment-16487445
]
ASF GitHub Bot commented on FLINK-9386:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/6031
> I planned to upgrade netty and drop netty-router in one step of upgrading
flink-shaded-netty. Do you think it should be split somehow?
No, if the ticket for upgrading covers that, we are all good.
[
https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9427:
--
Attachment: failure
> Cannot download from BlobServer, because the server address is unknown.
>
Piotr Nowojski created FLINK-9427:
-
Summary: Cannot download from BlobServer, because the server
address is unknown.
Key: FLINK-9427
URL: https://issues.apache.org/jira/browse/FLINK-9427
Project:
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487438#comment-16487438
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487439#comment-16487439
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190285625
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java
---
@@ -0,0 +1,235 @@
+/*
+ *
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r190279440
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,504 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487436#comment-16487436
]
mingleizhang commented on FLINK-9411:
-
Thanks for your feedback, [~StephanEwen]. What you mean is that
[
https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-9424:
Description:
It seems that the {{BlobClientSslTest}} assumes SSL algorithms that are not
present
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5798
cc @StefanRRichter
---
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487426#comment-16487426
]
ASF GitHub Bot commented on FLINK-7917:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487419#comment-16487419
]
ASF GitHub Bot commented on FLINK-9386:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/6031
Thanks for the review and manual checks! I either addressed your comments
in fixup commit and left comment responses otherwise.
> Do we file a follow up ticket to remove netty-router from
[
https://issues.apache.org/jira/browse/FLINK-9409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-9409:
Summary: Remove flink-avro and flink-json from /opt (was: Missing
assembly-dependencies in
[
https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487397#comment-16487397
]
Ted Yu commented on FLINK-9340:
---
Here is my env:
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option
[
https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487382#comment-16487382
]
ASF GitHub Bot commented on FLINK-9386:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/6031#discussion_r190274800
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/MethodlessRouter.java
---
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487381#comment-16487381
]
ASF GitHub Bot commented on FLINK-9386:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9337.
-
Resolution: Done
Fix Version/s: 1.6.0
> Implement AvroDeserializationSchema
>
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/6031#discussion_r190274982
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RouterHandler.java
---
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9338.
-
Resolution: Done
Fix Version/s: 1.6.0
> Implement
[
https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487379#comment-16487379
]
ASF GitHub Bot commented on FLINK-9386:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487378#comment-16487378
]
ASF GitHub Bot commented on FLINK-9258:
---
Github user StefanRRichter commented on the issue:
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6031#discussion_r190273990
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RouterHandler.java
---
@@ -0,0 +1,109 @@
+/*
+ * Licensed to
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5959
LGTM ð
---
1 - 100 of 326 matches
Mail list logo