[
https://issues.apache.org/jira/browse/FLINK-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9627:
Affects Version/s: 1.5.0
> Extending 'KafkaJsonTableSource' according to comments will
[
https://issues.apache.org/jira/browse/FLINK-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9627:
Description:
According to the comments what is needed to extend the 'KafkaJsonTableSource'
[
https://issues.apache.org/jira/browse/FLINK-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9627:
Summary: Extending 'KafkaJsonTableSource' according to comments will result
in NPE (was:
Dominik Wosiński created FLINK-9627:
---
Summary: Extending
Key: FLINK-9627
URL: https://issues.apache.org/jira/browse/FLINK-9627
Project: Flink
Issue Type: Bug
Reporter: Dominik
[
https://issues.apache.org/jira/browse/FLINK-9623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518112#comment-16518112
]
ASF GitHub Bot commented on FLINK-9623:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6187
FLINK-9623][runtime] Move zipping logic out of blobservice
## What is the purpose of the change
This PR moves the zipping logic for local user directory artifacts out of
the blobservice.
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518099#comment-16518099
]
xueyu commented on FLINK-6846:
--
I want to submit a PR for this function, would you mind change Assignee to
[
https://issues.apache.org/jira/browse/FLINK-9626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518096#comment-16518096
]
Stefan Richter commented on FLINK-9626:
---
I think in general it can be dangerous to call a {{close}}
[
https://issues.apache.org/jira/browse/FLINK-9626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-9626:
--
Description:
There is a potential resource leak in
Piotr Nowojski created FLINK-9626:
-
Summary: Possible resource leak in FileSystem
Key: FLINK-9626
URL: https://issues.apache.org/jira/browse/FLINK-9626
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9625:
Component/s: Table API & SQL
> Enrich the error information to user
>
[
https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9625:
Description:
When the fields too many, and the types do not match with it would cause the
below
mingleizhang created FLINK-9625:
---
Summary: Enrich the error information to user
Key: FLINK-9625
URL: https://issues.apache.org/jira/browse/FLINK-9625
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Comment: was deleted
(was: I close this since we catch a throwable. stackoverflowerror is
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Description:
When the below sql has too long. Like
case when case when .
when host in
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reopened FLINK-9614:
-
> Improve the error message for Compiler#compile
> --
>
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518060#comment-16518060
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6083
I agree with @dawidwys. We should use
`ConfluentRegistryAvroDeserializationSchema` for the test. It is ok that this
end-to-end test would then only go to Flink `1.6`. The benefit is that we
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518054#comment-16518054
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518055#comment-16518055
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518056#comment-16518056
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518053#comment-16518053
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518058#comment-16518058
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518059#comment-16518059
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518057#comment-16518057
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196740578
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java
---
@@ -39,15 +41,21 @@
public class
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196741065
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,483 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196739603
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java
---
@@ -70,9 +70,14 @@ protected
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196741255
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,483 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196740018
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -70,51 +84,103 @@ public FileUploadHandler(final
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196740407
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196739865
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the
Chesnay Schepler created FLINK-9624:
---
Summary: Move jar/artifact upload logic out of JobGraph
Key: FLINK-9624
URL: https://issues.apache.org/jira/browse/FLINK-9624
Project: Flink
Issue
Chesnay Schepler created FLINK-9623:
---
Summary: Move zipping logic out of blobservice
Key: FLINK-9623
URL: https://issues.apache.org/jira/browse/FLINK-9623
Project: Flink
Issue Type:
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/5857
@zentol, I see.
I just want to update the forked project, but I'm not familiar with the
process.
I'm learning this process, so try to delete then forked again. :smile:
---
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518010#comment-16518010
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user lamber-ken commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518002#comment-16518002
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on the issue:
GitHub user azagrebin opened a pull request:
https://github.com/apache/flink/pull/6186
[FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrappers
## What is the purpose of the change
This PR introduces TTL logic wrappers for state objects.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518001#comment-16518001
]
ASF GitHub Bot commented on FLINK-9514:
---
GitHub user azagrebin opened a pull request:
Github user azagrebin commented on the issue:
https://github.com/apache/flink/pull/6186
cc @StefanRRichter
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5857
If you created another fork and are no longer able to access the previous
one then yes, you will need a new PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517995#comment-16517995
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517982#comment-16517982
]
vinoyang commented on FLINK-9602:
-
hi [~Zentol] should I refer to [1.5 common
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517983#comment-16517983
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6178
@tillrohrmann I believe I've addressed all your comments.
---
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517975#comment-16517975
]
Fabian Hueske commented on FLINK-9565:
--
This seems to be a rather specific issue.
[~yinhua] Are you
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517971#comment-16517971
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-9622:
Priority: Blocker (was: Major)
> DistributedCacheDfsTest failed on travis
>
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196712002
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
[
https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517958#comment-16517958
]
yinhua.dai commented on FLINK-9565:
---
[~fhueske] [~twalthr]
Just wondering whether this could be
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196701452
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517952#comment-16517952
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517950#comment-16517950
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196699736
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -72,10 +82,12 @@ public FileUploadHandler(final Path
[
https://issues.apache.org/jira/browse/FLINK-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9499:
Assignee: Esteban Serrano
> Allow REST API for running a job to provide job configuration
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517946#comment-16517946
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196698434
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -72,10 +82,12 @@ public FileUploadHandler(final Path
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517940#comment-16517940
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196696248
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517935#comment-16517935
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196695325
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -72,10 +82,12 @@ public FileUploadHandler(final Path
[
https://issues.apache.org/jira/browse/FLINK-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9439:
Labels: test-stability (was: )
> DispatcherTest#testJobRecovery dead locks
>
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517933#comment-16517933
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5448
cc @dawidwys the third suggestion has finished, the others has supported
before. can you review this?
---
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517916#comment-16517916
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7881:
Fix Version/s: (was: 1.5.1)
> flink can't deployed on yarn with ha
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196689843
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
[
https://issues.apache.org/jira/browse/FLINK-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517905#comment-16517905
]
Dominik Wosiński edited comment on FLINK-9621 at 6/20/18 8:23 AM:
--
This
[
https://issues.apache.org/jira/browse/FLINK-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517905#comment-16517905
]
Dominik Wosiński commented on FLINK-9621:
-
This will happen for all of the configs that are read
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517896#comment-16517896
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196681937
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,471 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517878#comment-16517878
]
Sihua Zhou commented on FLINK-9622:
---
one more instances:
[
https://issues.apache.org/jira/browse/FLINK-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517874#comment-16517874
]
Sihua Zhou commented on FLINK-9622:
---
cc [~dawidwys]
> DistributedCacheDfsTest failed on travis
>
Sihua Zhou created FLINK-9622:
-
Summary: DistributedCacheDfsTest failed on travis
Key: FLINK-9622
URL: https://issues.apache.org/jira/browse/FLINK-9622
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-8795:
---
Assignee: Dawid Wysakowicz
> Scala shell broken for Flip6
>
Olivier Zembri created FLINK-9621:
-
Summary: Warning when enabling partition discovery
Key: FLINK-9621
URL: https://issues.apache.org/jira/browse/FLINK-9621
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517861#comment-16517861
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517860#comment-16517860
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196667391
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196667307
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517858#comment-16517858
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196667205
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
aitozi created FLINK-9620:
-
Summary: Add an alternative option to choose when deal with
eventtime cep
Key: FLINK-9620
URL: https://issues.apache.org/jira/browse/FLINK-9620
Project: Flink
Issue
101 - 183 of 183 matches
Mail list logo
