[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233643#comment-16233643
]
Sihua Zhou commented on FLINK-7873:
---
[~stefanrichte...@gmail.com] Thanks very much for y
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233608#comment-16233608
]
Stefan Richter edited comment on FLINK-7873 at 11/1/17 3:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233608#comment-16233608
]
Stefan Richter commented on FLINK-7873:
---
The first proposal of this JIRA had some is
[
https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233605#comment-16233605
]
ASF GitHub Bot commented on FLINK-7941:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4930
[FLINK-7941][flip6] Port SubtasksTimesHandler to new REST endpoint
## What is the purpose of the change
Port SubtasksTimesHandler to new REST endpoint
## Brief change log
- *A
[
https://issues.apache.org/jira/browse/FLINK-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233565#comment-16233565
]
ASF GitHub Bot commented on FLINK-7939:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16233564#comment-16233564
]
ASF GitHub Bot commented on FLINK-6563:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4917
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4638
---
[
https://issues.apache.org/jira/browse/FLINK-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16227513#comment-16227513
]
ASF GitHub Bot commented on FLINK-7939:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16227512#comment-16227512
]
ASF GitHub Bot commented on FLINK-6563:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4917
Will merge this fix as well.
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4638
Running some last tests before merging this PR
---
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16227479#comment-16227479
]
Chesnay Schepler commented on FLINK-7880:
-
[~till.rohrmann] yes it's still an issu
[
https://issues.apache.org/jira/browse/FLINK-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7936.
-
Thanks for confirming not an issue.
> Lack of synchronization w.r.t. taskManagers in MetricStore#add(
[
https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7954:
---
Assignee: Bowen Li
> sideoutput in async function
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16227260#comment-16227260
]
ASF GitHub Bot commented on FLINK-7922:
---
Github user walterddr commented on a diff i
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4929#discussion_r148083555
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/SetOperatorsTest.scala
---
@@ -178,4 +182,54 @@ class SetOperato
[
https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16227257#comment-16227257
]
ASF GitHub Bot commented on FLINK-7922:
---
GitHub user walterddr opened a pull request
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/4929
[FLINK-7922][Table API]make FlinkTypeFactory override leastRestrictive to
work with Nullable composite types while using super class method to handle
basic type
## What is the purpose of th
Chen Qin created FLINK-7954:
---
Summary: sideoutput in async function
Key: FLINK-7954
URL: https://issues.apache.org/jira/browse/FLINK-7954
Project: Flink
Issue Type: Improvement
Components
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7732:
--
Summary: Invalid offset to commit in Kafka (was: Test instability in Kafka
end-to-end test (inv
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226910#comment-16226910
]
ASF GitHub Bot commented on FLINK-7732:
---
Github user pnowojski commented on the issu
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4928
@tzulitai @aljoscha could you take a look?
---
[
https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226907#comment-16226907
]
ASF GitHub Bot commented on FLINK-7732:
---
GitHub user pnowojski opened a pull request
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4928
[FLINK-7732][kafka-consumer] Do not commit to kafka Flink's sentinel offsets
## What is the purpose of the change
This pull request fixes a bug in all versions of `KafkaConsumer`s, that
r
[
https://issues.apache.org/jira/browse/FLINK-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-7936.
---
Resolution: Not A Problem
Should not be a problem after refactor.
> Lack of synchronization w.r.t. taskManage
[
https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226875#comment-16226875
]
ASF GitHub Bot commented on FLINK-7778:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4927
[FLINK-7778] [build] Shade ZooKeeper dependency
## What is the purpose of the change
This PR shades and relocates curator&zookeeper into flink-runtime to avoid
dependency conflicts, primaril
Shashank Agarwal created FLINK-7953:
---
Summary: Kafka consumer printing error -
java.lang.IllegalArgumentException: Invalid offset: -915623761772
Key: FLINK-7953
URL: https://issues.apache.org/jira/browse/FLINK-7
[
https://issues.apache.org/jira/browse/FLINK-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 updated FLINK-7952:
--
Description:
It would be useful to track logging events .
*impl:*
adds event counting via a cus
[
https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226709#comment-16226709
]
ASF GitHub Bot commented on FLINK-7781:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7418.
---
Resolution: Fixed
1.4: 95847f4a70935f4c96da05c04254bd00a23eb4eb
> Replace all uses of jackson
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7945:
--
Affects Version/s: (was: 1.3.2)
(was: 1.2.1)
1.4.0
[
https://issues.apache.org/jira/browse/FLINK-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226710#comment-16226710
]
ASF GitHub Bot commented on FLINK-7418:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5233.
---
Resolution: Fixed
1.4: 95847f4a70935f4c96da05c04254bd00a23eb4eb
> Upgrade Jackson version bec
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4922
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4923
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4901
---
[
https://issues.apache.org/jira/browse/FLINK-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7912.
---
Resolution: Fixed
1.4: 3bf6ec980c87379534c0742d69681d695d020ae6
> Document metrics REST API
>
[
https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7781.
---
Resolution: Fixed
1.4: d48b208a7207bc50ba76019b7cb71039573bd26e
> Support simple on-demand me
Hai Zhou UTC+8 created FLINK-7952:
-
Summary: Add metrics for counting logging events
Key: FLINK-7952
URL: https://issues.apache.org/jira/browse/FLINK-7952
Project: Flink
Issue Type: Wish
Github user kl0u commented on the pull request:
https://github.com/apache/flink/commit/f2c3ff3ee3a5121665e32acebbaeee7bbb380e7f#commitcomment-25306091
@zentol reported instabilities so for now I ignored them until I fix them.
---
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/commit/f2c3ff3ee3a5121665e32acebbaeee7bbb380e7f#commitcomment-25306076
Would be great to add an explanation why these tests are ignored.
---
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-7880:
--
Given
https://github.com/apache/flink/commit/f2c3ff3ee3a5121665e32acebbaeee7bbb380e7f
I assume tha
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4925
---
[
https://issues.apache.org/jira/browse/FLINK-7950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-7950.
-
Resolution: Fixed
Merged on master with 27c5ab509e388aa9a8f7de1cf3f4b0dcd8e07aad
> flink-queryabl
[
https://issues.apache.org/jira/browse/FLINK-7950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226584#comment-16226584
]
ASF GitHub Bot commented on FLINK-7950:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 closed FLINK-6499.
-
Resolution: Fixed
> Migrate state configuration options
> ---
>
>
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4915#discussion_r147942486
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011Test.java
---
@@ -61,
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226554#comment-16226554
]
ASF GitHub Bot commented on FLINK-7838:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226549#comment-16226549
]
ASF GitHub Bot commented on FLINK-7838:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4915#discussion_r147941508
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java
---
@@ -2
[
https://issues.apache.org/jira/browse/FLINK-6495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-6495.
-
> Migrate Akka configuration options
> --
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7739.
-
> Improve Kafka*ITCase tests stability
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-7784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226537#comment-16226537
]
ASF GitHub Bot commented on FLINK-7784:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4910#discussion_r147939418
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011Tests.java
---
@@ -83
[
https://issues.apache.org/jira/browse/FLINK-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226511#comment-16226511
]
Piotr Nowojski edited comment on FLINK-7936 at 10/31/17 9:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226511#comment-16226511
]
Piotr Nowojski commented on FLINK-7936:
---
{{computIfAbsent}} was not used before my r
[
https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226444#comment-16226444
]
ASF GitHub Bot commented on FLINK-7694:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4757
Once this PR is merged, I'll migrate other metrics handlers and abstract
the common code away.
---
[
https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 updated FLINK-7286:
--
Fix Version/s: (was: 1.4.0)
1.5.0
> Flink Dashboard fails to display byte
62 matches
Mail list logo
