Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4239
I did a first high-level review of the code. I think it's good so far!
Before we can merge this, however, we need a few more things around it:
- A section in the Kafka doc about the new
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146771#comment-16146771
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146706#comment-16146706
]
ASF GitHub Bot commented on FLINK-7559:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4619
[FLINK-7559] Typo in flink-quickstart pom.xml
just fix typo.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yew1eb/flink FLINK-7559
Alternativel
Hai Zhou created FLINK-7559:
---
Summary: Typo in flink-quickstart pom.xml
Key: FLINK-7559
URL: https://issues.apache.org/jira/browse/FLINK-7559
Project: Flink
Issue Type: Improvement
Compon
Github user narendraj9 commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske Hi, I am trying to understand how Objects of RichProcessFunction
class are managed. For example, you mentioned that onTimer() and
processElement() won't be called at the same time. Could
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1614#comment-1614
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user narendraj9 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146639#comment-16146639
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
Great! I can start FLINK-7508 then
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
sunjincheng created FLINK-7558:
--
Summary: Improve SQL ValidationException message.
Key: FLINK-7558
URL: https://issues.apache.org/jira/browse/FLINK-7558
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146553#comment-16146553
]
ASF GitHub Bot commented on FLINK-7557:
---
GitHub user tony810430 opened a pull reques
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/4618
[FLINK-7557] Fix typo for s3a config in AWS deployment documentation
Should use `fs.s3a.buffer.dir` in `core-site.xml` to set s3a directories
for buffering files.
You can merge this pull request
Wei-Che Wei created FLINK-7557:
--
Summary: Fix typo for s3a config in AWS deployment documentation
Key: FLINK-7557
URL: https://issues.apache.org/jira/browse/FLINK-7557
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282
]
Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:16 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282
]
Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:15 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282
]
Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:15 PM:
-
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
Hi @ggevay,
Thanks for the commits. Do you have any plan for `FixedLengthRecordSorter`
implementation?
I'm not sure how much work need to be done there.
---
If your project is set u
[
https://issues.apache.org/jira/browse/FLINK-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7503:
--
Component/s: Webfrontend
> Config options taskmanager.log.path and jobmanager.web.log.path are
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146098#comment-16146098
]
Bowen Li commented on FLINK-7524:
-
This seems to be due to Flink TM ran out of memory. Aft
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7524:
--
Component/s: State Backends, Checkpointing
> Task "xxx" did not react to cancelling signal, but
[
https://issues.apache.org/jira/browse/FLINK-7546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7546:
--
Component/s: Table API & SQL
> Support SUBMULTISET_OF Operator for Multiset SQL type
> -
[
https://issues.apache.org/jira/browse/FLINK-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7539:
--
Component/s: Batch Connectors and Input/Output Formats
> Make AvroOutputFormat default codec con
[
https://issues.apache.org/jira/browse/FLINK-7545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7545:
--
Component/s: Table API & SQL
> Support MEMBER OF Operator for Multiset SQL type
> --
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146046#comment-16146046
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/4522
I've pushed the PR to CI again. If it passes, I'll merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7309.
Resolution: Fixed
Fix Version/s: 1.3.3
1.4.0
Fixed for 1.3.3 with eec261e9
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7398.
Resolution: Fixed
Fixed for 1.3.3 with 3167f72d95719ee551e798196fd26b9503e2dfd9
Fixed for 1.4.0 with
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7245.
Resolution: Implemented
Fix Version/s: 1.4.0
Implemented for 1.4.0 with 68fdaa57e35b8ee30a262
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7206.
Resolution: Implemented
Fix Version/s: 1.4.0
Implemented for 1.4.0 with 1fc0b6413c74eff0ace25
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146022#comment-16146022
]
ASF GitHub Bot commented on FLINK-7206:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146025#comment-16146025
]
ASF GitHub Bot commented on FLINK-7309:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146024#comment-16146024
]
ASF GitHub Bot commented on FLINK-7398:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146023#comment-16146023
]
ASF GitHub Bot commented on FLINK-7245:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4479
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4530
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4355
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4576
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user coveralls commented on the issue:
https://github.com/apache/flink/pull/1305
[](https://coveralls.io/builds/13040362)
Changes Unknown when pulling **db2a964a450c05cb2aad3843999d994e4b8e5ef5 on
gyfor
GitHub user nycholas opened a pull request:
https://github.com/apache/flink/pull/4617
[FLINK-7556] Fix fetch size configurable in JDBCInputFormat for MySQL Driver
According to the MySQL documentation[1], it follows:
* ResultSet
> By default, ResultSets are completel
[
https://issues.apache.org/jira/browse/FLINK-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145732#comment-16145732
]
ASF GitHub Bot commented on FLINK-7556:
---
GitHub user nycholas opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145697#comment-16145697
]
ASF GitHub Bot commented on FLINK-7547:
---
Github user eliaslevy commented on the issu
Github user eliaslevy commented on the issue:
https://github.com/apache/flink/pull/4614
ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the fea
[
https://issues.apache.org/jira/browse/FLINK-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nycholas de Oliveira e Oliveira updated FLINK-7556:
---
Description:
According to the MySQL documentation[1], it follo
Nycholas de Oliveira e Oliveira created FLINK-7556:
--
Summary: Fix fetch size configurable in JDBCInputFormat for MySQL
Driver
Key: FLINK-7556
URL: https://issues.apache.org/jira/browse/FLINK-7556
[
https://issues.apache.org/jira/browse/FLINK-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7555.
---
Resolution: Not A Problem
Certain libraries (cassandra, kinesis, table API) must use vanilla g
Hai Zhou created FLINK-7555:
---
Summary: Use flink-shaded-guava-18 to replace guava dependencies
Key: FLINK-7555
URL: https://issues.apache.org/jira/browse/FLINK-7555
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-7555:
Description:
After [#issue FLINK-6982|https://issues.apache.org/jira/browse/FLINK-6982],
I still find 40 occ
[
https://issues.apache.org/jira/browse/FLINK-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-7555:
Environment: (was: After [#issue
FLINK-6982|https://issues.apache.org/jira/browse/FLINK-6982],
I still f
[
https://issues.apache.org/jira/browse/FLINK-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-7551:
---
Assignee: Chesnay Schepler
> Add VERSION to the REST urls.
> ---
[
https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou closed FLINK-7297.
---
Resolution: Fixed
> Instable Kafka09ProducerITCase.testCustomPartitioning test case
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4454
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou closed FLINK-7376.
---
Resolution: Won't Fix
> Cleanup options class and test classes in flink-clients
> ---
[
https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-7376:
---
Assignee: Hai Zhou
> Cleanup options class and test classes in flink-clients
> -
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145393#comment-16145393
]
ASF GitHub Bot commented on FLINK-7398:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145394#comment-16145394
]
ASF GitHub Bot commented on FLINK-7309:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4479
Thanks for the PR @yestinchen.
Will merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4576
Thanks for the PR @haohui!
Will add `Logging` to `CRowOutputProcessRunner` as well and merge it.
Cheers, Fabian
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145363#comment-16145363
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on the iss
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4331
Hi @dawidwys , sorry for the late response.
Thanks for your reviews, I have updated the test and the document. Please
take a look if you have time. Thanks.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-7554:
Labels: starter (was: )
> Add a testing RuntimeContext to test utilities
>
Timo Walther created FLINK-7554:
---
Summary: Add a testing RuntimeContext to test utilities
Key: FLINK-7554
URL: https://issues.apache.org/jira/browse/FLINK-7554
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145357#comment-16145357
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4616
R: @rmetzger @pnowojski Could you please review this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have th
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145339#comment-16145339
]
ASF GitHub Bot commented on FLINK-7552:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4616
[FLINK-7552] [FLINK-7553] Enhance SinkInterface / Use in FlinkKafkaProducer
## What is the purpose of the change
Enhance `SinkFunction` with a way of retrieving the element timestamp. This
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4454
Thanks :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4577
Thanks! :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if th
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4577
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is e
Aljoscha Krettek created FLINK-7553:
---
Summary: Use new SinkFunction interface in FlinkKafkaProducer010
Key: FLINK-7553
URL: https://issues.apache.org/jira/browse/FLINK-7553
Project: Flink
I
Aljoscha Krettek created FLINK-7552:
---
Summary: Extend SinkFunction interface with SinkContext
Key: FLINK-7552
URL: https://issues.apache.org/jira/browse/FLINK-7552
Project: Flink
Issue Type
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4454
@pnowojski Thanks for the PR. I will go over the changes again and merge
this. I will create an followup issue about the mentioned comments.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145264#comment-16145264
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4612
@fhueske Feel free to review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wi
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-7410:
---
Description:
*Motivation*
Operator names setted in table-api are used by visualization and logging, i
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-7410:
---
Summary: Use toString method to display operator names for
UserDefinedFunction (was: Add getName meth
[
https://issues.apache.org/jira/browse/FLINK-7498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7498.
---
Resolution: Fixed
Implemented in ac72360cc0e71d6f543d93c9c1f117babaa35799
> Bind together sta
[
https://issues.apache.org/jira/browse/FLINK-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7497.
---
Resolution: Fixed
Implemented in 959d54fc828691759f15f2e83c0c123e9da6e782
> Allow users to ad
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4577
I merged this. ð
Could you please close the PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145213#comment-16145213
]
Hequn Cheng commented on FLINK-7410:
OK, I will use {{toString}} instead, thanks all.
[
https://issues.apache.org/jira/browse/FLINK-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145212#comment-16145212
]
ASF GitHub Bot commented on FLINK-7518:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4615
[FLINK-7518][network] pass our own NetworkBuffer to Netty
## What is the purpose of the change
With this PR, based on #4613, we finally pass our own `NetworkBuffer` class
to Netty and remove
Kostas Kloudas created FLINK-7551:
-
Summary: Add VERSION to the REST urls.
Key: FLINK-7551
URL: https://issues.apache.org/jira/browse/FLINK-7551
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145203#comment-16145203
]
ASF GitHub Bot commented on FLINK-7547:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4614
[FLINK-7547] AsyncFunction.scala extends Function, serialized
fix [#issue FLINK-7547](https://issues.apache.org/jira/browse/FLINK-7547)
details:
org.apache.flink.streaming.api.scala.async.Asyn
[
https://issues.apache.org/jira/browse/FLINK-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145200#comment-16145200
]
ASF GitHub Bot commented on FLINK-7520:
---
GitHub user NicoK opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145199#comment-16145199
]
ASF GitHub Bot commented on FLINK-7245:
---
Github user xccui commented on the issue:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4613
[FLINK-7520][network] let our Buffer class extend from Netty's buffer class
## What is the purpose of the change
With this PR, we extend out own `Buffer` class to extend from Netty's
`ByteBuf
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/4530
I totally understand the choice, @fhueske ð
Thanks for the refactoring.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
[
https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145186#comment-16145186
]
Hai Zhou commented on FLINK-7547:
-
HI [~elevy].
I will give a PR to fix it.
> o.a.f.s.api
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145165#comment-16145165
]
ASF GitHub Bot commented on FLINK-7245:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4530
You're right @xccui, this is a trade off.
I thought about this again and agree with @aljoscha that it would be better
to avoid the additional method call. The `processWatermark()` method is
[
https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145155#comment-16145155
]
ASF GitHub Bot commented on FLINK-7502:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145153#comment-16145153
]
ASF GitHub Bot commented on FLINK-7502:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145154#comment-16145154
]
ASF GitHub Bot commented on FLINK-7502:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4586#discussion_r135764533
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -130,7 +139,11 @@ public vo
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4586#discussion_r135764923
--- Diff:
flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java
---
@@ -160,6 +151,43 @@ publi
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4586#discussion_r135764351
--- Diff:
flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java
---
@@ -84,21 +84,30 @@ static Str
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-7438:
---
Assignee: Hai Zhou
> Some classes are eclipsed by classes in package scala
>
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145095#comment-16145095
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3838
There is none that I'm aware of. It is also possible for the JM and TM to
run in the same JVM, say for tests or in local mode.
I can't think of a nice way to solve this, so I suggest we simply
1 - 100 of 122 matches
Mail list logo
