[jira] [Created] (FLINK-19729) Create the FeedbackTransformation translator

2020-10-20 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19729: -- Summary: Create the FeedbackTransformation translator Key: FLINK-19729 URL: https://issues.apache.org/jira/browse/FLINK-19729 Project: Flink Issue Type:

[jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator

2020-10-20 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19730: -- Summary: Create the CoFeedbackTransformation translator Key: FLINK-19730 URL: https://issues.apache.org/jira/browse/FLINK-19730 Project: Flink Issue Type

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-10-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217367#comment-17217367 ] Leonard Xu commented on FLINK-19635: Sure, I'll have a look > HBaseConnectorITCase.

[jira] [Commented] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

2020-10-20 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217369#comment-17217369 ] Jiayi Liao commented on FLINK-16051: [~zjwang] This is reported by a user recently,

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

2020-10-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217368#comment-17217368 ] Leonard Xu commented on FLINK-19436: Sure, I'll have a look:) > TPC-DS end-to-end t

[jira] [Commented] (FLINK-19594) SubTasks start index don't unified and may confuse users

2020-10-20 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217372#comment-17217372 ] Jiayi Liao commented on FLINK-19594: Link an duplicated issue reported earlier.  htt

[jira] [Assigned] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-10-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19635: --- Assignee: Leonard Xu > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result >

[jira] [Assigned] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

2020-10-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19436: --- Assignee: Leonard Xu > TPC-DS end-to-end test (Blink planner) failed during shutdown >

[GitHub] [flink] flinkbot edited a comment on pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13577: URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705 ## CI report: * b56c3e8c4176504173eb1bb4dcc312082dabc4bc UNKNOWN * ba0ed645a060dc91363fb4334dadff0edcfb0e40 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #13616: [FLINK-18570][hbase][WIP] SQLClientHBaseITCase.testHBase fails on azure

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13616: URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760 ## CI report: * be3a69f7f525c963887a9cd0e8e293b9fe5062c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * 4873fb92710324b9d47682dcdfb707815d71bfc3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #13684: [FLINK-19707][table-runtime] Refactor table streaming file sink

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13684: URL: https://github.com/apache/flink/pull/13684#issuecomment-711859397 ## CI report: * 89cb7caace1af59acf545fb38d275020da6fe523 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217376#comment-17217376 ] Xintong Song commented on FLINK-19728: -- Sure. I'll look into this. > YARN tests fa

[jira] [Assigned] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19728: Assignee: Xintong Song > YARN tests failed with "RM uses DefaultResourceCalculator which

[GitHub] [flink] flinkbot edited a comment on pull request #13693: [Hotfix][Connector-hive] Fix the banned dependency of "_2.10" for sca…

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13693: URL: https://github.com/apache/flink/pull/13693#issuecomment-712561061 ## CI report: * 9ca6467a520659322fd91e1a4602f8556bd444f4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508262147 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@ prot

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508262147 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@ prot

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508264197 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@ prot

[jira] [Created] (FLINK-19731) 使用了批量执行SQL的api,job执行的时候,DataStream 不触发

2020-10-20 Thread little-tomato (Jira)
little-tomato created FLINK-19731: - Summary: 使用了批量执行SQL的api,job执行的时候,DataStream 不触发 Key: FLINK-19731 URL: https://issues.apache.org/jira/browse/FLINK-19731 Project: Flink Issue Type: Bug

[GitHub] [flink] leonardBang commented on a change in pull request #13679: [FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

2020-10-20 Thread GitBox
leonardBang commented on a change in pull request #13679: URL: https://github.com/apache/flink/pull/13679#discussion_r508267827 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -315,15

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508268432 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@ protect

[GitHub] [flink] aljoscha commented on pull request #13554: [FLINK-19493] In CliFrontend, make flow of Configuration more obvious

2020-10-20 Thread GitBox
aljoscha commented on pull request #13554: URL: https://github.com/apache/flink/pull/13554#issuecomment-712652388 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-20 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217384#comment-17217384 ] Antti Kaikkonen commented on FLINK-19692: - I did some testing with regular embed

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508270969 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@ prot

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-20 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:31 AM: --

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-20 Thread GitBox
pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508271579 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java ## @@ -526,6 +526,44 @@ public void te

[GitHub] [flink] carp84 closed pull request #13393: [FLINK-19238] [RocksDB] Sanity check for arena block size

2020-10-20 Thread GitBox
carp84 closed pull request #13393: URL: https://github.com/apache/flink/pull/13393 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 t

[GitHub] [flink] carp84 commented on pull request #13393: [FLINK-19238] [RocksDB] Sanity check for arena block size

2020-10-20 Thread GitBox
carp84 commented on pull request #13393: URL: https://github.com/apache/flink/pull/13393#issuecomment-712655399 > > I (previously @juha-mynttinen-king) switched over to this account. I think we can keep this PR, if that's fine for you @carp84. > > Actually, it didn't work out. I coul

[jira] [Closed] (FLINK-19268) Introduce batch-style execution for bounded keyed streams

2020-10-20 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19268. Resolution: Implemented All subtasks are done. > Introduce batch-style execution for boun

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-20 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:32 AM: --

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-20 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:34 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #13554: [FLINK-19493] In CliFrontend, make flow of Configuration more obvious

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13554: URL: https://github.com/apache/flink/pull/13554#issuecomment-704950126 ## CI report: * Unknown: [CANCELED](TBD) * ef47deeb469f6a6ad53287f787a23baacba3622b UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * a8432b0e26a5ba02b49f26a34f3f667df6808856 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

2020-10-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19316: -- Assignee: Kostas Kloudas > FLIP-134: Batch execution for the DataStream API > ---

[GitHub] [flink] aljoscha commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

2020-10-20 Thread GitBox
aljoscha commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508276355 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStreamBuilder.java ## @@ -60,14 +59,28 @@ */ private

[jira] [Updated] (FLINK-19356) Introduce FileLifeCycleListener to Buckets

2020-10-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19356: - Description: The interface: {code:java} /** * Listener about the status of file. */ @Internal

[jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode

2020-10-20 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19732: -- Summary: Disable Checkpointing when in BATCH mode Key: FLINK-19732 URL: https://issues.apache.org/jira/browse/FLINK-19732 Project: Flink Issue Type: Sub-

[GitHub] [flink] aljoscha commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

2020-10-20 Thread GitBox
aljoscha commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508277562 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/CEP.java ## @@ -52,7 +52,48 @@ DataStream input,

[GitHub] [flink] JingsongLi opened a new pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-20 Thread GitBox
JingsongLi opened a new pull request #13697: URL: https://github.com/apache/flink/pull/13697 ## What is the purpose of the change & Brief change log - Introduce createBucketWriter to BucketsBuilder: Compaction operator depends on BucketWriter to write compacted file. - Introdu

[jira] [Updated] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder

2020-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19357: --- Labels: pull-request-available (was: ) > Introduce createBucketWriter to BucketsBuilder > -

[jira] [Closed] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

2020-10-20 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16051. Resolution: Duplicate > Subtask ID in Overview-Subtasks should start from 1 >

[GitHub] [flink] flinkbot commented on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-20 Thread GitBox
flinkbot commented on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712662619 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] kl0u opened a new pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
kl0u opened a new pull request #13698: URL: https://github.com/apache/flink/pull/13698 ## What is the purpose of the change When a pipeline is executed in BATCH mode, its tasks are scheduled in independent regions and not all tasks are present throughout the execution. This implies

[jira] [Updated] (FLINK-19732) Disable Checkpointing when in BATCH mode

2020-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19732: --- Labels: pull-request-available (was: ) > Disable Checkpointing when in BATCH mode > ---

[GitHub] [flink] flinkbot commented on pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
flinkbot commented on pull request #13698: URL: https://github.com/apache/flink/pull/13698#issuecomment-712664579 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] [Assigned] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19700: Assignee: Nicholas Jiang (was: Xintong Song) > Make Kubernetes Client in KubernetesResou

[jira] [Assigned] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19700: Assignee: Xintong Song > Make Kubernetes Client in KubernetesResourceManagerDriver use io

[jira] [Assigned] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder

2020-10-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19357: Assignee: Jingsong Lee > Introduce createBucketWriter to BucketsBuilder > ---

[GitHub] [flink] carp84 commented on pull request #13688: Arena block size sanity

2020-10-20 Thread GitBox
carp84 commented on pull request #13688: URL: https://github.com/apache/flink/pull/13688#issuecomment-712666788 Thanks for continue working on this one @anonymouscodeholic . Checking the Azure test failure it's caused by FLINK-19619 and not related to changes here. I will review the latest

[jira] [Assigned] (FLINK-19356) Introduce FileLifeCycleListener to Buckets

2020-10-20 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19356: Assignee: Jingsong Lee > Introduce FileLifeCycleListener to Buckets > ---

[GitHub] [flink] flinkbot edited a comment on pull request #13554: [FLINK-19493] In CliFrontend, make flow of Configuration more obvious

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13554: URL: https://github.com/apache/flink/pull/13554#issuecomment-704950126 ## CI report: * Unknown: [CANCELED](TBD) * ef47deeb469f6a6ad53287f787a23baacba3622b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Commented] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217403#comment-17217403 ] Xintong Song commented on FLINK-19700: -- [~nicholasjiang] Sure, I've assigned you.

[GitHub] [flink] flinkbot edited a comment on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-710017891 ## CI report: * 489b695119de6553145a9fb39efb9ce033a2f1f1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] carp84 commented on pull request #13688: Arena block size sanity

2020-10-20 Thread GitBox
carp84 commented on pull request #13688: URL: https://github.com/apache/flink/pull/13688#issuecomment-712672608 Some quick comments: It seems the [comments](https://github.com/apache/flink/pull/13393#discussion_r502241882) on the javadoc of `RocksDBMemoryControllerUtils` (fix on the

[GitHub] [flink] flinkbot commented on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-20 Thread GitBox
flinkbot commented on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712672697 ## CI report: * b45885955bfdee4d4288f9273171e1d52379773f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] SteNicholas commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

2020-10-20 Thread GitBox
SteNicholas commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508293285 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStreamBuilder.java ## @@ -60,14 +59,28 @@ */ priva

[GitHub] [flink] flinkbot commented on pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
flinkbot commented on pull request #13698: URL: https://github.com/apache/flink/pull/13698#issuecomment-712673437 ## CI report: * 896df97b435150f2b0e4402315303ec83e1c9215 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] SteNicholas commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

2020-10-20 Thread GitBox
SteNicholas commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508292895 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/CEP.java ## @@ -52,7 +52,48 @@ DataStream input,

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217408#comment-17217408 ] Xintong Song commented on FLINK-19728: -- I think this is introduced by FLINK-19689.

[GitHub] [flink] aljoscha commented on a change in pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
aljoscha commented on a change in pull request #13698: URL: https://github.com/apache/flink/pull/13698#discussion_r508295090 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -266,6 +266,12 @@ private void con

[jira] [Commented] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217415#comment-17217415 ] Robert Metzger commented on FLINK-19469: Mh, why is this still failing on master

[GitHub] [flink] azagrebin commented on a change in pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-20 Thread GitBox
azagrebin commented on a change in pull request #13547: URL: https://github.com/apache/flink/pull/13547#discussion_r508297589 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java ## @@ -199,10 +208,11 @@ default int freeSlot(A

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217417#comment-17217417 ] Dian Fu commented on FLINK-19728: - [~xintongsong] Thanks a lot for looking into this iss

[GitHub] [flink] SteNicholas removed a comment on pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

2020-10-20 Thread GitBox
SteNicholas removed a comment on pull request #13676: URL: https://github.com/apache/flink/pull/13676#issuecomment-712553220 > I had a preliminary review. Overall this looks good but I had some comments on the API. @aljoscha thanks for your preliminary review. I have already replied

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2020-10-20 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217420#comment-17217420 ] Arvid Heise commented on FLINK-19589: - Hi [~Padarn], thank you for the ideas. I like

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217422#comment-17217422 ] Robert Metzger commented on FLINK-19728: I agree with your proposed resolution!

[GitHub] [flink] kl0u opened a new pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

2020-10-20 Thread GitBox
kl0u opened a new pull request #13699: URL: https://github.com/apache/flink/pull/13699 ## What is the purpose of the change Currently in Application Mode when we shutdown the cluster we always clean up the HA data of a job. This also includes the cases when the job fails due to a tr

[GitHub] [flink] kl0u closed pull request #13583: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary.

2020-10-20 Thread GitBox
kl0u closed pull request #13583: URL: https://github.com/apache/flink/pull/13583 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

[jira] [Updated] (FLINK-19695) Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException

2020-10-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19695: Fix Version/s: 1.11.3 1.12.0 > Writing Table with RowTime Column of type TIMESTAMP(3) t

[jira] [Updated] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

2020-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19728: --- Labels: pull-request-available test-stability (was: test-stability) > YARN tests failed wit

[GitHub] [flink] wuchong opened a new pull request #13701: [BP-1.11][FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

2020-10-20 Thread GitBox
wuchong opened a new pull request #13701: URL: https://github.com/apache/flink/pull/13701 This is a cherry-pick to release-1.11 branch. This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Updated] (FLINK-19731) 使用了批量执行SQL的api,job执行的时候,DataStream 不触发

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19731: --- Priority: Minor (was: Blocker) > 使用了批量执行SQL的api,job执行的时候,DataStream 不触发 > -

[GitHub] [flink] flinkbot commented on pull request #13700: [FLINK-19728][yarn][test] Revert FLINK-19689 and disable related test cases.

2020-10-20 Thread GitBox
flinkbot commented on pull request #13700: URL: https://github.com/apache/flink/pull/13700#issuecomment-712691626 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] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217445#comment-17217445 ] Robert Metzger commented on FLINK-19483: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] godfreyhe merged pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-20 Thread GitBox
godfreyhe merged pull request #13577: URL: https://github.com/apache/flink/pull/13577 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 t

[jira] [Reopened] (FLINK-19689) TaskExecutorProcessSpecContainerResourcePriorityAdapterTest fails

2020-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-19689: -- Reopen the ticket. The previous fix is reverted because it causes the IT cases fail. https://issu

[GitHub] [flink] xintongsong commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-20 Thread GitBox
xintongsong commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508335109 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +107,67 @@ KubernetesWatch watc

[jira] [Commented] (FLINK-19731) 使用了批量执行SQL的api,job执行的时候,DataStream 不触发

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217448#comment-17217448 ] Robert Metzger commented on FLINK-19731: Thank you for opening a ticket. I decre

[jira] [Closed] (FLINK-16579) Upgrade Calcite version to 1.26 for Flink SQL

2020-10-20 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-16579. -- Resolution: Implemented master: dc1da6a52496f67a52c99d7d39a5dd7266a42f5a > Upgrade Calcite version to

[GitHub] [flink] flinkbot commented on pull request #13701: [BP-1.11][FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

2020-10-20 Thread GitBox
flinkbot commented on pull request #13701: URL: https://github.com/apache/flink/pull/13701#issuecomment-712708903 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] kl0u commented on a change in pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
kl0u commented on a change in pull request #13698: URL: https://github.com/apache/flink/pull/13698#discussion_r508332076 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -266,6 +266,12 @@ private void configu

[GitHub] [flink] rmetzger commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

2020-10-20 Thread GitBox
rmetzger commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r508332498 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -101,6 +101,13 @@ under the License. true +

[jira] [Created] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

2020-10-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19733: Summary: Make fast_operation and slow_operation produce functions consistent Key: FLINK-19733 URL: https://issues.apache.org/jira/browse/FLINK-19733 Project: Flink

[jira] [Updated] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

2020-10-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-19733: - Issue Type: Improvement (was: New Feature) > Make fast_operation and slow_operation produce fun

[GitHub] [flink] gm7y8 commented on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-20 Thread GitBox
gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-712711411 @XComp I was able to identify the code fix. I working to unit test it had some issue with Flink set up to start a job with checkpoint and savepoint. it might take a day or so as I

[GitHub] [flink] caozhen1937 commented on pull request #13669: [FLINK-19684][Connector][jdbc] Fix the Jdbc-connector's 'lookup.max-retries' option implementation

2020-10-20 Thread GitBox
caozhen1937 commented on pull request #13669: URL: https://github.com/apache/flink/pull/13669#issuecomment-712696539 @wuchong, thank you, I add some tests. This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217438#comment-17217438 ] Robert Metzger commented on FLINK-19589: I was wondering if we could introduce a

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 3a9c127acf7d5615f5a32c7af35f8611b93cd6ab Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

2020-10-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217439#comment-17217439 ] Robert Metzger commented on FLINK-19483: https://dev.azure.com/apache-flink/apac

[jira] [Comment Edited] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2020-10-20 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217420#comment-17217420 ] Arvid Heise edited comment on FLINK-19589 at 10/20/20, 8:52 AM: --

[GitHub] [flink] kl0u commented on pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

2020-10-20 Thread GitBox
kl0u commented on pull request #13699: URL: https://github.com/apache/flink/pull/13699#issuecomment-712715009 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #13692: [FLINK-19624][table-planner-blink] Update deadlock break-up algorithm to cover more cases

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13692: URL: https://github.com/apache/flink/pull/13692#issuecomment-712551159 ## CI report: * a43126b85a2068c5605a804b5c46d5c3e669dbbd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

2020-10-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217455#comment-17217455 ] Dian Fu commented on FLINK-19483: - cc [~hxbks2ks] Could you help to take a look at this

[GitHub] [flink] flinkbot edited a comment on pull request #13694: [FLINK-19720][table-api] Introduce new Providers and parallelism API

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13694: URL: https://github.com/apache/flink/pull/13694#issuecomment-712569945 ## CI report: * b27370c0eb53a5f4b0799763b57bd73f79b1e386 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13616: [FLINK-18570][hbase][WIP] SQLClientHBaseITCase.testHBase fails on azure

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13616: URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760 ## CI report: * be3a69f7f525c963887a9cd0e8e293b9fe5062c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] aljoscha commented on a change in pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

2020-10-20 Thread GitBox
aljoscha commented on a change in pull request #13698: URL: https://github.com/apache/flink/pull/13698#discussion_r508343754 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -266,6 +266,12 @@ private void con

[GitHub] [flink] flinkbot commented on pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

2020-10-20 Thread GitBox
flinkbot commented on pull request #13699: URL: https://github.com/apache/flink/pull/13699#issuecomment-712700391 ## CI report: * 30c315c3eed0e0f32ceb06d3f7c64375c54c5014 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rkhachatryan commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-20 Thread GitBox
rkhachatryan commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508345496 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13650: [FLINK-19605][table-runtime-blink] Implement cumulative windowing for window aggregate operator

2020-10-20 Thread GitBox
flinkbot edited a comment on pull request #13650: URL: https://github.com/apache/flink/pull/13650#issuecomment-709271818 ## CI report: * 26d7b65b3e795a9aa597269fc04a00d38ef1a1ad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger closed pull request #13655: [FLINK-19664][e2e] Upload logs before tests time out

2020-10-20 Thread GitBox
rmetzger closed pull request #13655: URL: https://github.com/apache/flink/pull/13655 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

  1   2   3   4   5   6   >