[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552331#comment-16552331
]
Yinan Li commented on FLINK-4319:
-
Thanks for the information, [~till.rohrmann]! Got a few more questions
zhijiang created FLINK-9913:
---
Summary: Improve output serialization only once in RecordWriter
Key: FLINK-9913
URL: https://issues.apache.org/jira/browse/FLINK-9913
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552246#comment-16552246
]
godfrey johnson commented on FLINK-9906:
[^taskmanager.log]
Actually, containers were received,
[
https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552246#comment-16552246
]
godfrey johnson edited comment on FLINK-9906 at 7/23/18 3:31 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552241#comment-16552241
]
ASF GitHub Bot commented on FLINK-9793:
---
Github user linjun007 commented on the issue:
Github user linjun007 commented on the issue:
https://github.com/apache/flink/pull/6296
what error ?
---
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552238#comment-16552238
]
ASF GitHub Bot commented on FLINK-9793:
---
Github user linjun007 commented on the issue:
Github user linjun007 commented on the issue:
https://github.com/apache/flink/pull/6296
what error ?
---
[
https://issues.apache.org/jira/browse/FLINK-9912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9912:
Summary: Release TaskExecutors from SlotPool if all slots have been removed
(was: Release TaskExecutors
[
https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey johnson updated FLINK-9906:
---
Attachment: taskmanager.log
> Flink Job not running with no resource
>
[
https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552217#comment-16552217
]
ASF GitHub Bot commented on FLINK-9875:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6353
agree @StephanEwen , parallelize the core problem, this way we would not
introduce potential concurrent problem of EG, EJV related logic.
---
[
https://issues.apache.org/jira/browse/FLINK-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Riley Li closed FLINK-9882.
---
Resolution: Won't Fix
> A function access can be private in runtime
>
[
https://issues.apache.org/jira/browse/FLINK-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552215#comment-16552215
]
ASF GitHub Bot commented on FLINK-9882:
---
Github user rileyli closed the pull request at:
Github user rileyli closed the pull request at:
https://github.com/apache/flink/pull/6358
---
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552206#comment-16552206
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6103
Hi, @tillrohrmann I found more than one user found this issue and affect
their work. I suggest we can merge this PR as a temporary solution until the
travis turn green.
---
Till Rohrmann created FLINK-9912:
Summary: Release TaskExecutors from SlotPool if all slots have
been removd
Key: FLINK-9912
URL: https://issues.apache.org/jira/browse/FLINK-9912
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552144#comment-16552144
]
ASF GitHub Bot commented on FLINK-9890:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6368
---
[
https://issues.apache.org/jira/browse/FLINK-9890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9890.
--
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9891:
-
Priority: Major (was: Blocker)
> Flink cluster is not shutdown in YARN mode when Flink client
[
https://issues.apache.org/jira/browse/FLINK-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9911:
--
Labels: pull-request-available (was: )
> SlotPool#failAllocation is called outside of main
[
https://issues.apache.org/jira/browse/FLINK-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552139#comment-16552139
]
ASF GitHub Bot commented on FLINK-9911:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6386
[FLINK-9911][JM] Use SlotPoolGateway to call failAllocation
## What is the purpose of the change
Since the SlotPool is an actor, we must use the SlotPoolGateway to interact
with
Till Rohrmann created FLINK-9911:
Summary: SlotPool#failAllocation is called outside of main thread
Key: FLINK-9911
URL: https://issues.apache.org/jira/browse/FLINK-9911
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552138#comment-16552138
]
ASF GitHub Bot commented on FLINK-9910:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9910:
--
Labels: pull-request-available (was: )
> Non-queued scheduling failure sometimes does not
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6385
[FLINK-9910][scheduling] Execution#scheduleForeExecution does not cancel
slot future
## What is the purpose of the change
In order to properly give back an allocated slot to the
[
https://issues.apache.org/jira/browse/FLINK-9909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9909:
-
Labels: pull-request-available (was: )
> Remove cancellation of input futures from
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9900:
-
Priority: Critical (was: Major)
> Failed to testRestoreBehaviourWithFaultyStateHandles
>
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9900:
-
Affects Version/s: 1.6.0
> Failed to testRestoreBehaviourWithFaultyStateHandles
>
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552137#comment-16552137
]
Till Rohrmann commented on FLINK-9900:
--
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9900:
-
Fix Version/s: 1.6.0
> Failed to testRestoreBehaviourWithFaultyStateHandles
>
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552134#comment-16552134
]
Till Rohrmann commented on FLINK-9812:
--
Do we already know why this the test case is failing
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9812:
-
Priority: Critical (was: Major)
> SpanningRecordSerializationTest fails on travis
>
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9812:
-
Fix Version/s: 1.6.0
> SpanningRecordSerializationTest fails on travis
>
[
https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552133#comment-16552133
]
Till Rohrmann commented on FLINK-9812:
--
Another instance:
Till Rohrmann created FLINK-9910:
Summary: Non-queued scheduling failure sometimes does not return
the slot
Key: FLINK-9910
URL: https://issues.apache.org/jira/browse/FLINK-9910
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9048:
--
Description:
As of commit e0bc37bef69f5376d03214578e9b95816add661b, I got the following :
{code}
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6384
Remove conjunct future cancellation
## What is the purpose of the change
If a ConjunctFuture is cancelled, then it won't cancel all of its input
futures automatically. If the users
Till Rohrmann created FLINK-9909:
Summary: Remove cancellation of input futures from ConjunctFutures
Key: FLINK-9909
URL: https://issues.apache.org/jira/browse/FLINK-9909
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9908:
-
Fix Version/s: (was: 1.7.0)
> Inconsistent state of SlotPool after ExecutionGraph
[
https://issues.apache.org/jira/browse/FLINK-9908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9908:
-
Component/s: Distributed Coordination
> Inconsistent state of SlotPool after ExecutionGraph
[
https://issues.apache.org/jira/browse/FLINK-9908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9908:
--
Labels: pull-request-available (was: )
> Inconsistent state of SlotPool after ExecutionGraph
[
https://issues.apache.org/jira/browse/FLINK-9908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552111#comment-16552111
]
ASF GitHub Bot commented on FLINK-9908:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6383
[FLINK-9908][scheduling] Do not cancel individual scheduling future
## What is the purpose of the change
Since the individual scheduling futures contain logic to release the slot
if
Till Rohrmann created FLINK-9908:
Summary: Inconsistent state of SlotPool after ExecutionGraph
cancellation
Key: FLINK-9908
URL: https://issues.apache.org/jira/browse/FLINK-9908
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9834:
--
Assignee: buptljy
> Unable to support scala BasicArrayTypeInfo
>
[
https://issues.apache.org/jira/browse/FLINK-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552053#comment-16552053
]
ASF GitHub Bot commented on FLINK-9907:
---
GitHub user xueyumusic opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9907:
--
Labels: pull-request-available (was: )
> add CRC32 checksum in table Api and sql
>
GitHub user xueyumusic opened a pull request:
https://github.com/apache/flink/pull/6382
[FLINK-9907][Table API & SQL] add CRC32 support
## What is the purpose of the change
This PR adds CRC32 checksum compute in table api and sql.It returns the
cyclic redundancy check value of
xueyu created FLINK-9907:
Summary: add CRC32 checksum in table Api and sql
Key: FLINK-9907
URL: https://issues.apache.org/jira/browse/FLINK-9907
Project: Flink
Issue Type: New Feature
Github user YCjia commented on the issue:
https://github.com/apache/flink/pull/6378
@zentol Thank you for your reminder, I will pay attention in the future.
---
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552036#comment-16552036
]
ASF GitHub Bot commented on FLINK-9236:
---
Github user YCjia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552025#comment-16552025
]
ASF GitHub Bot commented on FLINK-9875:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552024#comment-16552024
]
Till Rohrmann commented on FLINK-4319:
--
Hi [~liyinan926], Flink's Kubernetes support is not yet
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6353
Maybe we can solve this simpler? Avoiding concurrency in the execution
graph creation makes the code simpler and more robust - very desirable for an
already fairly complex construct.
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/8231b62ff42aae53ca3a7b552980838ccab824ab#commitcomment-29792609
In
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroup.java:
In
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552017#comment-16552017
]
Till Rohrmann commented on FLINK-9891:
--
Thanks for reporting the issue [~krasovcheg]. The behaviour
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552010#comment-16552010
]
ASF GitHub Bot commented on FLINK-9185:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5894
---
[
https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9185.
--
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552008#comment-16552008
]
ASF GitHub Bot commented on FLINK-9720:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6357
Hi @liurenjie1024, thanks for opening this PR. The Flink community is
currently preparing the Flink 1.6 release and, thus, it might take a bit longer
for the review to happen. Please bear with
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551959#comment-16551959
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204233444
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551947#comment-16551947
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204232617
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551946#comment-16551946
]
ASF GitHub Bot commented on FLINK-9236:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6378
@zhangminglei @YCjia Please do not push changes for the sole purpose of
re-triggering Travis. We already know that they passed (due to the travis
fork), and realistically there's no way for the
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551939#comment-16551939
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204231919
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551929#comment-16551929
]
ASF GitHub Bot commented on FLINK-6847:
---
Github user hequn8128 commented on a diff in the pull
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6282#discussion_r204230530
--- Diff: docs/dev/table/tableApi.md ---
@@ -4490,6 +4490,16 @@ dateFormat(TIMESTAMP, STRING)
+
+
+
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6282#discussion_r204230536
--- Diff: docs/dev/table/tableApi.md ---
@@ -4490,6 +4490,16 @@ dateFormat(TIMESTAMP, STRING)
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551930#comment-16551930
]
ASF GitHub Bot commented on FLINK-6847:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551927#comment-16551927
]
ASF GitHub Bot commented on FLINK-6847:
---
Github user hequn8128 commented on a diff in the pull
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6282#discussion_r204230539
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -338,3 +341,66 @@ case class
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6282#discussion_r204230534
--- Diff: docs/dev/table/tableApi.md ---
@@ -4490,6 +4490,16 @@ dateFormat(TIMESTAMP, STRING)
+
+
+
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6282#discussion_r204230537
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -338,3 +341,66 @@ case class
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551931#comment-16551931
]
ASF GitHub Bot commented on FLINK-6847:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551928#comment-16551928
]
ASF GitHub Bot commented on FLINK-6847:
---
Github user hequn8128 commented on a diff in the pull
83 matches
Mail list logo
