Robert Metzger created FLINK-18271:
--
Summary: Move run-nightly-tests.sh
Key: FLINK-18271
URL: https://issues.apache.org/jira/browse/FLINK-18271
Project: Flink
Issue Type: Task
Robert Metzger created FLINK-18270:
--
Summary:
ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper
unstable
Key: FLINK-18270
URL: https://issues.apache.org/jira/browse/FLINK
Robert Metzger created FLINK-18262:
--
Summary: PyFlink end-to-end test stalls
Key: FLINK-18262
URL: https://issues.apache.org/jira/browse/FLINK-18262
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-18261:
--
Summary: flink-orc and flink-parquet have invalid NOTICE file
Key: FLINK-18261
URL: https://issues.apache.org/jira/browse/FLINK-18261
Project: Flink
Robert Metzger created FLINK-18259:
--
Summary: HeartbeatManagerTest.testHeartbeatCluster unstable
Key: FLINK-18259
URL: https://issues.apache.org/jira/browse/FLINK-18259
Project: Flink
Issue
Robert Metzger created FLINK-18247:
--
Summary: Unstable test: TableITCase.testCollectWithClose:122
expected: but was:
Key: FLINK-18247
URL: https://issues.apache.org/jira/browse/FLINK-18247
Project
Robert Metzger created FLINK-18246:
--
Summary: PyFlink e2e fails with java version mismatch on JDK11
nightly build
Key: FLINK-18246
URL: https://issues.apache.org/jira/browse/FLINK-18246
Project
Robert Metzger created FLINK-18239:
--
Summary: Kubernetes e2e test fails with "Kubernetes 1.18.3
requires conntrack to be installed in root's path"
Key: FLINK-18239
URL: https://issues.apache.org/j
Robert Metzger created FLINK-18233:
--
Summary: TaskExecutorSubmissionTest unstable
Key: FLINK-18233
URL: https://issues.apache.org/jira/browse/FLINK-18233
Project: Flink
Issue Type: Bug
Thanks for the reminder. I was also not aware of this tag!
How about enforcing the use of this tag through CI?
We could for example grep through the added lines of all changes in docs/
and fail the build if we see the wrong pattern.
On Tue, Jun 9, 2020 at 4:37 PM Seth Wiesman wrote:
> Whoops,
Robert Metzger created FLINK-18222:
--
Summary: "Avro Confluent Schema Registry nightly end-to-end test"
unstable with "Kafka cluster did not start after 120 seconds"
Key: FLINK-18222
Robert Metzger created FLINK-18221:
--
Summary: SQL client YAML validation incomplete
Key: FLINK-18221
URL: https://issues.apache.org/jira/browse/FLINK-18221
Project: Flink
Issue Type: Bug
Hi all,
we've received a pull request on flink-web.git for adding a Japanese
translation of the Flink website:
https://github.com/apache/flink-web/pull/346
Before we accept this PR, I believe we should have a discussion about it.
*Relevance*: Looking at Google analytics, our users are coming
Robert Metzger created FLINK-18174:
--
Summary: EventTimeWindowCheckpointingITCase crashes with exit code
127
Key: FLINK-18174
URL: https://issues.apache.org/jira/browse/FLINK-18174
Project: Flink
Robert Metzger created FLINK-18161:
--
Summary: Changing parallelism is not possible in sql-client.sh
Key: FLINK-18161
URL: https://issues.apache.org/jira/browse/FLINK-18161
Project: Flink
Robert Metzger created FLINK-18160:
--
Summary: YARN session logs about HADOOP_CONF_DIR even though
HADOOP_CLASSPATH containing a config is set
Key: FLINK-18160
URL: https://issues.apache.org/jira/browse/FLINK
Robert Metzger created FLINK-18155:
--
Summary: Disable Log4j's JMX for (integration)tests
Key: FLINK-18155
URL: https://issues.apache.org/jira/browse/FLINK-18155
Project: Flink
Issue Type
Thanks a lot for creating this release Gordon!
+1 (binding)
- maven staging repo looks fine (version tags, license files)
- source archive looks good (no binaries, no unexpected files, pom has
right version)
- quickly checked diff:
Robert Metzger created FLINK-18148:
--
Summary: "Resuming Savepoint" e2e fails with TimeoutException in
CliFrontend.stop()
Key: FLINK-18148
URL: https://issues.apache.org/jira/browse/F
Robert Metzger created FLINK-18138:
--
Summary: KeyedComplexChainTest.testMigrationAndRestore fails with
AskTimeoutException on CI
Key: FLINK-18138
URL: https://issues.apache.org/jira/browse/FLINK-18138
Robert Metzger created FLINK-18137:
--
Summary: JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint
fails with AskTimeoutException
Key: FLINK-18137
URL: https://issues.apache.org/jira/browse/FLINK-18137
Robert Metzger created FLINK-18128:
--
Summary: CoordinatedSourceITCase.testMultipleSources gets stuck
Key: FLINK-18128
URL: https://issues.apache.org/jira/browse/FLINK-18128
Project: Flink
Robert Metzger created FLINK-18125:
--
Summary: Skip CI execution on documentation pull requests
Key: FLINK-18125
URL: https://issues.apache.org/jira/browse/FLINK-18125
Project: Flink
Issue
Robert Metzger created FLINK-18123:
--
Summary:
KubernetesClusterDescriptorTest.testDeployApplicationCluster:135->checkUpdatedConfigAndResourceSetting:194
expected: but was:
Key: FLINK-18123
URL: ht
Robert Metzger created FLINK-18122:
--
Summary: Kubernetes test fails with "error: timed out waiting for
the condition on jobs/flink-job-cluster"
Key: FLINK-18122
URL: https://issues.apache.org/jira/br
Robert Metzger created FLINK-18117:
--
Summary: "Kerberized YARN per-job on Docker test" "Could not start
hadoop cluster."
Key: FLINK-18117
URL: https://issues.apache.org/jir
Robert Metzger created FLINK-18082:
--
Summary: UnsignedTypeConversionITCase stalls in
ch.vorburger.mariadb4j.DB.stop
Key: FLINK-18082
URL: https://issues.apache.org/jira/browse/FLINK-18082
Project
Robert Metzger created FLINK-18071:
--
Summary:
CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI
Key: FLINK-18071
URL: https://issues.apache.org/jira/browse/FLINK-18071
Project
Hi Jacky,
thanks a lot for starting the discussion. I have no objections to adding
support for reading data from ElasticSearch as well, as long as we clearly
state the performance and correctness implications / guarantees in the
Flink documentation.
On Tue, Jun 2, 2020 at 9:52 AM Jacky Lau
Robert Metzger created FLINK-18058:
--
Summary: MesosResourceManagerTest.testWorkerStarted:656 »
NullPointer
Key: FLINK-18058
URL: https://issues.apache.org/jira/browse/FLINK-18058
Project: Flink
Robert Metzger created FLINK-18057:
--
Summary:
SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but
was:<2>
Key: FLINK-18057
URL: https://issues.apache.org/jira/browse
Robert Metzger created FLINK-18052:
--
Summary:
Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE
Key: FLINK-18052
URL: https://issues.apache.org/jira/browse/FLINK-18052
Robert Metzger created FLINK-18051:
--
Summary: Fail Maven setup on AZP if download fails
Key: FLINK-18051
URL: https://issues.apache.org/jira/browse/FLINK-18051
Project: Flink
Issue Type
; -
> Sivaprasanna
>
> On Thu, May 28, 2020 at 12:22 PM Sivaprasanna
> wrote:
>
> > Awesome. : )
> > Thanks, Robert for signing up to be the reviewer. I will create Jira and
> > share the link here.
> >
> > Stay safe.
> >
> > -
> >
Hi,
afaik, this feature was added because Hadoop MapReduce has it as well (
https://blog.cloudera.com/how-to-include-third-party-libraries-in-your-map-reduce-job/,
point 2.).
I don't remember having seen this anywhere in the wild. I believe it is a
good idea to simplify our codebase here.
If
Hi Sivaprasanna,
thanks a lot for your proposal. Now that I ran into a HadoopUtils-related
issue myself [1] I see the benefit in this proposal.
I'm happy to be the Flink committer that mentors this change. If we do
this, I would like to have a small scope for the initial change:
- create a
Robert Metzger created FLINK-17987:
--
Summary: KafkaITCase.testStartFromGroupOffsets fails with
SchemaException: Error reading field
Key: FLINK-17987
URL: https://issues.apache.org/jira/browse/FLINK-17987
Robert Metzger created FLINK-17968:
--
Summary: Hadoop Configuration is not properly serialized in
HBaseRowInputFormat
Key: FLINK-17968
URL: https://issues.apache.org/jira/browse/FLINK-17968
Project
+1 (binding)
Checks:
- diff to flink-shaded 1.10:
https://github.com/apache/flink-shaded/compare/release-10.0...release-11.0-rc1
- mvn clean install passes on the source archive
- sha of source archive is correct
- source archive is signed by Chesnay
- mvn staging repo looks reasonable
-
Robert Metzger created FLINK-17949:
--
Summary:
KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388
expected:<310> but was:<0>
Key: FLINK-17949
URL: https://issues.apache.org/ji
k which RELEASED Flink versions are affected by
> some bug, that user is searching for. Otherwise it might be a bit confusing
> if there are lots of bugs with both affects version and fix version set to
> the same value.
>
> Piotrek
>
> > On 25 May 2020, at 16:40, Robert Metzge
Robert Metzger created FLINK-17945:
--
Summary: Improve error reporting of Python CI tests
Key: FLINK-17945
URL: https://issues.apache.org/jira/browse/FLINK-17945
Project: Flink
Issue Type
posal
> > > > > > >
> > > > > > > This will bring some consistency to the process
> > > > > > >
> > > > > > > Regarding Closed vs Resolved, should we go back and switch all
> > the
> > > > > &g
Robert Metzger created FLINK-17915:
--
Summary:
TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error
while calling the test program: Could not retrieve JobResult
Key: FLINK-17915
Robert Metzger created FLINK-17914:
--
Summary:
HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214
expected:<2> but was:<0>
Key: FLINK-17914
URL: https://issues.apache.org/ji
Robert Metzger created FLINK-17912:
--
Summary: KafkaShuffleITCase.testAssignedToPartitionEventTime:
"Watermark should always increase"
Key: FLINK-17912
URL: https://issues.apache.org/jira/browse/F
Robert Metzger created FLINK-17911:
--
Summary: K8s e2e: error: timed out waiting for the condition on
deployments/flink-native-k8s-session-1
Key: FLINK-17911
URL: https://issues.apache.org/jira/browse/FLINK-17911
Robert Metzger created FLINK-17883:
--
Summary: Unable to configure write mode for FileSystem() connector
in PyFlink
Key: FLINK-17883
URL: https://issues.apache.org/jira/browse/FLINK-17883
Project
sed) only 1.10.x & 1.9.x are supported. Another say the most recent 3
> releases. However, I don't really find this information from any
> formal/credible sources, e.g. the project website. Maybe there is such
> information that I overlooked? If not, I would suggest to add it to our
>
Robert Metzger created FLINK-17877:
--
Summary: Add support for Python 3.8
Key: FLINK-17877
URL: https://issues.apache.org/jira/browse/FLINK-17877
Project: Flink
Issue Type: Improvement
Hi all,
I have the feeling that the semantics of some of our JIRA fields (mostly
"affects versions", "fix versions" and resolve / close) are not defined in
the same way by all the core Flink contributors, which leads to cases where
I spend quite some time on filling the fields correctly (at least
Hi Leonard,
for the first problem, I reported this to Microsoft a while ago, and they
acknowledged that it is a valid problem that they are going to address [1].
In the meantime, you can manually access the overview of all "master" and
"release-1.11" builds here:
Robert Metzger created FLINK-17851:
--
Summary:
FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement
Key: FLINK-17851
URL: https://issues.apache.org/jira/browse/FLINK-17
I like the idea of releasing Statefun more frequently to have faster
feedback cycles!
No objections for releasing 2.1.0 from my side.
On Wed, May 20, 2020 at 2:22 PM Tzu-Li (Gordon) Tai
wrote:
> Hi devs,
>
> Since Stateful Functions 2.0 was released early April,
> we've been getting some good
Robert Metzger created FLINK-17825:
--
Summary: HA end-to-end gets killed due to timeout
Key: FLINK-17825
URL: https://issues.apache.org/jira/browse/FLINK-17825
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-17824:
--
Summary: "Resuming Savepoint" e2e stalls indefinitely
Key: FLINK-17824
URL: https://issues.apache.org/jira/browse/FLINK-17824
Project: Flink
Microsoft has now doubled our CI capacity (to 20 concurrent VMs for
executing e2e tests).
If the e2e test execution is normalized tomorrow, I will revert the hotfix,
enabling e2e tests on PRs again.
Sorry for the back and forth.
On Tue, May 19, 2020 at 3:11 PM Robert Metzger wrote:
> Micros
Robert Metzger created FLINK-17817:
--
Summary: CollectResultFetcher fails with EOFException in
AggregateReduceGroupingITCase
Key: FLINK-17817
URL: https://issues.apache.org/jira/browse/FLINK-17817
!
Best,
Robert
On Thu, May 14, 2020 at 11:23 AM Robert Metzger wrote:
> Roughly speaking, I see the following problematic areas (I have initially
> tried running the E2E tests on those machines):
>
> a) e2e tests starting Docker images (including Kubernetes). Since the
> tests o
Robert Metzger created FLINK-17806:
--
Summary: CollectSinkFunctionTest.testCheckpointedFunction fails
with expected:<50> but was:<0>
Key: FLINK-17806
URL: https://issues.apache.org/jira/browse
Robert Metzger created FLINK-17801:
--
Summary: TaskExecutorTest.testHeartbeatTimeoutWithResourceManager
timeout
Key: FLINK-17801
URL: https://issues.apache.org/jira/browse/FLINK-17801
Project: Flink
are
> > > more
> > > > popular based on feedback, and accordingly, we can adjust our
> promotion
> > > > strategy. I think these would be great complementation to what we can
> > > > achieve solely through mailing lists, slack, or stack overflow today
Robert Metzger created FLINK-17790:
--
Summary: flink-connector-kafka-base does not compile on Java11
Key: FLINK-17790
URL: https://issues.apache.org/jira/browse/FLINK-17790
Project: Flink
Robert Metzger created FLINK-17787:
--
Summary: BucketStateSerializerTest fails on output mismatch
Key: FLINK-17787
URL: https://issues.apache.org/jira/browse/FLINK-17787
Project: Flink
Issue
Robert Metzger created FLINK-17772:
--
Summary: test_pandas_udf.py: NoClassDefFoundError
RowDataArrowPythonScalarFunctionRunner
Key: FLINK-17772
URL: https://issues.apache.org/jira/browse/FLINK-17772
Robert Metzger created FLINK-17771:
--
Summary: "PyFlink end-to-end test" fails with "The output result:
[] is not as expected: [2, 3, 4]!" on Java11
Key: FLINK-17771
URL: https://issues.ap
Robert Metzger created FLINK-17770:
--
Summary: TPC-DS end-to-end test (Blink planner) fails with
AskTimeoutException
Key: FLINK-17770
URL: https://issues.apache.org/jira/browse/FLINK-17770
Project
Robert Metzger created FLINK-17769:
--
Summary: Wrong order of log events on a task failure
Key: FLINK-17769
URL: https://issues.apache.org/jira/browse/FLINK-17769
Project: Flink
Issue Type
putting this together Marta!
> > >
> > > On Mon, May 11, 2020 at 8:35 AM Fabian Hueske
> wrote:
> > >
> > > > Thanks Marta and congratulations!
> > > >
> > > > Am Mo., 11. Mai 2020 um 14:55 Uhr schrieb Robert Metzger <
> > >
Robert Metzger created FLINK-17732:
--
Summary:
RescalingITCase.testSavepointRescalingOutPartitionedOperatorStateList
Key: FLINK-17732
URL: https://issues.apache.org/jira/browse/FLINK-17732
Project
Robert Metzger created FLINK-17731:
--
Summary: Artifact X already exists for build Y
Key: FLINK-17731
URL: https://issues.apache.org/jira/browse/FLINK-17731
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-17730:
--
Summary:
HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart
times out
Key: FLINK-17730
URL: https://issues.apache.org/jira/browse/FLINK-17730
I'm okay, but I would suggest to agree on a time of day. What about Monday
morning in Europe?
On Fri, May 15, 2020 at 1:43 PM Piotr Nowojski wrote:
> Hi,
>
> Couple of contributors asked for extending cutting the release branch
> until Monday, what do you think about such extension?
>
> (+1
Robert Metzger created FLINK-17725:
--
Summary: FileUploadHandlerTest.testUploadCleanupOnFailure fails
with "SocketTimeout timeout"
Key: FLINK-17725
URL: https://issues.apache.org/jira/browse/F
Robert Metzger created FLINK-17724:
--
Summary: PyFlink end-to-end test fails with Cannot run program
"venv.zip/.conda/bin/python": error=2, No such file or directory
Key: FLINK-17724
Robert Metzger created FLINK-17722:
--
Summary: "Failed to find the file" in "build_wheels" stage
Key: FLINK-17722
URL: https://issues.apache.org/jira/browse/FLINK-17722
Project: F
Robert Metzger created FLINK-17721:
--
Summary: AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry
fails with AssertionError
Key: FLINK-17721
URL: https://issues.apache.org/jira/browse/FLINK-17721
Robert Metzger created FLINK-17720:
--
Summary: StreamSqlTests.test_execute_sql: "AssertionError: True is
not false"
Key: FLINK-17720
URL: https://issues.apache.org/jira/browse/FLINK-17720
Robert Metzger created FLINK-17713:
--
Summary: "Stateful stream job upgrade end-to-end test" fails
Key: FLINK-17713
URL: https://issues.apache.org/jira/browse/FLINK-17713
Proj
Robert Metzger created FLINK-17697:
--
Summary: JDK11: JdbcFullTest.testEnrichedClassCastException:
expected:<[java.lang.String cannot be cast to java.lang.Double], field index:
3, fi...> but was:<[class java.lang.String
> Thanks for the update Robert.
>
> One idea to make the e2e also run on the Alibaba infrastructure would be to
> ensure that e2e tests clean up after they have run. Do we know which e2e
> tests don't do this properly?
>
> Cheers,
> Till
>
> On Thu, May 14, 2020 at 8:38
Robert Metzger created FLINK-17685:
--
Summary: Remove flink-shaded-hadoop-2-parent and submodules
Key: FLINK-17685
URL: https://issues.apache.org/jira/browse/FLINK-17685
Project: Flink
Issue
Hi all,
tl;dr: I will have to cancel some E2E test executions of pull requests
because we have reached the capacity limit of Flink's Azure Pipelines
account.
Long version: We have two types of agent pools in Azure Pipelines:
Microsoft-hosted VMs and Alibaba-hosted Docker environment.
In the
Robert Metzger created FLINK-17662:
--
Summary: testDetachedModeSecureWithPreInstallKeytab: "The
JobManager and the TaskManager should both run with Kerberos."
Key: FLINK-17662
URL: https://issues.apach
Robert Metzger created FLINK-17637:
--
Summary: HadoopS3RecoverableWriterITCase fails with Expected
exception: java.io.FileNotFoundException
Key: FLINK-17637
URL: https://issues.apache.org/jira/browse/FLINK-17637
Robert Metzger created FLINK-17636:
--
Summary:
SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read
from released RecoveredInputChannel
Key: FLINK-17636
URL: https://issues.apache.org
Robert Metzger created FLINK-17627:
--
Summary: Add support for writing _SUCCESS file with
StreamingFileSink
Key: FLINK-17627
URL: https://issues.apache.org/jira/browse/FLINK-17627
Project: Flink
; also
> >> > > > [1], which is about incorporating the existing Flink Training
> >> material
> >> > > > into the concepts section of the Flink doc.
> >> > > >
> >> > > > What I think would be very good is working on the Table API/SQL
> >> > > > documen
Fabian's idea is definitely nice, if we find somebody who wants to develop
such a site :)
Marta has raised valid concerns. Maybe we could start by creating a Wiki
page, that nicely categorizes the different items.
I'm happy to prominently link the Wiki page from the "Powered By" and
Starting
>
> >
> > On Tue, May 5, 2020 at 4:44 PM Till Rohrmann
> wrote:
> >
> > > I don't think that a post-release step makes sense since the release
> > > manager of release X won't necessarily be involved in the high level
> > > planning of the relea
Hey Yuan,
I like this idea lot!
As long as the material is non-commercial, and really for the purpose of
sharing knowledge and promoting Flink, it should be suitable for the Flink
website.
If we add such a page to Flink, it is important to keep it up to date. If I
remember correctly, we used to
Robert Metzger created FLINK-17592:
--
Summary: flink-table-planner doesn't compile on Scala 2.12
Key: FLINK-17592
URL: https://issues.apache.org/jira/browse/FLINK-17592
Project: Flink
Issue
Thanks a lot for creating another RC!
+1 (binding)
- checked diff to last RC:
https://github.com/apache/flink/compare/release-1.10.1-rc2...release-1.10.1-rc3
- kinesis dependency change is properly documented
- started Flink locally (on Java11 :) )
- seems to be build off the specified
Robert Metzger created FLINK-17581:
--
Summary: Update translation of S3 documentation
Key: FLINK-17581
URL: https://issues.apache.org/jira/browse/FLINK-17581
Project: Flink
Issue Type: Task
Robert Metzger created FLINK-17530:
--
Summary: Fix illegal reflective access by ClosureCleaner
Key: FLINK-17530
URL: https://issues.apache.org/jira/browse/FLINK-17530
Project: Flink
Issue
Robert Metzger created FLINK-17524:
--
Summary: Remove "An illegal reflective access operation has
occurred" on JDK11
Key: FLINK-17524
URL: https://issues.apache.org/jira/browse/FLINK-17524
ecessarily high.
>
> One way to ensure that the roadmap is kept fresh could be to make the
> update part of the release kick-off (for example, as part of the
> responsibilities of the release managers).
>
> What do you think?
>
> Marta
>
> On Mon, May 4, 2020 at 10:35 PM R
Robert Metzger created FLINK-17511:
--
Summary: "RocksDB Memory Management end-to-end test" fails with
"Current block cache usage 202123272 larger than expected memory limit
2"
Key: FLINK-17511
Robert Metzger created FLINK-17510:
--
Summary: StreamingKafkaITCase. testKafka timeouts on downloading
Kafka
Key: FLINK-17510
URL: https://issues.apache.org/jira/browse/FLINK-17510
Project: Flink
Hey all,
The roadmap has been updated last in September 2019. There is quite a bit
of outdated information on that page.
Is there a volunteer who wants to create a first draft for an updated
version?
On Mon, Aug 19, 2019 at 12:14 PM Robert Metzger wrote:
> Nice, thanks! Looking forw
401 - 500 of 1666 matches
Mail list logo
