[GitHub] [flink] flinkbot edited a comment on pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

flinkbot edited a comment on pull request #12028: URL: https://github.com/apache/flink/pull/12028#issuecomment-625656822 ## CI report: * 86e04bf10b62c7dd52655fc8a20340c3c0ba4d38 Azure:

[jira] [Commented] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126405#comment-17126405 ] Hequn Cheng commented on FLINK-18101: - Done. Test Python Transformer and Estimator. Test Wrapper

[jira] [Closed] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18101. --- Resolution: Resolved > Test Python Pipeline API including Transformer and Estimator >

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435231056 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java ## @@ -0,0 +1,271 @@ +/* + * Licensed

[jira] [Created] (FLINK-18130) File name conflict for different jobs in filesystem/hive sink

Jingsong Lee created FLINK-18130: Summary: File name conflict for different jobs in filesystem/hive sink Key: FLINK-18130 URL: https://issues.apache.org/jira/browse/FLINK-18130 Project: Flink

[GitHub] [flink] libenchao commented on pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

libenchao commented on pull request #12436: URL: https://github.com/apache/flink/pull/12436#issuecomment-638829696 @wuchong I have no more concerns, the pr LGTM now, +1 for merging. This is an automated message from the

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435232158 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java ## @@ -91,6 +92,20 @@

[GitHub] [flink] azagrebin commented on a change in pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

azagrebin commented on a change in pull request #12375: URL: https://github.com/apache/flink/pull/12375#discussion_r435232158 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java ## @@ -91,6 +92,20 @@

[jira] [Updated] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery

[ https://issues.apache.org/jira/browse/FLINK-18110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18110: - Component/s: Connectors / Hive Connectors / FileSystem > Bucket Listener in

[jira] [Updated] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery

[ https://issues.apache.org/jira/browse/FLINK-18110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18110: - Priority: Blocker (was: Major) > Bucket Listener in StreamingFileSink should notify for

[GitHub] [flink] JingsongLi opened a new pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

JingsongLi opened a new pull request #12485: URL: https://github.com/apache/flink/pull/12485 ## What is the purpose of the change The sink of different jobs (or the same SQL runs multiple times) will produce the same file name, the rename will fail, and different file systems

[jira] [Updated] (FLINK-18130) File name conflict for different jobs in filesystem/hive sink

[ https://issues.apache.org/jira/browse/FLINK-18130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18130: --- Labels: pull-request-available (was: ) > File name conflict for different jobs in

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 33b1ef0748285bc503363458a684ab237a64cd62 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

flinkbot commented on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-638835443 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

[GitHub] [flink] flinkbot edited a comment on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c947693b75eae2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12435: [FLINK-18059] [sql-client] Fix create/drop catalog statement can not be executed in sql client

flinkbot edited a comment on pull request #12435: URL: https://github.com/apache/flink/pull/12435#issuecomment-637372360 ## CI report: * 223701abe70c0815eb1f35af7383727385ce2e90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12480: [hotfix] Remove redundant backslash in the log of GPUDriver

flinkbot edited a comment on pull request #12480: URL: https://github.com/apache/flink/pull/12480#issuecomment-638732843 ## CI report: * 0704f5331a783e4d3dbd7c404e4b80c27e7b6a60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12471: [FLINK-18073][FLINK-18029][avro] Fix AvroRowDataSerializationSchema is not serializable and add IT cases

flinkbot edited a comment on pull request #12471: URL: https://github.com/apache/flink/pull/12471#issuecomment-638362836 ## CI report: * cd6af0ccaeda47e15c31f20df9743ab038b4bfa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12482: [FLINK-17831][doc] Add documentation for the new Kafka connector

flinkbot edited a comment on pull request #12482: URL: https://github.com/apache/flink/pull/12482#issuecomment-638825868 ## CI report: * c8c39d8552852d4b7fdbd84501052d08d9b0963d Azure:

[GitHub] [flink] flinkbot commented on pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

flinkbot commented on pull request #12483: URL: https://github.com/apache/flink/pull/12483#issuecomment-638835966 ## CI report: * d8400d687e17309f9c69c296fdbf16a1323a07f4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12484: [FLINK-18127][tests] Streamline manual execution of Java E2E tests

flinkbot commented on pull request #12484: URL: https://github.com/apache/flink/pull/12484#issuecomment-638836075 ## CI report: * 30b3c3dfdc501e2f8c54877d6a9c950e688dfd09 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] yangyichao-mango opened a new pull request #12486: [hotfix][docs] Modify the lateness definition according to the descri…

yangyichao-mango opened a new pull request #12486: URL: https://github.com/apache/flink/pull/12486 …ption ## What is the purpose of the change *Modify the lateness definition according to the description* ## Brief change log - *Change the lateness

[GitHub] [flink] flinkbot commented on pull request #12486: [hotfix][docs] Modify the lateness definition according to the descri…

flinkbot commented on pull request #12486: URL: https://github.com/apache/flink/pull/12486#issuecomment-638839397 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

[GitHub] [flink] wuchong commented on a change in pull request #12303: [FLINK-17625] [table] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

wuchong commented on a change in pull request #12303: URL: https://github.com/apache/flink/pull/12303#discussion_r435243944 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AppendOnlyTopNFunction.java ## @@

[GitHub] [flink] wuchong commented on a change in pull request #12303: [FLINK-17625] [table] Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

wuchong commented on a change in pull request #12303: URL: https://github.com/apache/flink/pull/12303#discussion_r435244412 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AppendOnlyTopNFunction.java ## @@

[GitHub] [flink] aljoscha commented on pull request #12479: [FLINK-17260] Fix StreamingKafkaITCase instabilities

aljoscha commented on pull request #12479: URL: https://github.com/apache/flink/pull/12479#issuecomment-638844041 I pushed the same changes also for `SQLClientKafkaITCase` This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

flinkbot commented on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-638848123 ## CI report: * 7fe7332d4767bbfb996e86f1b59d99c8c4713192 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12483: [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

flinkbot edited a comment on pull request #12483: URL: https://github.com/apache/flink/pull/12483#issuecomment-638835966 ## CI report: * d8400d687e17309f9c69c296fdbf16a1323a07f4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12352: [FLINK-17717][sql-parser] Throws for DDL create temporary system func…

flinkbot edited a comment on pull request #12352: URL: https://github.com/apache/flink/pull/12352#issuecomment-634517986 ## CI report: * 7dc817125d0684987814d45192eab87a41ebc5b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12484: [FLINK-18127][tests] Streamline manual execution of Java E2E tests

flinkbot edited a comment on pull request #12484: URL: https://github.com/apache/flink/pull/12484#issuecomment-638836075 ## CI report: * 30b3c3dfdc501e2f8c54877d6a9c950e688dfd09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot edited a comment on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638032908 ## CI report: * 12e3932ed8d74a59c0d4c28441b336284a2dffeb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12435: [FLINK-18059] [sql-client] Fix create/drop catalog statement can not be executed in sql client

flinkbot edited a comment on pull request #12435: URL: https://github.com/apache/flink/pull/12435#issuecomment-637372360 ## CI report: * 223701abe70c0815eb1f35af7383727385ce2e90 Azure:

[GitHub] [flink] flinkbot commented on pull request #12486: [hotfix][docs] Modify the lateness definition according to the descri…

flinkbot commented on pull request #12486: URL: https://github.com/apache/flink/pull/12486#issuecomment-638848235 ## CI report: * 21bab4df76688fccc953d68398fc2cad54b0a26a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-17961) Create an Elasticsearch source

[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119635#comment-17119635 ] Etienne Chauchot edited comment on FLINK-17961 at 6/4/20, 1:34 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #12352: [FLINK-17717][sql-parser] Throws for DDL create temporary system func…

flinkbot edited a comment on pull request #12352: URL: https://github.com/apache/flink/pull/12352#issuecomment-634517986 ## CI report: * 7dc817125d0684987814d45192eab87a41ebc5b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12475: [FLINK-18076][table sql / client] Sql client uses wrong class loader when parsing queries

flinkbot edited a comment on pull request #12475: URL: https://github.com/apache/flink/pull/12475#issuecomment-638593958 ## CI report: * 41240cd524255ffc7cf63d2bc2ee9ff38f3abcbd UNKNOWN * 49c19b93edb74ef702c97a4742f4936145913f35 Azure:

[GitHub] [flink] flinkbot commented on pull request #12487: [FLINK-17829][docs][jdbc] Add documentation for the new JDBC connector.

flinkbot commented on pull request #12487: URL: https://github.com/apache/flink/pull/12487#issuecomment-638911231 ## CI report: * 91172715268381f9bdaa7b2284fd322a9608a4ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot edited a comment on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638032908 ## CI report: * 028c7804132598c982cdc82506781df5a4fb753a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12485: [FLINK-18130][hive][fs-connector] File name conflict for different jobs in filesystem/hive sink

flinkbot edited a comment on pull request #12485: URL: https://github.com/apache/flink/pull/12485#issuecomment-638848123 ## CI report: * 7fe7332d4767bbfb996e86f1b59d99c8c4713192 Azure:

[GitHub] [flink] flinkbot commented on pull request #12488: [FLINK-18126][python] Correct the exception handling of the Python CompletableFuture

flinkbot commented on pull request #12488: URL: https://github.com/apache/flink/pull/12488#issuecomment-638911342 ## CI report: * 4f60d1df216f704acb71f6546d295ed5dc640e1f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Resolved] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid in Hadoop 3 build profile

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17404. Resolution: Fixed Merged to master (1.12.0) in

[GitHub] [flink] rkhachatryan opened a new pull request #12489: [FLINK-18136] Don't start channel state writing for savepoints (RPC)

rkhachatryan opened a new pull request #12489: URL: https://github.com/apache/flink/pull/12489 ## What is the purpose of the change `StreamTask.triggerCheckpoint` calls `channelStateWriter.start` unconditionally. For savepoints and when unaligned mode is disabled this is

[GitHub] [flink] flinkbot edited a comment on pull request #12482: [FLINK-17831][doc] Add documentation for the new Kafka connector

flinkbot edited a comment on pull request #12482: URL: https://github.com/apache/flink/pull/12482#issuecomment-638825868 ## CI report: * c8c39d8552852d4b7fdbd84501052d08d9b0963d Azure:

[jira] [Updated] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-18137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18137: --- Labels: test-stability (was: ) > JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint

[jira] [Created] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException

Robert Metzger created FLINK-18137: -- Summary: JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException Key: FLINK-18137 URL: https://issues.apache.org/jira/browse/FLINK-18137

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aihua Li updated FLINK-18115: - Labels: release-testing (was: ) > StabilityTest > - > > Key: FLINK-18115 >

[GitHub] [flink] flinkbot commented on pull request #12476: [FLINK-17902][python] Support the new interfaces about temporary functions in PyFlink

flinkbot commented on pull request #12476: URL: https://github.com/apache/flink/pull/12476#issuecomment-638622433 ## CI report: * b874a610cfa519d36b7a26d991568fc6d993bb56 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12460: [FLINK-18063][checkpointing] Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #12460: URL: https://github.com/apache/flink/pull/12460#issuecomment-638102290 ## CI report: * c3f3aca669da2619d58190e684479c3fadd7026f Azure:

[jira] [Created] (FLINK-18115) StabilityTest

Aihua Li created FLINK-18115: Summary: StabilityTest Key: FLINK-18115 URL: https://issues.apache.org/jira/browse/FLINK-18115 Project: Flink Issue Type: Test Components: API / Core, API

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125587#comment-17125587 ] YufeiLiu commented on FLINK-18070: -- [~libenchao] I feel uncertain about why we need "_materialize

[GitHub] [flink] flinkbot edited a comment on pull request #12460: [FLINK-18063][checkpointing] Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #12460: URL: https://github.com/apache/flink/pull/12460#issuecomment-638102290 ## CI report: * c3f3aca669da2619d58190e684479c3fadd7026f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12476: [FLINK-17902][python] Support the new interfaces about temporary functions in PyFlink

flinkbot edited a comment on pull request #12476: URL: https://github.com/apache/flink/pull/12476#issuecomment-638622433 ## CI report: * b874a610cfa519d36b7a26d991568fc6d993bb56 Azure:

[jira] [Commented] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125594#comment-17125594 ] Robert Metzger commented on FLINK-17824: hadoop 3.1.3

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125591#comment-17125591 ] Robert Metzger commented on FLINK-17260:

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125596#comment-17125596 ] Till Rohrmann commented on FLINK-15687: --- Sounds good to me [~xintongsong]. Go ahead. > Potential

[jira] [Reopened] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17194: I'm sorry, but I have to reopen this ticket again. Failure in this nights e2e test,

[GitHub] [flink] flinkbot edited a comment on pull request #12473: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

flinkbot edited a comment on pull request #12473: URL: https://github.com/apache/flink/pull/12473#issuecomment-638574481 ## CI report: * b481eaeaf53495c94556190ef2d0dce5aedc7884 Azure:

[jira] [Commented] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125607#comment-17125607 ] Robert Metzger commented on FLINK-18117: No, and the NameNode is running in a Docker container,

[GitHub] [flink] flinkbot edited a comment on pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

flinkbot edited a comment on pull request #12453: URL: https://github.com/apache/flink/pull/12453#issuecomment-637941328 ## CI report: * 0576ab0732c449f88663447101828e4ce69d1474 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * c23450c9e7735ca7bad0ff97c37480de6c420d0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 5a57da9ab11d0109d384490321cb470e96737ae2 Azure:

[jira] [Closed] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18006. Resolution: Fixed Fixed in: master: 640a56fee9d777ff2acb69ab6d77275e7373415d 1.11:

[GitHub] [flink-web] rmetzger commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

rmetzger commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-638655356 Thanks a lot, merging This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

[ https://issues.apache.org/jira/browse/FLINK-17926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17926. -- Resolution: Fixed Resolved in

[GitHub] [flink] zjffdu commented on a change in pull request #12346: [FLINK-17944][sql-client] Wrong output in sql client's table mode

zjffdu commented on a change in pull request #12346: URL: https://github.com/apache/flink/pull/12346#discussion_r435045007 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/MaterializedCollectStreamResult.java ## @@

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125629#comment-17125629 ] Aljoscha Krettek commented on FLINK-17260: -- I think this is two separate issues, for some

[jira] [Created] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints

Jark Wu created FLINK-18118: --- Summary: Some SQL Jobs with two input operators are loosing data with unaligned checkpoints Key: FLINK-18118 URL: https://issues.apache.org/jira/browse/FLINK-18118 Project:

[GitHub] [flink] klion26 commented on a change in pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

klion26 commented on a change in pull request #12420: URL: https://github.com/apache/flink/pull/12420#discussion_r43466 ## File path: docs/dev/table/streaming/joins.zh.md ## @@ -22,37 +22,35 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c947693b75eae2 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #12477: [FLINK-18037][Documentation]The doc of StreamTaskNetworkInput.java may has a redundant 'status'

flinkbot commented on pull request #12477: URL: https://github.com/apache/flink/pull/12477#issuecomment-638626794 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

[jira] [Created] (FLINK-18116) E2E performance test

Aihua Li created FLINK-18116: Summary: E2E performance test Key: FLINK-18116 URL: https://issues.apache.org/jira/browse/FLINK-18116 Project: Flink Issue Type: Test Components: API /

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125588#comment-17125588 ] Zhu Zhu commented on FLINK-17726: - I think it should be that in TM we do not allow `transitionState`

[jira] [Created] (FLINK-18117) "Kerberized YARN per-job on Docker test" "Could not start hadoop cluster."

Robert Metzger created FLINK-18117: -- Summary: "Kerberized YARN per-job on Docker test" "Could not start hadoop cluster." Key: FLINK-18117 URL: https://issues.apache.org/jira/browse/FLINK-18117

[jira] [Commented] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125597#comment-17125597 ] Till Rohrmann commented on FLINK-18117: --- [~rmetzger] do we know what process was occupying

[GitHub] [flink] pnowojski commented on pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

pnowojski commented on pull request #11541: URL: https://github.com/apache/flink/pull/11541#issuecomment-638644705 There are a couple of things left to do there. 1. For example test is marked with Ignore and I’m not sure if that’s a mistake, as the commit marking it ignored seemed

[GitHub] [flink] rmetzger commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

rmetzger commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r435041905 ## File path: tools/ci/compile.sh ## @@ -54,10 +54,22 @@ if [ $EXIT_CODE != 0 ]; then exit $EXIT_CODE fi -echo " Checking Scaladocs

[GitHub] [flink-web] asfgit closed pull request #342: [FLINK-17926] Fix the build problem of docker image

asfgit closed pull request #342: URL: https://github.com/apache/flink-web/pull/342 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

[jira] [Comment Edited] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125527#comment-17125527 ] Jark Wu edited comment on FLINK-17466 at 6/4/20, 7:30 AM: -- - master (1.12.0):

[jira] [Assigned] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-18091: - Assignee: Congxian Qiu(klion26) Thanks [~klion26], just assigned to you. > Test Relocatable

[jira] [Updated] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16451: Summary: Fix IndexOutOfBoundsException for DISTINCT AGG with constants (was: listagg with distinct for

[jira] [Comment Edited] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125525#comment-17125525 ] Jark Wu edited comment on FLINK-16451 at 6/4/20, 7:30 AM: -- - master (1.12.0):

[jira] [Closed] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17466. --- Resolution: Fixed > toRetractStream doesn't work correctly with Pojo conversion class >

[jira] [Closed] (FLINK-16451) Fix IndexOutOfBoundsException for DISTINCT AGG with constants

[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16451. --- Resolution: Fixed > Fix IndexOutOfBoundsException for DISTINCT AGG with constants >

[jira] [Commented] (FLINK-18055) Catalog does not exist in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-18055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125626#comment-17125626 ] Dawid Wysakowicz commented on FLINK-18055: -- Isn't it a duplicate of FLINK-17941? > Catalog

[GitHub] [flink] zhuxiaoshang opened a new pull request #12477: [FLINK-18037][Documentation]The doc of StreamTaskNetworkInput.java may has a redundant 'status'

zhuxiaoshang opened a new pull request #12477: URL: https://github.com/apache/flink/pull/12477 ## What is the purpose of the change The doc of StreamTaskNetworkInput.java may has a redundant 'status'. The doc of class StreamTaskNetworkInput as follows *

[jira] [Updated] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18037: --- Labels: pull-request-available (was: ) > The doc of StreamTaskNetworkInput.java may has a

[GitHub] [flink-web] zjffdu commented on pull request #344: [blog] flink on zeppelin - part2

zjffdu commented on pull request #344: URL: https://github.com/apache/flink-web/pull/344#issuecomment-638627939 Thanks for the review @MarkSfik , I have updated the post This is an automated message from the Apache Git

[jira] [Updated] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aihua Li updated FLINK-18116: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > E2E performance test >

[jira] [Updated] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18037: - Priority: Trivial (was: Minor) > The doc of StreamTaskNetworkInput.java may has a

[jira] [Updated] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18116: - Priority: Blocker (was: Major) > E2E performance test > > > Key:

[GitHub] [flink] zentol merged pull request #12477: [FLINK-18037][Documentation]The doc of StreamTaskNetworkInput.java may has a redundant 'status'

zentol merged pull request #12477: URL: https://github.com/apache/flink/pull/12477 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

[jira] [Closed] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18037. Fix Version/s: 1.12.0 Resolution: Fixed master:

[jira] [Assigned] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18116: Assignee: Aihua Li > E2E performance test > > > Key:

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18115: - Affects Version/s: (was: 1.10.0) 1.11.0 > StabilityTest > - > >

[jira] [Updated] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18037: - Priority: Minor (was: Major) > The doc of StreamTaskNetworkInput.java may has a

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18115: - Priority: Blocker (was: Major) > StabilityTest > - > > Key: FLINK-18115 >

[jira] [Assigned] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18115: Assignee: Aihua Li > StabilityTest > - > > Key: FLINK-18115 >

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aihua Li updated FLINK-18115: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > StabilityTest > - > >

[GitHub] [flink] flinkbot edited a comment on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

flinkbot edited a comment on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632089857 ## CI report: * b3fd51b309c78d9dd5056eed35dc2fe388665899 UNKNOWN * c29ec64e9bc260015c4b57395ace4a578926fa16 Azure:

[jira] [Updated] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18117: --- Summary: "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop

<    1   2   3   4   5   6   7   >