[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557522#comment-17557522
]
Gyula Fora commented on FLINK-28187:
We do upgrades in 2 steps, in the UPGRADING sta
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557518#comment-17557518
]
Aitozi commented on FLINK-28187:
IMO, there is one and only one job for one FlinkSessio
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557513#comment-17557513
]
Aitozi edited comment on FLINK-28187 at 6/22/22 3:19 PM:
-
I'm af
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557513#comment-17557513
]
Aitozi edited comment on FLINK-28187 at 6/22/22 3:16 PM:
-
I'm af
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557513#comment-17557513
]
Aitozi commented on FLINK-28187:
I'm afraid of not clearly expressing my meaning. I will
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-24666:
Description:
In stream processing, records will be deleted when exceed state ttl (if
configured),
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-24666:
Description:
In stream processing, records will be deleted when exceed state ttl (if
configured),
flinkbot commented on PR #20052:
URL: https://github.com/apache/flink/pull/20052#issuecomment-1163228801
## CI report:
* 3806a24b58270e39434a7c2e3f85e284c0b55ec6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-24666:
Description:
Currently, the lenient option was not exposed to users on
RetractableTopNFunction
{q
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-24666:
Summary: Add job level "table.exec.state-stale.error-handling" option and
apply to related statefu
[
https://issues.apache.org/jira/browse/FLINK-28047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557507#comment-17557507
]
Alexander Fedulov commented on FLINK-28047:
---
[~martijnvisser] this is also don
flinkbot commented on PR #20051:
URL: https://github.com/apache/flink/pull/20051#issuecomment-1163227528
## CI report:
* 36837b1b02a9ea3998c826b80377bcd1f518dffd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuyangzhong commented on PR #19866:
URL: https://github.com/apache/flink/pull/19866#issuecomment-1163227335
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific commen
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557506#comment-17557506
]
Biao Geng edited comment on FLINK-28199 at 6/22/22 3:03 PM:
xuyangzhong commented on PR #19850:
URL: https://github.com/apache/flink/pull/19850#issuecomment-1163226270
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific commen
[
https://issues.apache.org/jira/browse/FLINK-28047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-28047:
-
Assignee: Alexander Fedulov
> Annotate StreamExecutionEnvironment#readFile()/re
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557506#comment-17557506
]
Biao Geng commented on FLINK-28199:
---
According to the log, the exception is thrown as
[
https://issues.apache.org/jira/browse/FLINK-28047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28047:
---
Labels: pull-request-available (was: )
> Annotate StreamExecutionEnvironment#readFile()/rea
afedulov opened a new pull request, #20052:
URL: https://github.com/apache/flink/pull/20052
This is a trivial change that deprecates
StreamExecutionEnvironment#readFile()/readTextFile() methods.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24666:
---
Labels: pull-request-available (was: )
> Add job level "table.exec.state-staled.error-handl
lincoln-lil opened a new pull request, #20051:
URL: https://github.com/apache/flink/pull/20051
## What is the purpose of the change
In stream processing, records will be deleted when exceed state ttl (if
configured), and when the corresponding record's update arrives again, the
operator
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557498#comment-17557498
]
Ferenc Csaky commented on FLINK-28199:
--
Hm, this is weird. As I see this happened o
[
https://issues.apache.org/jira/browse/FLINK-28047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28047:
--
Summary: Annotate StreamExecutionEnvironment#readFile()/readTextFile(*)
methods deprec
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557494#comment-17557494
]
Feifan Wang commented on FLINK-27822:
-
Hi [~yunta] , can you help me review this pr
[
https://issues.apache.org/jira/browse/FLINK-28204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28204.
--
Resolution: Duplicate
> Deleting a FlinkDeployment results in an error on the pod
> --
[
https://issues.apache.org/jira/browse/FLINK-28204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557490#comment-17557490
]
Gyula Fora commented on FLINK-28204:
We will probably have a patch release (1.0.1) i
[
https://issues.apache.org/jira/browse/FLINK-28204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557473#comment-17557473
]
Matyas Orhidi commented on FLINK-28204:
---
Hi Matt, this is a know issue in v1.0.0.
gaborgsomogyi commented on PR #20011:
URL: https://github.com/apache/flink/pull/20011#issuecomment-1163162968
@MartijnVisser Thanks for making the PR better and for taking care!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-28166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28166.
--
Resolution: Fixed
merged to main 39d9d105b0f77298252e1ff917a2b5e30538ee9d
> Configurable Automatic Re
gyfora merged PR #273:
URL: https://github.com/apache/flink-kubernetes-operator/pull/273
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
gyfora commented on PR #275:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/275#issuecomment-1163158939
please use the `-Pgenerate-docs` maven flag to generate the new HTML files
for the updated config names
--
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-28205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28205.
--
Resolution: Invalid
[~michael201827] Please use English for your ticket
> jdbc connector 定时调度
[
https://issues.apache.org/jira/browse/FLINK-28112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28112.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: 5bcef81356f965ee9e6a8ab54b5fac
MartijnVisser merged PR #20011:
URL: https://github.com/apache/flink/pull/20011
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-28116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557466#comment-17557466
]
Deepika Sahu commented on FLINK-28116:
--
In earlier version of flink we had the prov
MartijnVisser commented on PR #19812:
URL: https://github.com/apache/flink/pull/19812#issuecomment-1163138222
Closing due to lack of activity
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the s
MartijnVisser closed pull request #19812: [hotfix] [docs] Fix misspelled word...
URL: https://github.com/apache/flink/pull/19812
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
flinkbot commented on PR #20050:
URL: https://github.com/apache/flink/pull/20050#issuecomment-1163137561
## CI report:
* 0c9af451265746abfe3102e2206cca42d39610ef UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
akalash commented on PR #20050:
URL: https://github.com/apache/flink/pull/20050#issuecomment-1163135979
@pnowojski, can you take a look at this, please? I moved all management of
the idling timer to MailboxProcessor which use it only from the mailbox thread.
--
This is an automated messag
michaelxiang created FLINK-28205:
Summary: jdbc connector 定时调度 flush 存在内存泄漏 bug
Key: FLINK-28205
URL: https://issues.apache.org/jira/browse/FLINK-28205
Project: Flink
Issue Type: Bug
akalash opened a new pull request, #20050:
URL: https://github.com/apache/flink/pull/20050
…r only from one thread.
## What is the purpose of the change
Backport of https://github.com/apache/flink/pull/18210
## Brief change log
Pausing and resuming idle metrics mov
Matt Casters created FLINK-28204:
Summary: Deleting a FlinkDeployment results in an error on the pod
Key: FLINK-28204
URL: https://issues.apache.org/jira/browse/FLINK-28204
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-27912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27912:
---
Labels: pull-request-available (was: )
> Improve operator config names
> --
czy006 opened a new pull request, #275:
URL: https://github.com/apache/flink-kubernetes-operator/pull/275
[FLINK-27912] Improve operator config names
@gyfora PLAT
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
fsk119 commented on code in PR #20007:
URL: https://github.com/apache/flink/pull/20007#discussion_r903487186
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java:
##
@@ -136,6 +147,45 @@ public BulkFormat
createRuntimeDecoder(
[
https://issues.apache.org/jira/browse/FLINK-27648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557450#comment-17557450
]
ConradJam commented on FLINK-27648:
---
I plan to retest the 1.1 version when it is ready
[
https://issues.apache.org/jira/browse/FLINK-27648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi closed FLINK-27648.
-
Resolution: Done
> Review example YAMLs in the documentation
> -
[
https://issues.apache.org/jira/browse/FLINK-27871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi closed FLINK-27871.
-
Resolution: Fixed
> Configuration change is undedected on config removal
> -
zentol commented on PR #20046:
URL: https://github.com/apache/flink/pull/20046#issuecomment-1163072309
> the following lines
Those tests rely on a system property set by the surefire-plugin. It's not
strictly reliant on the system property we set on the command-line / the maven
prope
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557439#comment-17557439
]
Gyula Fora commented on FLINK-28187:
I know we can't use arbitrary strings as jobid
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557438#comment-17557438
]
Gyula Fora commented on FLINK-28187:
I think the problem you highlight here could be
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28008:
--
Assignee: Matyas Orhidi
> Can not get secondary resource from context after operator restart
MartijnVisser merged PR #18779:
URL: https://github.com/apache/flink/pull/18779
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28008:
--
Priority: Blocker (was: Major)
> Can not get secondary resource from context after operator r
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557437#comment-17557437
]
Matyas Orhidi commented on FLINK-28008:
---
I'll have a look at it.
> Can not get se
MartijnVisser commented on PR #20030:
URL: https://github.com/apache/flink/pull/20030#issuecomment-1163067229
@dependabot rebase
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
MartijnVisser closed pull request #20034: Bump kotlin-stdlib from 1.3.50 to
1.6.0 in /flink-formats/flink-json-glue-schema-registry
URL: https://github.com/apache/flink/pull/20034
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
MartijnVisser closed pull request #20035: Bump kotlin-stdlib from 1.3.50 to
1.6.0 in /flink-end-to-end-tests/flink-glue-schema-registry-avro-test
URL: https://github.com/apache/flink/pull/20035
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
MartijnVisser closed pull request #20036: Bump kotlin-stdlib from 1.3.50 to
1.6.0 in /flink-formats/flink-avro-glue-schema-registry
URL: https://github.com/apache/flink/pull/20036
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
dependabot[bot] commented on PR #20034:
URL: https://github.com/apache/flink/pull/20034#issuecomment-1163066705
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or minor version, let
MartijnVisser commented on PR #20034:
URL: https://github.com/apache/flink/pull/20034#issuecomment-1163066646
This dependency is added to resolve dependency convergence. We would rather
get rid of it all together which is not yet possible. Therefore not bumping
this PR.
--
This is an au
MartijnVisser commented on PR #20036:
URL: https://github.com/apache/flink/pull/20036#issuecomment-1163066201
This dependency is added to resolve dependency convergence. We would rather
get rid of it all together which is not yet possible. Therefore not bumping
this PR.
--
This is an au
dependabot[bot] commented on PR #20035:
URL: https://github.com/apache/flink/pull/20035#issuecomment-1163066446
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or minor version, let
MartijnVisser commented on PR #20035:
URL: https://github.com/apache/flink/pull/20035#issuecomment-1163066413
This dependency is added to resolve dependency convergence. We would rather
get rid of it all together which is not yet possible. Therefore not bumping
this PR.
--
This is an au
Chesnay Schepler created FLINK-28203:
Summary: Mark all bundled dependencies as optional
Key: FLINK-28203
URL: https://issues.apache.org/jira/browse/FLINK-28203
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28008:
--
Fix Version/s: kubernetes-operator-1.1.0
> Can not get secondary resource from context after o
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28008:
--
Affects Version/s: kubernetes-operator-1.1.0
> Can not get secondary resource from context aft
dependabot[bot] commented on PR #20036:
URL: https://github.com/apache/flink/pull/20036#issuecomment-1163066251
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or minor version, let
Chesnay Schepler created FLINK-28202:
Summary: Generalize utils around shade-plugin
Key: FLINK-28202
URL: https://issues.apache.org/jira/browse/FLINK-28202
Project: Flink
Issue Type: Sub-
afedulov commented on PR #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1163063525
@MartijnVisser that was quick :) 👍
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the sp
wuchong commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1163056508
> Do you think this will likely stay the case?
Are these jars small enough that users won't worry about that?
Yes. Spark/Databricks also doesn't support remove jar[1]. If a user w
Chesnay Schepler created FLINK-28201:
Summary: Generalize utils around dependency-plugin
Key: FLINK-28201
URL: https://issues.apache.org/jira/browse/FLINK-28201
Project: Flink
Issue Type:
flinkbot commented on PR #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1163046742
## CI report:
* 4e3f9a5f5d9f30e495be4c6b8da021d0442f70fa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser commented on PR #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1163044783
@afedulov The only thing that's missing is starting your commit message with
`FLINK-28045`
--
This is an automated message from the Apache Git Service.
To respond to the message,
fsk119 commented on PR #19823:
URL: https://github.com/apache/flink/pull/19823#issuecomment-1163042529
Thanks for all guys' reviews and suggestions, especially @wuchong detailed
comments. I rebase the master and reorganize the commits.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25814:
---
Priority: Major (was: Minor)
> AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSave
[
https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25814:
---
Affects Version/s: 1.14.6
> AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepoin
[
https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25814:
---
Labels: test-stability (was: auto-deprioritized-major test-stability)
> AdaptiveSchedulerIT
[
https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557422#comment-17557422
]
Martijn Visser commented on FLINK-25814:
https://dev.azure.com/apache-flink/apac
afedulov opened a new pull request, #20049:
URL: https://github.com/apache/flink/pull/20049
This is a trivial change that marks SourceFunction API as @Deprecated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557416#comment-17557416
]
fengjk commented on FLINK-26270:
Copy that.
> Flink SQL write data to kafka by CSV form
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557414#comment-17557414
]
Martijn Visser commented on FLINK-26270:
[~jkf6...@163.com] I've assigned it to
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26270:
--
Assignee: fengjk
> Flink SQL write data to kafka by CSV format , decimal type was con
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26270:
---
Fix Version/s: (was: 1.12.4)
> Flink SQL write data to kafka by CSV format , decimal typ
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557410#comment-17557410
]
fengjk commented on FLINK-26270:
Can you assign this problem to me.
> Flink SQL write d
Aitozi commented on PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#issuecomment-1163019156
Thanks for this nice work, the new hierarchy looks good to me, I will take a
closer look tonight or tomorrow
--
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557404#comment-17557404
]
Aitozi commented on FLINK-28187:
I get your meaning now, but I think the case is a bit d
bobby-richard commented on PR #20048:
URL: https://github.com/apache/flink/pull/20048#issuecomment-1163016577
@MartijnVisser Sure, could you point me in the right direction? I couldn't
find any existing tests for the row converters. Does it need to be an
integration test with a postgres con
flinkbot commented on PR #20048:
URL: https://github.com/apache/flink/pull/20048#issuecomment-1163008132
## CI report:
* 1efa958a738744969e25c59f1ce58f65c0d972d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Description:
In hive, it's support to cast timestamp to decimal implictly with following sql:
{code:java
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Summary: Hive dialect supports cast timestamp to decimal (was: Hive
dialect supports cast timestamp to
Jingsong Lee created FLINK-28200:
Summary: Add Table Store Hive reader documentation
Key: FLINK-28200
URL: https://issues.apache.org/jira/browse/FLINK-28200
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-19869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19869:
---
Labels: pull-request-available (was: )
> Flink SQL JDBC connector for Postgres can't handle
bobby-richard opened a new pull request, #20048:
URL: https://github.com/apache/flink/pull/20048
## What is the purpose of the change
Add support for reading and writing postgres UUID types via Flink SQL STRING
type
## Brief change log
- modified AbstractJdbcRowConve
[
https://issues.apache.org/jira/browse/FLINK-28197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28197:
---
Fix Version/s: (was: 1.16.0)
> Flink didn't deletes the YARN application files when the
[
https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557392#comment-17557392
]
Martijn Visser commented on FLINK-27703:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27703:
---
Priority: Critical (was: Major)
> FileChannelManagerImplTest.testDirectoriesCleanupOnKillWi
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557390#comment-17557390
]
Martijn Visser commented on FLINK-28199:
[~ferenc-csaky] [~bgeng777] This error
Martijn Visser created FLINK-28199:
--
Summary: Failures on
YARNHighAvailabilityITCase.testClusterClientRetrieval and
YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint
Key: FLINK-28199
URL: https://i
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557388#comment-17557388
]
Martijn Visser commented on FLINK-28198:
[~echauchot] I'm seeing this failure qu
101 - 200 of 312 matches
Mail list logo
