[jira] [Updated] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException

2021-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21654: --- Labels: pull-request-available test-stability (was: test-stability) > YARNSessionCapacitySc

[jira] [Updated] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-21707: Description: Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers. T

[GitHub] [flink] XComp opened a new pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-09 Thread GitBox
XComp opened a new pull request #15134: URL: https://github.com/apache/flink/pull/15134 I didn't add these tests in [3436381](https://github.com/apache/flink/commit/3436381) as part of [FLINK-20659](https://issues.apache.org/jira/browse/FLINK-20659) because I thought of extending the docs

[jira] [Comment Edited] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298608#comment-17298608 ] Zhu Zhu edited comment on FLINK-21707 at 3/10/21, 7:56 AM: --- cc

[jira] [Commented] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298608#comment-17298608 ] Zhu Zhu commented on FLINK-21707: - cc [~trohrmann][~mapohl] > Job is possible to hang w

[jira] [Created] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-09 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-21707: --- Summary: Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers Key: FLINK-21707 URL: https://issues.apache.org/jira/browse/FLINK-21707 Proje

[jira] [Commented] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException

2021-03-09 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298605#comment-17298605 ] Matthias commented on FLINK-21654: -- Thanks for reporting this [~maguowei]. This is a kn

[jira] [Updated] (FLINK-21684) Fix typo in StreamExecDeduplicate

2021-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21684: Component/s: Table SQL / Planner > Fix typo in StreamExecDeduplicate > - >

[jira] [Updated] (FLINK-21684) Fix typo in StreamExecDeduplicate

2021-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21684: Fix Version/s: (was: 1.13') 1.13.0 > Fix typo in StreamExecDeduplicate > --

[jira] [Closed] (FLINK-21684) Fix typo in StreamExecDeduplicate

2021-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21684. --- Fix Version/s: 1.13' Assignee: wangpeibin Resolution: Fixed Fixed in master: 8bd18ff249ee464

[GitHub] [flink] wuchong merged pull request #15122: [FLINK-21684][table-planner-blink] Fix typo in StreamExecDeduplicate

2021-03-09 Thread GitBox
wuchong merged pull request #15122: URL: https://github.com/apache/flink/pull/15122 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

[GitHub] [flink] flinkbot commented on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-09 Thread GitBox
flinkbot commented on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * 3ff8f4a973c368ff82f56414abe7d53f825beb2e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-790411183 ## CI report: * 1524b7f54e207fe1c09b1899da0b3d6ab84b7b48 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449 ## CI report: * d98424b40ed962803bf6151185119d4dc5affaf7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15130: [FLINK-21632][python] Add NamespacedStateView and PerWindowStateDataViewStore

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15130: URL: https://github.com/apache/flink/pull/15130#issuecomment-794821417 ## CI report: * 1355c454f84507fcc4aaa0e56529a397d86f47ae Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15068: URL: https://github.com/apache/flink/pull/15068#issuecomment-789459239 ## CI report: * 2a67bce07c78b6fc8a86184dfd5a7c499afffd7d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 097472900d4be5c87466bf7678aa506f6fd5d463 UNKNOWN * 9cacc1de62eda2f1389ae382fd78b54222c148e7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] wuchong commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-09 Thread GitBox
wuchong commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r591160927 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java ## @@ -0,0 +1,269 @@ +/* + * L

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-09 Thread Peng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298595#comment-17298595 ] Peng Zhang commented on FLINK-21685: [~fly_in_gis] we are running in a production K8

[GitHub] [flink] KevinyhZou commented on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

2021-03-09 Thread GitBox
KevinyhZou commented on pull request #15068: URL: https://github.com/apache/flink/pull/15068#issuecomment-795025084 > @KevinyhZou The PR generally LGTM, could you fix my last minor comment and rebase to latest master? hello, I have rebased to latest master and create a new test case

[GitHub] [flink] wuchong commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
wuchong commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-795024638 I just think it's weired `Sink Parallelism` is not a sub-section of `sink`. I agree `sink.parallelism` works both in batch and streaming. But other streaming sink options will a

[jira] [Assigned] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management

2021-03-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21177: Assignee: Xintong Song > Introduce the counterpart of slotmanager.number-of-slots.max in

[GitHub] [flink] flinkbot commented on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-09 Thread GitBox
flinkbot commented on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795015309 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] wuchong commented on a change in pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

2021-03-09 Thread GitBox
wuchong commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r591006274 ## File path: docs/content.zh/docs/dev/table/sql/show.md ## @@ -244,6 +266,17 @@ table_env.execute_sql("SHOW FUNCTIONS").print() # | ... | # +

[GitHub] [flink] flinkbot commented on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-09 Thread GitBox
flinkbot commented on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449 ## CI report: * d98424b40ed962803bf6151185119d4dc5affaf7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-21694) Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num"

2021-03-09 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298588#comment-17298588 ] Jun Qin commented on FLINK-21694: - I think we should consider increasing this one as wel

[GitHub] [flink] flinkbot edited a comment on pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15128: URL: https://github.com/apache/flink/pull/15128#issuecomment-794821179 ## CI report: * ae8e4ac3942d6b5d43eaf79db3a506175e088f07 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * a056896cf1f92e4e4874e1e454e93898d097f431 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-790411183 ## CI report: * 1524b7f54e207fe1c09b1899da0b3d6ab84b7b48 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio

2021-03-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298584#comment-17298584 ] Dawid Wysakowicz commented on FLINK-21706: -- [~jqin] Could you help find somebod

[jira] [Created] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.B

2021-03-09 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21706: Summary: FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.BufferUnderflowException"

[jira] [Commented] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

2021-03-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298580#comment-17298580 ] Dawid Wysakowicz commented on FLINK-21416: -- https://dev.azure.com/apache-flink/

[jira] [Commented] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs

2021-03-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298579#comment-17298579 ] Dawid Wysakowicz commented on FLINK-20569: -- cc [~twalthr] Do you mind having a

[jira] [Commented] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs

2021-03-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298578#comment-17298578 ] Dawid Wysakowicz commented on FLINK-20569: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic

2021-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21621: --- Labels: pull-request-available (was: ) > Support TIMESTAMP_LTZ arithmetic > ---

[GitHub] [flink] leonardBang opened a new pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-09 Thread GitBox
leonardBang opened a new pull request #15133: URL: https://github.com/apache/flink/pull/15133 ## What is the purpose of the change * This pull request support TIMESTAMP_LTZ arithmetics like `TIMESTAMP_LTZ + interval '1' DAY` ## Brief change log - Enable TIMESTAMP_LTZ

[jira] [Commented] (FLINK-21695) Increase default value for number of KeyGroups

2021-03-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298572#comment-17298572 ] Yu Li commented on FLINK-21695: --- Thanks for the note [~sewen], I also noticed the blog thr

[GitHub] [flink] flinkbot edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 097472900d4be5c87466bf7678aa506f6fd5d463 UNKNOWN * 9cacc1de62eda2f1389ae382fd78b54222c148e7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] WeiZhong94 commented on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-09 Thread GitBox
WeiZhong94 commented on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-794989510 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot commented on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-09 Thread GitBox
flinkbot commented on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-794987599 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-21698) Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21698: --- Labels: pull-request-available (was: ) > Disable problematic cast conversion between NUMERI

[GitHub] [flink] yulei0824 commented on pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

2021-03-09 Thread GitBox
yulei0824 commented on pull request #15110: URL: https://github.com/apache/flink/pull/15110#issuecomment-794984669 Hi @wuchong, Could you please review this PR when you are free? This is an automated message from the Apache G

[GitHub] [flink] leonardBang opened a new pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-09 Thread GitBox
leonardBang opened a new pull request #15132: URL: https://github.com/apache/flink/pull/15132 ## What is the purpose of the change * This pull request disables problematic cast conversion between NUMERIC type and TIMESTAMP type ## Brief change log - Disable the cast

[GitHub] [flink] KarmaGYZ commented on a change in pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-09 Thread GitBox
KarmaGYZ commented on a change in pull request #15112: URL: https://github.com/apache/flink/pull/15112#discussion_r591120661 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java ## @@ -369,14 +373,21 @@ public Builder setManagedMemoryM

[GitHub] [flink] shouweikun edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
shouweikun edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-794979027 @wuchong > I think we can add a Sink Options section under Writing in Hive page, then describe the configurations are shared with file system sink and add a link

[GitHub] [flink] shouweikun edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
shouweikun edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-794979027 @wuchong > I think we can add a Sink Options section under Writing in Hive page, then describe the configurations are shared with file system sink and add a link

[GitHub] [flink] shouweikun commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
shouweikun commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-794979027 @wuchong > I think we can add a Sink Options section under Writing in Hive page, then describe the configurations are shared with file system sink and add a link Yep, s

[jira] [Closed] (FLINK-21705) Add a SliceType to the StateFun Java SDK

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21705. --- Resolution: Fixed flink-statefun/master: b1c50db25b9610e0362ab56dbd718b39d63cee2d >

[jira] [Closed] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21678. --- Resolution: Fixed flink-statefun/master: 039b2d298f617720196c272c6f769d8bbab1a394 >

[GitHub] [flink] wuchong commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
wuchong commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-794978325 @shouweikun what do you think? This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Closed] (FLINK-21663) Reject duplicate StatefulFunction registrations under the same typename

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21663. --- Resolution: Fixed flink-statefun/master: 3845226b82f64dd8a8f5a06d5840096beeaad3c7 >

[jira] [Closed] (FLINK-21676) Ensure that state names are valid identifiers in the StateFun Java SDK

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21676. --- Resolution: Fixed flink-statefun/master: 5e6e05b74701ec8617af966f3944a56023fd2783 >

[jira] [Closed] (FLINK-21662) Reject duplicate ValueSpec registrations under the same state name

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21662. --- Resolution: Fixed flink-statefun/master: c85f293cc9dc6bea369481710223b84cb909a8e2 >

[jira] [Closed] (FLINK-21642) RequestReplyFunction recovery fails with a remote SDK

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21642. --- Fix Version/s: statefun-3.0.0 Assignee: Igal Shilman Resolution: Fixe

[jira] [Closed] (FLINK-21577) SimpleType.simpleTypeFrom(...) complains with "Collection is empty"

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21577. --- Resolution: Fixed flink-statefun/master: 76858f526b58b13fe178422006c5220e65c93741 >

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * a056896cf1f92e4e4874e1e454e93898d097f431 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15124: [FLINK-21620][table-api / sql-parser ] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15124: URL: https://github.com/apache/flink/pull/15124#issuecomment-793694451 ## CI report: * 0225af7b7d3a0b952f164361ba56230fc4c80fd0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lirui-apache commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
lirui-apache commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-794975552 > I think we can add a `Sink Options` section under `Writing` in Hive page, then describe the configurations are shared with file system sink and add a link. `Sink Parallel

[GitHub] [flink-statefun] tzulitai merged pull request #209: [Java SDK] Miscellaneous Java SDK improvements

2021-03-09 Thread GitBox
tzulitai merged pull request #209: URL: https://github.com/apache/flink-statefun/pull/209 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

[jira] [Created] (FLINK-21705) Add a SliceType to the StateFun Java SDK

2021-03-09 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21705: --- Summary: Add a SliceType to the StateFun Java SDK Key: FLINK-21705 URL: https://issues.apache.org/jira/browse/FLINK-21705 Project: Flink Issue

[GitHub] [flink] fsk119 commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-09 Thread GitBox
fsk119 commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r591110332 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java ## @@ -0,0 +1,269 @@ +/* + * Li

[GitHub] [flink] fsk119 commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-09 Thread GitBox
fsk119 commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r591109797 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java ## @@ -0,0 +1,269 @@ +/* + * Li

[jira] [Assigned] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21700: --- Assignee: Junfan Zhang > Allow to disable fetching Hadoop delegation token on Yarn > --

[jira] [Comment Edited] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298540#comment-17298540 ] Junfan Zhang edited comment on FLINK-21700 at 3/10/21, 6:31 AM: --

[GitHub] [flink] flinkbot commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread GitBox
flinkbot commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * a056896cf1f92e4e4874e1e454e93898d097f431 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15124: [FLINK-21620][table-api / sql-parser ] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15124: URL: https://github.com/apache/flink/pull/15124#issuecomment-793694451 ## CI report: * 0225af7b7d3a0b952f164361ba56230fc4c80fd0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15122: [FLINK-21684][table-planner-blink] Fix typo in StreamExecDeduplicate

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15122: URL: https://github.com/apache/flink/pull/15122#issuecomment-793493161 ## CI report: * f66987e970f0ccb09e9be7084e533d577e9bd5de Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15083: [FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15083: URL: https://github.com/apache/flink/pull/15083#issuecomment-790411183 ## CI report: * 1524b7f54e207fe1c09b1899da0b3d6ab84b7b48 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * 0c8fa5d1aa21c6b98134ec528c8001b55d326b38 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-21704) Support StreamExecChangelogNormalize json serde

2021-03-09 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21704: --- Summary: Support StreamExecChangelogNormalize json serde Key: FLINK-21704 URL: https://issues.apache.org/jira/browse/FLINK-21704 Project: Flink Issue Type: Sub

[jira] [Commented] (FLINK-20557) Support statement set in SQL CLI

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298548#comment-17298548 ] Shengkai Fang commented on FLINK-20557: --- Thanks you for your help [~nicholasjiang]

[jira] [Commented] (FLINK-20557) Support statement set in SQL CLI

2021-03-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298547#comment-17298547 ] Nicholas Jiang commented on FLINK-20557: [~fsk119], [~jark], IMO, I could work f

[jira] [Assigned] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21462: --- Assignee: Shengkai Fang > Use configuration to store the option and value in Sql client > -

[jira] [Commented] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298546#comment-17298546 ] Shengkai Fang commented on FLINK-21462: --- [~jark] Could you assign it to me. I have

[jira] [Updated] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21462: -- Summary: Use configuration to store the option and value in Sql client (was: Use `table.plann

[jira] [Updated] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21462: -- Description: In this jira, we will also deprecate the yaml file. > Use configuration to store

[jira] [Updated] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21702: -- Parent: FLINK-21454 Issue Type: Sub-task (was: Bug) > Support option `sql-client.verb

[jira] [Updated] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21702: -- Component/s: (was: Table SQL / API) Table SQL / Client > Support option `

[jira] [Closed] (FLINK-21703) Add option `table.dml-sync`

2021-03-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-21703. - Resolution: Duplicate > Add option `table.dml-sync` > --- > >

[GitHub] [flink] flinkbot commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread GitBox
flinkbot commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794938493 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Created] (FLINK-21703) Add option `table.dml-sync`

2021-03-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21703: - Summary: Add option `table.dml-sync` Key: FLINK-21703 URL: https://issues.apache.org/jira/browse/FLINK-21703 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298543#comment-17298543 ] Junfan Zhang commented on FLINK-21700: -- Linked to [PR|https://github.com/apache/fli

[jira] [Updated] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21700: --- Labels: pull-request-available (was: ) > Allow to disable fetching Hadoop delegation token

[GitHub] [flink] zuston opened a new pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread GitBox
zuston opened a new pull request #15131: URL: https://github.com/apache/flink/pull/15131 Linked to [ISSUE](https://issues.apache.org/jira/browse/FLINK-21700#). ### Why I want to support Flink Action on Oozie. As we know, Oozie will obtain HDFS/HBase delegation token using Ha

[jira] [Created] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack

2021-03-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21702: - Summary: Support option `sql-client.verbos` to print the exception stack Key: FLINK-21702 URL: https://issues.apache.org/jira/browse/FLINK-21702 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * 6156ad8bc2bc72e49ca4e9df96f61277755abec4 UNKNOWN * 513788efa5d3c2d3674c4ab377fe7f9e333e3bc5 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298540#comment-17298540 ] Junfan Zhang commented on FLINK-21700: -- Anybody can assign this task to me? I have

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * c4c73b24c730472d974aa3d874e0a5c2e116ca51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-21700: - Description: h3. Why I want to support Flink Action on Oozie. As we know, Oozie will obtain H

[jira] [Created] (FLINK-21701) Extend the `RESET` command in the sql client

2021-03-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21701: - Summary: Extend the `RESET` command in the sql client Key: FLINK-21701 URL: https://issues.apache.org/jira/browse/FLINK-21701 Project: Flink Issue Type: Su

[jira] [Updated] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-21700: - Description: h3. Why I want to support Flink Action on Oozie. As we know, Oozie will obtain H

[jira] [Created] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-03-09 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-21700: Summary: Allow to disable fetching Hadoop delegation token on Yarn Key: FLINK-21700 URL: https://issues.apache.org/jira/browse/FLINK-21700 Project: Flink Iss

[GitHub] [flink] flinkbot edited a comment on pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15128: URL: https://github.com/apache/flink/pull/15128#issuecomment-794821179 ## CI report: * ae8e4ac3942d6b5d43eaf79db3a506175e088f07 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #14800: URL: https://github.com/apache/flink/pull/14800#issuecomment-769581041 ## CI report: * c4c73b24c730472d974aa3d874e0a5c2e116ca51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15128: URL: https://github.com/apache/flink/pull/15128#issuecomment-794821179 ## CI report: * ae8e4ac3942d6b5d43eaf79db3a506175e088f07 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15129: [FLINK-20979] [elasticsearch] Corrected Elasticsearch Documentation for sink.bulk-flush.max-actions

2021-03-09 Thread GitBox
flinkbot edited a comment on pull request #15129: URL: https://github.com/apache/flink/pull/15129#issuecomment-794821310 ## CI report: * 9fe82ea870e5394292cb0d1d749d87f5d6259c72 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

2021-03-09 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-21699: - Description: System.setProperty(JAVA_SECURITY_AUTH_LOGIN_CONFIG, configFile.getAbsolutePath()); "java.

[jira] [Created] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

2021-03-09 Thread tonychan (Jira)
tonychan created FLINK-21699: Summary: SecurityUtils JaasModule make JVM dirty Key: FLINK-21699 URL: https://issues.apache.org/jira/browse/FLINK-21699 Project: Flink Issue Type: Bug Com

[GitHub] [flink] lindong28 commented on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSch

2021-03-09 Thread GitBox
lindong28 commented on pull request #15051: URL: https://github.com/apache/flink/pull/15051#issuecomment-794892934 @becketqin @StephanEwen, could you take a look at this PR when you get time? We have more Kafka Source related PRs for review after this PR is merged. ---

[GitHub] [flink] xintongsong commented on a change in pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-09 Thread GitBox
xintongsong commented on a change in pull request #15112: URL: https://github.com/apache/flink/pull/15112#discussion_r590131518 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java ## @@ -93,7 +92,7 @@ private ResourceSpec(

  1   2   3   4   5   >