Hi Dian,
Thanks for the review! Please see my reply inline.
Regards,
Dong
On Wed, Feb 8, 2023 at 11:58 AM Dian Fu wrote:
> Hi Dong,
>
>
> Thanks for driving this effort! This FLIP LGTM overall. I have just a few
> minor comments regarding the proposed API:
>
> 1) For the method `DataFrame.coll
Fan Hong created FLINK-30982:
Summary: Support checkpoint mechanism in GBT
Key: FLINK-30982
URL: https://issues.apache.org/jira/browse/FLINK-30982
Project: Flink
Issue Type: Sub-task
Co
Juntao Hu created FLINK-30981:
-
Summary: explain_sql throws java method not exist
Key: FLINK-30981
URL: https://issues.apache.org/jira/browse/FLINK-30981
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-30980:
Summary: Support s3.signer-type for S3
Key: FLINK-30980
URL: https://issues.apache.org/jira/browse/FLINK-30980
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-30979:
Summary: The buckets of the secondary partition should fall on
different tasks
Key: FLINK-30979
URL: https://issues.apache.org/jira/browse/FLINK-30979
Project: Flink
Qingsheng Ren created FLINK-30978:
-
Summary: ExecutorImplITCase.testInterruptExecution hangs waiting
for SQL gateway service closing
Key: FLINK-30978
URL: https://issues.apache.org/jira/browse/FLINK-30978
Joekwal created FLINK-30977:
---
Summary: flink tumbling window stream converting to pandas
dataframe not work
Key: FLINK-30977
URL: https://issues.apache.org/jira/browse/FLINK-30977
Project: Flink
I
Matthias Pohl created FLINK-30976:
-
Summary: docs_404_check fails occasionally
Key: FLINK-30976
URL: https://issues.apache.org/jira/browse/FLINK-30976
Project: Flink
Issue Type: Bug
Samrat Deb created FLINK-30975:
--
Summary: Upgrade aws sdk to v2
Key: FLINK-30975
URL: https://issues.apache.org/jira/browse/FLINK-30975
Project: Flink
Issue Type: Improvement
Reporte
xi chaomin created FLINK-30974:
--
Summary: NoClassDefFoundError
org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtils
Key: FLINK-30974
URL: https://issues.apache.org/jira/browse/FLINK-30974
Project:
Matthias Pohl created FLINK-30973:
-
Summary: e2e test prepare crashes with libssl dependency not being
available
Key: FLINK-30973
URL: https://issues.apache.org/jira/browse/FLINK-30973
Project: Flink
Lijie Wang created FLINK-30972:
--
Summary: E2e tests always fail in phase "Prepare E2E run"
Key: FLINK-30972
URL: https://issues.apache.org/jira/browse/FLINK-30972
Project: Flink
Issue Type: Bug
Yunhong Zheng created FLINK-30971:
-
Summary: Modify the default value of parameter
'table.exec.local-hash-agg.adaptive.sampling-threshold'
Key: FLINK-30971
URL: https://issues.apache.org/jira/browse/FLINK-30971
Hi David
Thanks for your answer.
> Can you elaborate more about how you'd intend to use the endpoint? I
think we can ultimately introduce a way of re-declaring "per-vertex
defaults," but I'd like to understand the use case bit more first.
For this issue, I mainly consider the consistency of user
Shengkai Fang created FLINK-30970:
-
Summary: Fix SQL Client doc still uses old style output
Key: FLINK-30970
URL: https://issues.apache.org/jira/browse/FLINK-30970
Project: Flink
Issue Type:
Juntao Hu created FLINK-30969:
-
Summary: Pyflink table example throws "module 'pandas' has no
attribute 'Int8Dtype'"
Key: FLINK-30969
URL: https://issues.apache.org/jira/browse/FLINK-30969
Project: Flink
Shammon created FLINK-30968:
---
Summary: Sql-client supports dynamic config to open session
Key: FLINK-30968
URL: https://issues.apache.org/jira/browse/FLINK-30968
Project: Flink
Issue Type: Improvem
Chesnay Schepler created FLINK-30967:
Summary: Add MongoDB connector documentation
Key: FLINK-30967
URL: https://issues.apache.org/jira/browse/FLINK-30967
Project: Flink
Issue Type: Sub-t
谢波 created FLINK-30966:
--
Summary: Flink SQL IF FUNCTION logic error
Key: FLINK-30966
URL: https://issues.apache.org/jira/browse/FLINK-30966
Project: Flink
Issue Type: Bug
Components: Table SQL
Matthias Pohl created FLINK-30965:
-
Summary: git-repo-sync doesn't pick up the 2nd-most-recently
published Flink version (even though it's still supported) after a new release
branch is cut
Key: FLINK-30965
URL:
Currently we use SupportsProjectionPushDown to push down physical columns,
and SupportsReadingMetadata is used to read metadata columns.
There is no problem when implementing one of the interfaces alone. If two
interfaces are implemented at the same time, there will be confusing
semantics.
For exa
Leonard Xu created FLINK-30964:
--
Summary: flink-mirror repo sync release branches failed
Key: FLINK-30964
URL: https://issues.apache.org/jira/browse/FLINK-30964
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-30963:
Summary: Switch binary downloads to archive.apache.org
Key: FLINK-30963
URL: https://issues.apache.org/jira/browse/FLINK-30963
Project: Flink
Issue T
Just as a reminder for everyone: Please label issues using the "starter"
label if you have Jira issues that are suitable for people that want to
start contributing. This is documented in the Flink Jira process
documentation [1].
Happy coding! Best,
Matthias
[1]
https://cwiki.apache.org/confluence
Moving the Dev mailing list to BCC and adding the User ML in this thread
On Wed, Feb 8, 2023 at 8:08 AM Amir Hossein Sharifzadeh <
amirsharifza...@gmail.com> wrote:
> Thanks. If you look at the code, I am defining/creating the table as:
>
> create_kafka_source_ddl = """
> CREATE TABLE pay
Juntao Hu created FLINK-30962:
-
Summary: Improve error messaging when launching py4j gateway server
Key: FLINK-30962
URL: https://issues.apache.org/jira/browse/FLINK-30962
Project: Flink
Issue Ty
Juntao Hu created FLINK-30961:
-
Summary: Remove deprecated tests_require in setup.py
Key: FLINK-30961
URL: https://issues.apache.org/jira/browse/FLINK-30961
Project: Flink
Issue Type: Improvement
Hello Yuxia,
Thanks for sharing these tickets.
I will look through some PRs of the ones that are already done there and
then ask to be assigned to an open one.
Best regards,
Jörn
On Wed, Feb 8, 2023 at 9:59 AM yuxia wrote:
> Hi, Joern.
> Weclome to contribute.
>
> As for contritbueingto SQL
Hi, Joern.
Weclome to contribute.
As for contritbueingto SQL part, i would like to recommend the FLINK-6810[1]
FLINK-20787 [2] as a start. By contributing it, you may get more familiar to
the stack of Flink SQL. I have no right to assign ticket, but i think you can
just comment in the jira y
Bo Shen created FLINK-30960:
---
Summary: OutOfMemory error using jdbc sink
Key: FLINK-30960
URL: https://issues.apache.org/jira/browse/FLINK-30960
Project: Flink
Issue Type: Bug
Components:
Hi Kevin!
Thanks for starting this discussion.
On a high level what you are proposing is quite simple: if the initial
savepoint path changes we use that for the upgrade.
I see a few caveats here that may be important:
1. To use a new savepoint/checkpoint path for recovery we have to stop the
j
Hello all,
I contributed 2 -3 commits once to fix small issues I found in Flink, and
would love to start contributing again.
I am interested in working on Testing or SQL (or anything else where help
is needed).
Is there anyone here who could assign me a smaller Jira ticket so I can get
started?
Hi Reme,
Please check out https://flink.apache.org/community.html#mailing-lists for
all details on the mailing lists and how to join them.
Best regards,
Martijn
On Wed, Feb 8, 2023 at 9:12 AM Reme Ajayi wrote:
> Hi there,
>
> I am a new Data Engineer. I would like to join this list in order t
Hi there,
I am a new Data Engineer. I would like to join this list in order to
contribute to Apache Flink.
Thanks,
Reme.
34 matches
Mail list logo
