[
https://issues.apache.org/jira/browse/FLINK-9778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536589#comment-16536589
]
陈梓立 commented on FLINK-9778:
I will pull a PR a little later, and wonder if we could remove t
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536576#comment-16536576
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
陈梓立 created FLINK-9778:
--
Summary: Remove SlotRequest timeout
Key: FLINK-9778
URL: https://issues.apache.org/jira/browse/FLINK-9778
Project: Flink
Issue Type: Improvement
Components: JobManager
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200892031
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536571#comment-16536571
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200890648
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536563#comment-16536563
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200889912
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536562#comment-16536562
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200889601
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536560#comment-16536560
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200888987
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -54,6 +54,14 @@ under the License.
true
+
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536559#comment-16536559
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200888235
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536531#comment-16536531
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user wgtmac commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536530#comment-16536530
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user wgtmac commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9407:
--
Labels: pull-request-available (was: )
> Support orc rolling sink writer
> ---
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879243
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879624
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200878724
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -54,6 +54,14 @@ under the License.
true
+
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536529#comment-16536529
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user wgtmac commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536532#comment-16536532
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user wgtmac commented on a diff in
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879775
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536525#comment-16536525
]
Zhenqiu Huang commented on FLINK-7243:
--
[~nssalian]
We already have a working vers
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536522#comment-16536522
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536523#comment-16536523
]
ASF GitHub Bot commented on FLINK-8866:
---
GitHub user suez1224 reopened a pull reque
GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/6201
[FLINK-8866][Table API & SQL] Add support for unified table sink
instantiation
**(The sections below can be removed for hotfixes of typos)**
## What is the purpose of the change
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/6201
---
[
https://issues.apache.org/jira/browse/FLINK-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536483#comment-16536483
]
ASF GitHub Bot commented on FLINK-9666:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6230
@tillrohrmann, @zentol, cc.
---
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536479#comment-16536479
]
Neelesh Srinivas Salian commented on FLINK-7243:
What is the status of th
[
https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536478#comment-16536478
]
Neelesh Srinivas Salian edited comment on FLINK-6976 at 7/9/18 1:40 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536478#comment-16536478
]
Neelesh Srinivas Salian edited comment on FLINK-6976 at 7/9/18 1:40 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536478#comment-16536478
]
Neelesh Srinivas Salian commented on FLINK-6976:
[~sunjincheng121], could
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536477#comment-16536477
]
vinoyang commented on FLINK-9777:
-
[~gjy] I fixed issue FLINK-6469, I will take this tick
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9777:
---
Assignee: vinoyang
> YARN: JM and TM Memory must be specified with Units
>
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536455#comment-16536455
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user Aitozi closed the pull request
Github user Aitozi closed the pull request at:
https://github.com/apache/flink/pull/6168
---
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536289#comment-16536289
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user xndai commented on the issue:
Github user xndai commented on the issue:
https://github.com/apache/flink/pull/6281
hi @kl0u , where can I find overall document/design of the bucketing sink
rework (FLINK-9749)? I am a committer of Apache Orc and are interested in
helping Flink-Orc integration.
---
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9777:
Description:
FLINK-6469 breaks backwards compatibility because the JobManager and
TaskManager memory must
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9777:
Description:
FLINK-6469 breaks backwards compatibility because the JobManager and
TaskManager memory shoul
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-9777:
Environment: commit 9f736d1927c62d220a82931c4f5ffa4955910f27
> YARN: JM and TM Memory must be specified wit
Gary Yao created FLINK-9777:
---
Summary: YARN: JM and TM Memory must be specified with Units
Key: FLINK-9777
URL: https://issues.apache.org/jira/browse/FLINK-9777
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536132#comment-16536132
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user dawidwys commented on the issu
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/6168
Hi @Aitozi, yes please close this PR, as I made a spelling mistake while
merging and that's why it wasn't closed automatically. Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-6847:
--
Labels: pull-request-available starter (was: starter)
> Add TIMESTAMPDIFF supported in TableAP
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536070#comment-16536070
]
zhangminglei commented on FLINK-9411:
-
[~triones] Are you still working on this ?
>
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536071#comment-16536071
]
ASF GitHub Bot commented on FLINK-6847:
---
GitHub user xueyumusic opened a pull reque
GitHub user xueyumusic opened a pull request:
https://github.com/apache/flink/pull/6282
[FLINK-6847][FLINK-6813][Table Api & Sql] TimestampDiff table api and sql
support
## What is the purpose of the change
This PR propose to add TimestampDiff sql and table Api.
Sql for
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Labels: (was: patch-available pull-request-available)
> Support orc rolling sink writer
> ---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-5232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536059#comment-16536059
]
vinoyang commented on FLINK-5232:
-
[~till.rohrmann] this issues past a long time, any op
[
https://issues.apache.org/jira/browse/FLINK-5231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-5231:
---
Assignee: vinoyang
> JobManager should exit on "OutOfMemoryError"
>
[
https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536052#comment-16536052
]
ASF GitHub Bot commented on FLINK-9377:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6273
conflicts, please update the PR~
---
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536051#comment-16536051
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user yanghua commented on a diff in
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r200835177
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/Writer.java
---
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Softwar
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6280
@zentol thanks for your suggestion, I have done some refactor and removed
the config item from `RestOptions `
---
[
https://issues.apache.org/jira/browse/FLINK-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536050#comment-16536050
]
ASF GitHub Bot commented on FLINK-9733:
---
Github user yanghua commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536025#comment-16536025
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200833563
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200831458
--- Diff:
flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcFileWriterTest.java
---
@@ -0,0 +1,40 @@
+/**
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536007#comment-16536007
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536005#comment-16536005
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user xndai commented on a diff in t
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200831360
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
69 matches
Mail list logo