Razvan created FLINK-9540:
-
Summary: Apache Flink 1.4.2 S3 Hadooplibrary for Hadoop 2.7 is
built for Hadoop 2.8 and fails
Key: FLINK-9540
URL: https://issues.apache.org/jira/browse/FLINK-9540
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503071#comment-16503071
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193357238
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -40,22 +42,63 @@
[
https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503109#comment-16503109
]
ASF GitHub Bot commented on FLINK-9525:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6118
Where in the loading of the factories do you see the error?
My suspicion is still an issue with inverted class loading.
To confirm, can we check the following?
- Are you running
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503160#comment-16503160
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193377245
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -105,7 +153,18 @@
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6079
@twalthr Thanks a lot for the review and merging. I will take a look at the
FLINK-9440 and see if we can do any improvement.
---
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503284#comment-16503284
]
swy commented on FLINK-9506:
[~srichter] Thanks for tips, after implement Rocksdb the performance seems much
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503120#comment-16503120
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503192#comment-16503192
]
ASF GitHub Bot commented on FLINK-8430:
---
Github user hequn8128 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503037#comment-16503037
]
ASF GitHub Bot commented on FLINK-3952:
---
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/6071#discussion_r193345578
--- Diff: pom.xml ---
@@ -300,15 +300,7 @@ under the License.
org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503082#comment-16503082
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193359300
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -83,7 +103,22 @@
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193359253
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -83,7 +103,22 @@
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503081#comment-16503081
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ph.Duveau updated FLINK-9544:
-
Description: The amazon client do not downgrade from CBOR to JSON while
setting env AWS_CBOR_DISABLE to
[
https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu reassigned FLINK-8886:
-
Assignee: Renjie Liu
> Job isolation via scheduling in shared cluster
>
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan updated FLINK-9540:
--
Description:
Download Apache Flink 1.4.2 for Hadoop 2.7 or earlier. Go to opt/ inside
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503077#comment-16503077
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193358805
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -66,12 +79,19 @@
Chesnay Schepler created FLINK-9543:
---
Summary: Expose JobMaster IDs to metric system
Key: FLINK-9543
URL: https://issues.apache.org/jira/browse/FLINK-9543
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan updated FLINK-9540:
--
Description:
Download Apache Flink 1.4.2 for Hadoop 2.7 or earlier. Go to opt/ inside
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5954
@aljoscha @kl0u
---
[
https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503155#comment-16503155
]
Fabian Hueske commented on FLINK-9528:
--
Hi [~hequn8128], can you explain in more detail what you
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503153#comment-16503153
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user yanghua commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r193395032
--- Diff: flink-end-to-end-tests/test-scripts/test_quickstarts.sh ---
@@ -51,12 +59,12 @@ sed -i -e ''"$(($position + 1))"'i\
${flink.version}\
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r193394392
--- Diff: flink-end-to-end-tests/flink-quickstart-test/pom.xml ---
@@ -0,0 +1,98 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6128
[FLINK-9539][build] Integrate flink-shaded 4.0
## What is the purpose of the change
This PR bumps the flink-shaded version to 4.0 . The workarounds for the
faulty jackson shading can be
[
https://issues.apache.org/jira/browse/FLINK-9539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503035#comment-16503035
]
ASF GitHub Bot commented on FLINK-9539:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan updated FLINK-9540:
--
Summary: Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for
Hadoop 2.8 and fails (was: Apache
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503092#comment-16503092
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193361587
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -83,7 +103,22 @@
Chesnay Schepler created FLINK-9542:
---
Summary: ExEnv#registerCachedFile should accept Path
Key: FLINK-9542
URL: https://issues.apache.org/jira/browse/FLINK-9542
Project: Flink
Issue Type:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r193392673
--- Diff: flink-end-to-end-tests/flink-quickstart-test/pom.xml ---
@@ -0,0 +1,98 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503232#comment-16503232
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503233#comment-16503233
]
ASF GitHub Bot commented on FLINK-9451:
---
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/6089#discussion_r193392825
--- Diff: flink-end-to-end-tests/flink-quickstart-test/pom.xml ---
@@ -0,0 +1,98 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503231#comment-16503231
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503234#comment-16503234
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503066#comment-16503066
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193356713
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -40,22 +42,63 @@
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193356675
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -124,7 +159,82 @@
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193356620
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503067#comment-16503067
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503069#comment-16503069
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503090#comment-16503090
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user pduveau commented on a diff in the pull
Github user pduveau commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r193360923
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
---
@@ -83,7 +103,22 @@
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan updated FLINK-9540:
--
Description: ++Download Apache Flink 1.4.2 for Hadoop 2.7 or earlier.
> Apache Flink 1.4.2 S3 Hadooplibrary
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/6082
We treat sequences of values as arrays in SQL and the Table API. There are
no built-in functions to handle lists. So we should return the values as an
array, and hence don't need a List type.
---
Fabian Hueske created FLINK-9541:
Summary: Add robots.txt and sitemap.xml to Flink website
Key: FLINK-9541
URL: https://issues.apache.org/jira/browse/FLINK-9541
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9538:
---
Assignee: vinoyang
> Make KeyedStateFunction an interface
>
>
Ph.Duveau created FLINK-9544:
Summary: Impossible to downgrade kinesis protocole from CBOR to
JSON as required by kinesalite
Key: FLINK-9544
URL: https://issues.apache.org/jira/browse/FLINK-9544
Project:
Chesnay Schepler created FLINK-9539:
---
Summary: Integrate flink-shaded 4.0
Key: FLINK-9539
URL: https://issues.apache.org/jira/browse/FLINK-9539
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Razvan updated FLINK-9540:
--
Description:
Download Apache Flink 1.4.2 for Hadoop 2.7 or earlier. Go to opt/ inside
[
https://issues.apache.org/jira/browse/FLINK-5232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502895#comment-16502895
]
vinoyang commented on FLINK-5232:
-
[~StephanEwen] any opinion? if not, I will try to fix this.
> Add a
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6092
cc @zentol if you have time, can you review this?
---
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502896#comment-16502896
]
ASF GitHub Bot commented on FLINK-9352:
---
Github user yanghua commented on the issue:
Till Rohrmann created FLINK-9537:
Summary: JobManager isolation in session mode
Key: FLINK-9537
URL: https://issues.apache.org/jira/browse/FLINK-9537
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502901#comment-16502901
]
Dawid Wysakowicz commented on FLINK-9533:
-
Hi [~aitozi],
I don't think this is a bug at all,
[
https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502918#comment-16502918
]
Till Rohrmann commented on FLINK-9455:
--
Hi [~sihuazhou], the issue is indeed a bit more involved
[
https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502920#comment-16502920
]
Timo Walther commented on FLINK-9294:
-
The problem why we don't extract {{MapTypeInfo}} is because we
Dawid Wysakowicz created FLINK-9538:
---
Summary: Make KeyedStateFunction an interface
Key: FLINK-9538
URL: https://issues.apache.org/jira/browse/FLINK-9538
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502923#comment-16502923
]
Aljoscha Krettek commented on FLINK-9538:
-
Sounds good!
> Make KeyedStateFunction an interface
>
[
https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-9538:
Description: I suggest to change the KeyedStateFunction from abstract class
to interface
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502901#comment-16502901
]
Dawid Wysakowicz edited comment on FLINK-9533 at 6/6/18 7:46 AM:
-
Hi
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-9533.
---
Resolution: Not A Problem
> CEP cant deal with the known outOfOrder config with event time
>
[
https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502935#comment-16502935
]
Sihua Zhou commented on FLINK-9455:
---
[~till.rohrmann] Thanks for your reply, I agreed. I'll give a
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6126
[FLINK-9530][metrics] Fix numRecords task metric for chains
## What is the purpose of the change
This PR fixes the task re-use of operator `numRecordsIn/Out` metrics. Tasks
were re-using
[
https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502947#comment-16502947
]
ASF GitHub Bot commented on FLINK-9530:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9532:
Description:
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9532:
Description:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6125
[FLINK-9532] Flink Overview of Jobs Documentation Incorrect
## What is the purpose of the change
*This pull request fixed Flink Overview of Jobs Documentation Incorrect*
##
[
https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502885#comment-16502885
]
ASF GitHub Bot commented on FLINK-9532:
---
GitHub user yanghua opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9535:
---
Assignee: vinoyang
> log4j.properties specified in env.java.options doesn't get picked.
>
[
https://issues.apache.org/jira/browse/FLINK-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9471:
---
Assignee: vinoyang
> Job ending exceptions being logged at Info level
>
[
https://issues.apache.org/jira/browse/FLINK-9536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9536:
---
Assignee: vinoyang
> Rolling logs using log4j.properties, prevents them from showing on the UI.
>
SUBRAMANYA SURESH created FLINK-9535:
Summary: log4j.properties specified in env.java.options doesn't
get picked.
Key: FLINK-9535
URL: https://issues.apache.org/jira/browse/FLINK-9535
Project:
SUBRAMANYA SURESH created FLINK-9536:
Summary: Rolling logs using log4j.properties, prevents them from
showing on the UI.
Key: FLINK-9536
URL: https://issues.apache.org/jira/browse/FLINK-9536
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-7917.
---
Resolution: Fixed
Fix Version/s: 1.6.0
> The return of taskInformationOrBlobKey should be placed
[
https://issues.apache.org/jira/browse/FLINK-9368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502977#comment-16502977
]
ASF GitHub Bot commented on FLINK-9368:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6127
[FLINK-9368][py][tests] Add Python API E2E test
## What is the purpose of the change
This PR adds en end-to-end test for the batch Python API. It uses the
built-in wordcount example.
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8744:
Summary: Add annotations for documenting common/advanced options (was: Add
annotations
[
https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-8886:
Description:
Flink's TaskManager executes tasks from different jobs within the same JVM as
[
https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502997#comment-16502997
]
Renjie Liu commented on FLINK-8886:
---
I think there are two parts of this issue:
# Task manager
[
https://issues.apache.org/jira/browse/FLINK-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503024#comment-16503024
]
ASF GitHub Bot commented on FLINK-9366:
---
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/6107#discussion_r193340830
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -844,7 +844,7 @@ public JobExecutionResult execute() throws
[
https://issues.apache.org/jira/browse/FLINK-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503025#comment-16503025
]
ASF GitHub Bot commented on FLINK-9366:
---
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/6107#discussion_r193341492
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -844,7 +844,7 @@ public JobExecutionResult execute() throws
Github user eliaslevy commented on a diff in the pull request:
https://github.com/apache/flink/pull/6076#discussion_r193619225
--- Diff: docs/dev/event_time.md ---
@@ -213,10 +213,33 @@ arrive after the system's event time clock (as
signaled by the watermarks) has a
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503426#comment-16503426
]
swy commented on FLINK-9506:
[~kkrugler] please don't close the ticket yet. Because the performance
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504249#comment-16504249
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user tragicjun commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504199#comment-16504199
]
ASF GitHub Bot commented on FLINK-9503:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6129
cc @zentol please review again, the reason of CI error is other problem
---
[
https://issues.apache.org/jira/browse/FLINK-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503396#comment-16503396
]
Ken Krugler commented on FLINK-9535:
I believe that {{log4j.configuration}} takes a path to a file,
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503401#comment-16503401
]
Ken Krugler commented on FLINK-9506:
@swy - the questions about setting up RocksDB, and your
[
https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503505#comment-16503505
]
Sihua Zhou commented on FLINK-9506:
---
[~yow] Maybe there is one more optimization that could have a try,
[
https://issues.apache.org/jira/browse/FLINK-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9543:
---
Assignee: vinoyang
> Expose JobMaster IDs to metric system
> -
[
https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503542#comment-16503542
]
ASF GitHub Bot commented on FLINK-9503:
---
GitHub user yanghua opened a pull request:
1 - 100 of 140 matches
Mail list logo
