Github user joan38 commented on the issue:
https://github.com/apache/flink/pull/3703
Is there any news on this?
---
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156701#comment-16156701
]
ASF GitHub Bot commented on FLINK-7521:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4654
Hi @zjureel ! Thanks for the work!
This can be a temporary fix, but I was thinking more of a long term one
where there is no limit.
The problems that I can find with such temporary
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4654
This doesn't solve the problem of the JIRA. For the job submission we have
to send jars to the cluster, which may be multiple 100mb large; we obviously
can't allocate that much memory in general.
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156686#comment-16156686
]
ASF GitHub Bot commented on FLINK-7521:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4654
@kl0u I have tried to fix
[https://issues.apache.org/jira/browse/FLINK-7521](https://issues.apache.org/jira/browse/FLINK-7521)
in this PR, could you please have a look when you're free, thanks
---
[
https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156763#comment-16156763
]
Steve Loughran commented on FLINK-7589:
---
well, you are allowed to file bug reports.
However, it's
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156683#comment-16156683
]
ASF GitHub Bot commented on FLINK-7521:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4654
[FLINK-7521] Add config option to set the content length limit of REST
server and client
## Brief change log
Add config option to set the content length limit of REST server and client
Github user jameslafa closed the pull request at:
https://github.com/apache/flink/pull/4648
---
[
https://issues.apache.org/jira/browse/FLINK-7584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156711#comment-16156711
]
ASF GitHub Bot commented on FLINK-7584:
---
Github user jameslafa closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156710#comment-16156710
]
ASF GitHub Bot commented on FLINK-7584:
---
Github user jameslafa commented on the issue:
Github user jameslafa commented on the issue:
https://github.com/apache/flink/pull/4648
As decided, we stay on 6.19. I drop the pull request.
---
[
https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156740#comment-16156740
]
ASF GitHub Bot commented on FLINK-7521:
---
Github user zentol commented on the issue:
Dian Fu created FLINK-7599:
--
Summary: Support aggregation functions in the define and measures
clause of MatchRecognize
Key: FLINK-7599
URL: https://issues.apache.org/jira/browse/FLINK-7599
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156747#comment-16156747
]
ASF GitHub Bot commented on FLINK-5005:
---
Github user joan38 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156775#comment-16156775
]
Timo Walther commented on FLINK-7594:
-
[~wheat9] That sounds great. Maybe you can share some design
GitHub user mlipkovich opened a pull request:
https://github.com/apache/flink/pull/4655
[FLINK-7567]: Removed keepPartitioning parameter from iterate method
## What is the purpose of the change
Removed parameter keepPartitioning from DataStream#iterate method since
it's
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156986#comment-16156986
]
ASF GitHub Bot commented on FLINK-7567:
---
GitHub user mlipkovich opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156997#comment-16156997
]
Mikhail Lipkovich commented on FLINK-7567:
--
Hi Peter,
As a user I agree with Aljoscha that we
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156954#comment-16156954
]
Hai Zhou commented on FLINK-7594:
-
[~wheat9] That sounds great. +1
BTW, If Alibaba and Huawei to share
[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7495:
--
Description:
{code}
recoveredStreamElements = context
.getOperatorStateStore()
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7508:
Description:
KinesisProducerLibrary (KPL) 0.10.x had been using a One-New-Thread-Per-Request
model for all
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157608#comment-16157608
]
ASF GitHub Bot commented on FLINK-7508:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4656
[FLINK-7508][kinesis] switch FlinkKinesisProducer to use KPL's
ThreadingMode to ThreadedPool mode rather than Per_Request mode
## What is the purpose of the change
KinesisProducerLibrary
[
https://issues.apache.org/jira/browse/FLINK-7597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157662#comment-16157662
]
Bowen Li commented on FLINK-7597:
-
Importing that module separately after importing the whole flink
[
https://issues.apache.org/jira/browse/FLINK-7597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7597.
---
Resolution: Not A Problem
> broken flink-connectors-kinesis setup in Intellij that potentially results
>
Bowen Li created FLINK-7600:
---
Summary: shorten delay of
KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid
updateCredentials Exception
Key: FLINK-7600
URL:
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4638#discussion_r137671151
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -106,8 +240,191
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157873#comment-16157873
]
Bowen Li edited comment on FLINK-6703 at 9/7/17 11:49 PM:
--
[~Zentol] is this
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157873#comment-16157873
]
Bowen Li commented on FLINK-6703:
-
[~Zentol] is this still valid? is the above savepoint command for Flink
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
As I understand the build has failed because of changed API method. The
method which was changed has annotation PublicEvolving so there should be a way
to change it. As was mentioned by @aljoscha
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157885#comment-16157885
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user mlipkovich commented on the issue:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4657
[FLINK-7600][kinesis] shorten delay of
KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid
updateCredentials Exception
## What is the purpose of the change
we saw the
[
https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157785#comment-16157785
]
ASF GitHub Bot commented on FLINK-7600:
---
GitHub user bowenli86 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157798#comment-16157798
]
ASF GitHub Bot commented on FLINK-6563:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157858#comment-16157858
]
Bowen Li commented on FLINK-6125:
-
[~tzulitai] I agree, I think this is different from FLINK-6951.
>
[
https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6703:
---
Assignee: Bowen Li
> Document how to take a savepoint on YARN
>
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6549:
---
Assignee: Bowen Li
> Improve error message for type mismatches with side outputs
>
[
https://issues.apache.org/jira/browse/FLINK-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6957:
---
Assignee: Bowen Li
> WordCountTable example cannot be run
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-5095:
---
Assignee: Bowen Li
> Add explicit notifyOfAddedX methods to MetricReporter interface
>
Nico Kruber created FLINK-7598:
--
Summary: ineffective shaded artifacts checks in
travis_mvn_watchdog.sh
Key: FLINK-7598
URL: https://issues.apache.org/jira/browse/FLINK-7598
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7598:
---
Description:
The {{check_shaded_artifacts()}} checks have some shortcomings which render
them
[
https://issues.apache.org/jira/browse/FLINK-7598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156611#comment-16156611
]
ASF GitHub Bot commented on FLINK-7598:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4653
[FLINK-7598][travis] fix ineffective shaded artifacts checks
## What is the purpose of the change
This fixes the Netty shaded dependencies check and makes all of the checks
more robust
[
https://issues.apache.org/jira/browse/FLINK-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156540#comment-16156540
]
ASF GitHub Bot commented on FLINK-7440:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4473
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4537
---
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156541#comment-16156541
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7367.
--
Resolution: Fixed
Fix Version/s: (was: 1.3.3)
Since this includes
[
https://issues.apache.org/jira/browse/FLINK-7440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7440.
--
Resolution: Fixed
Fix Version/s: (was: 1.3.3)
Merged to master via
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7407.
--
Resolution: Fixed
> Assumption of partition id strict contiguity is too naive in Kafka
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156543#comment-16156543
]
Tzu-Li (Gordon) Tai commented on FLINK-7407:
Merged to {{master}} via
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156546#comment-16156546
]
Tzu-Li (Gordon) Tai commented on FLINK-7367:
Merged to {{master}} via
Bowen Li created FLINK-7597:
---
Summary: broken flink-connectors-kinesis setup in Intellij that
potentially results from improper pom.xml
Key: FLINK-7597
URL: https://issues.apache.org/jira/browse/FLINK-7597
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4653
+1
---
[
https://issues.apache.org/jira/browse/FLINK-7598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156625#comment-16156625
]
ASF GitHub Bot commented on FLINK-7598:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-7596:
-
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156647#comment-16156647
]
Fabian Hueske commented on FLINK-7594:
--
[~twalthr] and I have been working on a prototype for a few
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4631
Thanks :)
---
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4631
---
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1615#comment-1615
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
Bugs in tests (those that you can see in fixup commits)
---
63 matches
Mail list logo
