[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438223#comment-16438223
]
ASF GitHub Bot commented on FLINK-8910:
---
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/5676#discussion_r181540905
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java ---
@@ -107,4 +131,12 @@ public int getAttemptNumber() {
public
[
https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Lau updated FLINK-9173:
---
Description:
The system prints the exception log as follows:
{code:java}
//代码占位符
09:07:20.755 tysc_log
[
https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Lau updated FLINK-9173:
---
Description:
The system prints the exception log as follows:
{code:java}
//代码占位符
09:07:20.755 tysc_log
[
https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Lau updated FLINK-9173:
---
Description:
The system prints the exception log as follows:
{code:java}
//代码占位符
09:07:20.755 tysc_log
[
https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Lau updated FLINK-9173:
---
Component/s: flink-shaded.git
> RestClient - Received response is abnormal
>
[
https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Lau updated FLINK-9173:
---
Description:
The system prints the exception log as follows:
{code:java}
//代码占位符
09:07:20.755 tysc_log
Bob Lau created FLINK-9173:
--
Summary: RestClient - Received response is abnormal
Key: FLINK-9173
URL: https://issues.apache.org/jira/browse/FLINK-9173
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438151#comment-16438151
]
Rong Rong commented on FLINK-9157:
--
Hi [~dmitry_kober], yes, that would be great! I think for now feel
[
https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9172:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-7594
> Support external catalog factory
Rong Rong created FLINK-9172:
Summary: Support external catalog factory that comes default with
SQL-Client
Key: FLINK-9172
URL: https://issues.apache.org/jira/browse/FLINK-9172
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-9157:
-
Description: Having SQL-Client to support first external catalog: Apache
HCatalog out of the box. (was:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438133#comment-16438133
]
ASF GitHub Bot commented on FLINK-8370:
---
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/5805#discussion_r181534458
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingSubtasksMetricsHandler.java
---
@@ -0,0 +1,129 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438130#comment-16438130
]
ASF GitHub Bot commented on FLINK-8370:
---
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/5805#discussion_r181534395
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/DoubleAccumulator.java
---
@@ -0,0 +1,257 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438129#comment-16438129
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181534220
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -49,15 +54,17 @@
* Starts
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438128#comment-16438128
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181534097
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
---
@@ -196,21 +188,23 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438125#comment-16438125
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181533944
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -117,6 +138,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438119#comment-16438119
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181533175
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
---
@@ -196,21 +188,23 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16438117#comment-16438117
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181532978
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -49,15 +54,17 @@
* Starts
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9157:
--
Summary: Support Apache HCatalog in SQL client (was: Support for commonly
used external catalog)
>
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-1466:
--
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-9171
> Add InputFormat to read HCatalog
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9157:
--
Issue Type: Bug (was: Sub-task)
Parent: (was: FLINK-7594)
> Support for commonly used
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9157:
--
Issue Type: Sub-task (was: Bug)
Parent: FLINK-9171
> Support for commonly used external
[
https://issues.apache.org/jira/browse/FLINK-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-1913:
--
Issue Type: Sub-task (was: Bug)
Parent: FLINK-9171
> Document how to access data in HCatalog
>
[
https://issues.apache.org/jira/browse/FLINK-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9170:
--
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-9171
> HCatolog integration with
Shuyi Chen created FLINK-9171:
-
Summary: Flink HCatolog integration
Key: FLINK-9171
URL: https://issues.apache.org/jira/browse/FLINK-9171
Project: Flink
Issue Type: Task
Reporter:
Shuyi Chen created FLINK-9170:
-
Summary: HCatolog integration with Table/SQL API
Key: FLINK-9170
URL: https://issues.apache.org/jira/browse/FLINK-9170
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-9169:
--
Assignee: Tzu-Li (Gordon) Tai
> NPE when restoring from old savepoint and
[
https://issues.apache.org/jira/browse/FLINK-9103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9103.
--
Resolution: Fixed
Fix Version/s: 1.4.3
1.5.0
Fixed via
master:
[
https://issues.apache.org/jira/browse/FLINK-9103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9103:
Assignee: Edward Rojas
> SSL verification on TaskManager when parallelism > 1
>
[
https://issues.apache.org/jira/browse/FLINK-9103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437853#comment-16437853
]
ASF GitHub Bot commented on FLINK-9103:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5789
---
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1643#comment-1643
]
ASF GitHub Bot commented on FLINK-8872:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5672
---
[
https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8872.
--
Resolution: Fixed
Fixed via
master: fdd1c6ed0fed229612ecde1565d90a06dbe6ff55
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437682#comment-16437682
]
ASF GitHub Bot commented on FLINK-8955:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437679#comment-16437679
]
ASF GitHub Bot commented on FLINK-8955:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437680#comment-16437680
]
ASF GitHub Bot commented on FLINK-8955:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437681#comment-16437681
]
ASF GitHub Bot commented on FLINK-8955:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437683#comment-16437683
]
ASF GitHub Bot commented on FLINK-8955:
---
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/5780#discussion_r181467478
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java
---
@@ -196,21 +188,23 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5780#discussion_r181465966
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -225,6 +247,11 @@ private
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5780#discussion_r181467950
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -117,6 +138,7 @@ public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5780#discussion_r181466728
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -117,6 +138,7 @@ public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5780#discussion_r181468061
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java
---
@@ -49,15 +54,17 @@
*
[
https://issues.apache.org/jira/browse/FLINK-8955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437667#comment-16437667
]
ASF GitHub Bot commented on FLINK-8955:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5780
The `ClassLoaderITCase` fails on Travis. There are also checkstyle
violations:
```
10:04:01.988 [ERROR]
src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java:[62,15]
[
https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437604#comment-16437604
]
Till Rohrmann commented on FLINK-9143:
--
The problem is that we don't necessarily have the cluster
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437601#comment-16437601
]
ASF GitHub Bot commented on FLINK-9168:
---
GitHub user XiaoZYang opened a pull request:
GitHub user XiaoZYang opened a pull request:
https://github.com/apache/flink/pull/5845
[FLINK-9168][flink-connectors]Pulsar Sink connector
## What is the purpose of the change
Provide a [pulsar](https://github.com/apache/incubator-pulsar) sink
connector for flink.
##
Till Rohrmann created FLINK-9169:
Summary: NPE when restoring from old savepoint and state
serializer could not be deserialized
Key: FLINK-9169
URL: https://issues.apache.org/jira/browse/FLINK-9169
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437396#comment-16437396
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181414763
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/DoubleAccumulator.java
---
@@ -0,0 +1,257 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437392#comment-16437392
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437388#comment-16437388
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437391#comment-16437391
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437389#comment-16437389
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437393#comment-16437393
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437390#comment-16437390
]
ASF GitHub Bot commented on FLINK-8370:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181404252
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AbstractAggregatingMetricsHandler.java
---
@@ -0,0 +1,302 @@
+/*
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181411022
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingSubtasksMetricsHandler.java
---
@@ -0,0 +1,129 @@
+/*
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181408771
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingSubtasksMetricsHandler.java
---
@@ -0,0 +1,129 @@
+/*
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181404370
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AbstractAggregatingMetricsHandler.java
---
@@ -0,0 +1,302 @@
+/*
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181401972
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/MetricsAggregationParameter.java
---
@@ -0,0 +1,58 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5805#discussion_r181411248
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingSubtasksMetricsHandler.java
---
@@ -0,0 +1,129 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437261#comment-16437261
]
ASF GitHub Bot commented on FLINK-9165:
---
Github user Bekreth closed the pull request at:
Github user Bekreth closed the pull request at:
https://github.com/apache/flink/pull/5844
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5634
@juhoautio
Your concerns for this fix is quite correct, and is why this PR was closed
in the first place as there are a lot of ill-defined semantics introduced by
this.
Regarding
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437175#comment-16437175
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437030#comment-16437030
]
Zongyang Xiao edited comment on FLINK-9168 at 4/13/18 9:01 AM:
---
Related
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437030#comment-16437030
]
Xiao Zongyang commented on FLINK-9168:
--
Related works will be done by [~si...@apache.org] and
Xiao Zongyang created FLINK-9168:
Summary: Pulsar Sink Connector
Key: FLINK-9168
URL: https://issues.apache.org/jira/browse/FLINK-9168
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16437021#comment-16437021
]
ASF GitHub Bot commented on FLINK-5479:
---
Github user juhoautio commented on the issue:
Github user juhoautio commented on the issue:
https://github.com/apache/flink/pull/5634
@tzulitai did you ever test your code? I tried it and it allowed watermarks
to proceed but apparently too aggressively, as it caused a lot of data loss.
I'm looking for a quick fix for
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436999#comment-16436999
]
ASF GitHub Bot commented on FLINK-6557:
---
Github user zentol closed the pull request at:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/3899
---
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436997#comment-16436997
]
Chesnay Schepler edited comment on FLINK-8867 at 4/13/18 8:22 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436997#comment-16436997
]
Chesnay Schepler commented on FLINK-8867:
-
FLINK-6557 may be relevant as it is also caused by
[
https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436994#comment-16436994
]
ASF GitHub Bot commented on FLINK-9165:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5844
Even then `invoke(Collection)` would never be called. `IN` is always
the type of the `DataStream` the sink is applied on, and it can't be
`Collection` as you would have an infinitely recursive type.
[
https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SUBRAMANYA SURESH updated FLINK-9166:
-
Description:
With a high number of Flink SQL queries (100 of below), the Flink command
88 matches
Mail list logo
