bjkonglu created FLINK-10836:
Summary: Add repositories and pluginRepositories in root pom.xml
Key: FLINK-10836
URL: https://issues.apache.org/jira/browse/FLINK-10836
Project: Flink
Issue Type:
Hi lining,
Yes, currently you can't get slot information via the
"/taskmanagers/:taskmanagerid" rest API.
In addition, please ask questions in the user mailing list. The dev mailing
list mainly discusses information related to Flink development.
Thanks, vino.
lining jing 于2018年11月9日周五 上午5:42写道
zhijiang created FLINK-10835:
Summary: Remove duplicated Round-robin ChannelSelector
implementation in RecordWriterTest
Key: FLINK-10835
URL: https://issues.apache.org/jira/browse/FLINK-10835
Project: Fli
sunjincheng created FLINK-10834:
---
Summary: TableAPI flatten calculated value error
Key: FLINK-10834
URL: https://issues.apache.org/jira/browse/FLINK-10834
Project: Flink
Issue Type: Bug
Hi Piotr,
That seems to be good idea!
Since the google doc for the design is currently under extensive review, I will
leave it as it is for now. However, I'll convert it to two different FLIPs when
the time comes.
How does it sound to you?
Thanks,
Xuefu
-
Arnaud Linz created FLINK-10832:
---
Summary: StreamExecutionEnvironment.execute() does not return when
all sources end
Key: FLINK-10832
URL: https://issues.apache.org/jira/browse/FLINK-10832
Project: Flin
Chesnay Schepler created FLINK-10829:
Summary: Extend FlinkDistribution to support running jars
Key: FLINK-10829
URL: https://issues.apache.org/jira/browse/FLINK-10829
Project: Flink
Issu
sunjincheng created FLINK-10819:
---
Summary: The instability problem of CI,
JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.
Key: FLINK-10819
URL: https://issues.apache.org/jira/browse/
Hi, dev. I have a question. Now rest api can get TaskManagerInfo, but can
not get information of task which run on slot.
zhijiang created FLINK-10820:
Summary: Simplify the RebalancePartitioner implementation
Key: FLINK-10820
URL: https://issues.apache.org/jira/browse/FLINK-10820
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-10822:
Summary: Configurable MetricQueryService interval
Key: FLINK-10822
URL: https://issues.apache.org/jira/browse/FLINK-10822
Project: Flink
Issue Type:
Stefan Richter created FLINK-10828:
--
Summary: Enforce that all TypeSerializers are tested through
SerializerTestBase
Key: FLINK-10828
URL: https://issues.apache.org/jira/browse/FLINK-10828
Project: F
Timo Walther created FLINK-10826:
Summary: Heavy deployment end-to-end test produces no output on
Travis
Key: FLINK-10826
URL: https://issues.apache.org/jira/browse/FLINK-10826
Project: Flink
ambition created FLINK-10818:
Summary: RestartStrategies.fixedDelayRestart Occur
NoResourceAvailableException: Not enough free slots available to run the job.
Key: FLINK-10818
URL: https://issues.apache.org/jira/brow
Chesnay Schepler created FLINK-10823:
Summary: Missing scala suffixes
Key: FLINK-10823
URL: https://issues.apache.org/jira/browse/FLINK-10823
Project: Flink
Issue Type: Bug
Comp
Andrey Zagrebin created FLINK-10830:
---
Summary: Consider making processing time provider pluggable
Key: FLINK-10830
URL: https://issues.apache.org/jira/browse/FLINK-10830
Project: Flink
Issu
Andrey Zagrebin created FLINK-10831:
---
Summary: Consider making processing time monotonically increasing
by default
Key: FLINK-10831
URL: https://issues.apache.org/jira/browse/FLINK-10831
Project: Fl
Hi,
Maybe we should split this topic (and the design doc) into couple of smaller
ones, hopefully independent. The questions that you have asked Fabian have for
example very little to do with reading metadata from Hive Meta Store?
Piotrek
> On 7 Nov 2018, at 14:27, Fabian Hueske wrote:
>
> H
Hi all,
We are discussing very detailed content about this proposal. We are trying
to design the API in many aspects (functionality, compatibility, ease of
use, etc.). I think this is a very good process. Only such a detailed
discussion, In order to develop PR more clearly and smoothly in the late
Stefan Richter created FLINK-10827:
--
Summary: Add test for duplicate() to SerializerTestBase
Key: FLINK-10827
URL: https://issues.apache.org/jira/browse/FLINK-10827
Project: Flink
Issue Type
Hi Piotrek,
> But I don’t see a reason why we should expose both blocking `take()` and
non-blocking `poll()` methods to the Flink engine. Someone (Flink engine or
connector) would have to do the same busy
> looping anyway and I think it would be better to have a simpler connector
API (that would s
Gary Yao created FLINK-10821:
Summary: Resuming Externalized Checkpoint E2E test does not Resume
from Externalized Checkpoint
Key: FLINK-10821
URL: https://issues.apache.org/jira/browse/FLINK-10821
Projec
Hi,
I was also just planning to work on it before Stephan contacted Thomas to ask
about this test.
Thomas, you are right about the structure, the test should also go into the
`run-nightly-tests.sh`. What I was planning to do is a simple job that consists
of a Kinesis consumer, a mapper that fa
Hi Till,
Today when I do the CI before merge code, I find a instability test case:
JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test
fail.
I'm not sure if this is issue should blocking the release 1.7, but I think
it's best to find the cause and fix it before releasing 1.7
Hongtao Zhang created FLINK-10824:
-
Summary: Compile Flink unit test failed with 1.6.0 branch
Key: FLINK-10824
URL: https://issues.apache.org/jira/browse/FLINK-10824
Project: Flink
Issue Type
Timo Walther created FLINK-10825:
Summary: ConnectedComponents test instable on Travis
Key: FLINK-10825
URL: https://issues.apache.org/jira/browse/FLINK-10825
Project: Flink
Issue Type: Bug
Hi,
in general, I think it is clearly a good idea to make rescaling as cheap and as
dynamic as possible and this is a goal that is surely on the long term roadmap
of Flink.
However, from a technical point of view I think that things are not as simple
if you go into details, and details is what
Andrey Zagrebin created FLINK-10833:
---
Summary:
FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify
failed on Travis
Key: FLINK-10833
URL: https://issues.apache.org/jira/browse/
Hi Addison,
unfortunately, there is a long-standing problem that user functions cannot
differentiate between successful and erroneous shutdown [1]. I had this high on
my private list of things that I finally want to see fixed in Flink 1.8. And
your message further confirms this.
Best,
Aljoscha
Hi Thomas,
the community is really interested in adding an end-to-end test for the
Kinesis connector (producer as well as consumer). Thus, it would be really
helpful if you could contribute your work you've already done.
Using Kinesalite sounds good to me and you're right and that we assume that
Hi Addison,
thanks for reporting this issue. I've pulled in Kostas who worked on the
StreamingFileSink and knows the current behaviour as well as its
limitations best.
Cheers,
Till
On Wed, Nov 7, 2018 at 11:49 PM Addison Higham wrote:
> Hi all,
>
> Just run into a bit of a problem and I am not
31 matches
Mail list logo
