godfrey he created FLINK-18621:
--
Summary: Simplify the methods of Executor interface in sql client
Key: FLINK-18621
URL: https://issues.apache.org/jira/browse/FLINK-18621
Project: Flink
Issue Ty
Dian Fu created FLINK-18622:
---
Summary: Add limit method in the Python Table API
Key: FLINK-18622
URL: https://issues.apache.org/jira/browse/FLINK-18622
Project: Flink
Issue Type: Task
Com
Fabian Hueske created FLINK-18623:
-
Summary: CREATE TEMPORARY TABLE not documented
Key: FLINK-18623
URL: https://issues.apache.org/jira/browse/FLINK-18623
Project: Flink
Issue Type: Bug
Generally, I tend to continue the vote if this is not a blocking issue for the
following reasons:
- As discussed in the discussion thread[1], this release is mainly to fix the
CDC bug to provide a complete CDC feature.
- We are still in an early stage after 1.11.0 release, so I think there will
Jingsong Lee created FLINK-18624:
Summary: Document CREATE TEMPORARY TABLE
Key: FLINK-18624
URL: https://issues.apache.org/jira/browse/FLINK-18624
Project: Flink
Issue Type: New Feature
You could approach testing this in the same way that Flink has implemented
its unit tests for KeyedBroadcastProcessFunctions, which is to use
a KeyedTwoInputStreamOperatorTestHarness with
a CoBroadcastWithKeyedOperator. To learn how to use Flink's test harnesses,
see [1], and for an example of test
Liu created FLINK-18625:
---
Summary: Maintain redundant taskmanagers to speed up failover
Key: FLINK-18625
URL: https://issues.apache.org/jira/browse/FLINK-18625
Project: Flink
Issue Type: New Feature
gaoling ma created FLINK-18626:
--
Summary: the result of aggregate SQL on streaming cannot write to
upsert table sink
Key: FLINK-18626
URL: https://issues.apache.org/jira/browse/FLINK-18626
Project: Flin
Roey Shem Tov created FLINK-18627:
-
Summary: Get unmatch filter method records to side output
Key: FLINK-18627
URL: https://issues.apache.org/jira/browse/FLINK-18627
Project: Flink
Issue Type
Timo Walther created FLINK-18628:
Summary: Invalid error message for overloaded methods with same
parameter name
Key: FLINK-18628
URL: https://issues.apache.org/jira/browse/FLINK-18628
Project: Flink
Dawid Wysakowicz created FLINK-18629:
Summary: ConnectedStreams#keyBy can not derive key TypeInformation
for lambda KeySelectors
Key: FLINK-18629
URL: https://issues.apache.org/jira/browse/FLINK-18629
I agree with Dian. We can release a 1.11.2 shortly afterwards. Only
regressions compared to 1.11.0 should block this vote.
Regards,
Timo
On 17.07.20 10:48, Dian Fu wrote:
Generally, I tend to continue the vote if this is not a blocking issue for the
following reasons:
- As discussed in the di
David Anderson created FLINK-18630:
--
Summary: Improve solution to Long Rides training exercise
Key: FLINK-18630
URL: https://issues.apache.org/jira/browse/FLINK-18630
Project: Flink
Issue Ty
Roman Grebennikov created FLINK-18631:
-
Summary: Serializer for scala sealed trait hierarchies
Key: FLINK-18631
URL: https://issues.apache.org/jira/browse/FLINK-18631
Project: Flink
Issue
luoziyu created FLINK-18632:
---
Summary: RowData's row kind do not assigned from input row data
when sink code generate and physical type info is pojo type
Key: FLINK-18632
URL: https://issues.apache.org/jira/browse/FLINK
+1 (non-binding)
- checked/verified signatures and hashes
- built from source code with scala 2.11 succeeded
- checked that there are no missing artifacts
- started a cluster, the Web UI was accessible, submitted a wordcount job and
ran succeeded, no suspicious log output
- test using SQL Client
OK, I agree FLINK-18588 can wait for the next release.
On Fri, Jul 17, 2020 at 11:56 PM Leonard Xu wrote:
> +1 (non-binding)
>
> - checked/verified signatures and hashes
> - built from source code with scala 2.11 succeeded
> - checked that there are no missing artifacts
> - started a cluster, th
Hi ,
I did not find out of box flink sink connector for http and SQS mechanism.
Has anyone implemented it?
Wanted to know if we are writing a custom sink function , whether it
would affect semantic exactly one guarantees ?
Thanks ,
Prasanna
Hi there,
Here in Pinterest, we utilize thrift end to end in our tech stack. As we
have been building Flink as a service platform, the team spent time working
on supporting Flink jobs with thrift format and successfully launched a
good number of important jobs in Production in H1.
In H2, we are l
Dian Fu created FLINK-18633:
---
Summary: Download miniconda is instable
Key: FLINK-18633
URL: https://issues.apache.org/jira/browse/FLINK-18633
Project: Flink
Issue Type: Test
Components: A
Dian Fu created FLINK-18634:
---
Summary: FlinkKafkaProducerITCase.testRecoverCommittedTransaction
failed with "Timeout expired after 6milliseconds while awaiting
InitProducerId"
Key: FLINK-18634
URL: https://issues.a
21 matches
Mail list logo
