[GitHub] [flink] flinkbot edited a comment on pull request #13266: [FLINK-15719] fix mistake of reading state in scala lang.

flinkbot edited a comment on pull request #13266: URL: https://github.com/apache/flink/pull/13266#issuecomment-682067939 ## CI report: * e3bd4b8fcc871f1d0b6f6154515dee6268e70fd1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13264: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

flinkbot edited a comment on pull request #13264: URL: https://github.com/apache/flink/pull/13264#issuecomment-681943815 ## CI report: * 9098d03ed03d2427315216819ac216b88b124f85 Azure:

[jira] [Commented] (FLINK-19051) Exception message should be reserved in log When the Job Manager failed

[ https://issues.apache.org/jira/browse/FLINK-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185986#comment-17185986 ] Pua commented on FLINK-19051: - [~jark] [~lzljs3620320],what do you think? Now if job manager failed ,we

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185972#comment-17185972 ] Pua commented on FLINK-19064: - [~jark] [~rmetzger] ,According to the Javadoc,the connection should be

[GitHub] [flink] flinkbot commented on pull request #13266: [FLINK-15719] fix mistake of reading state in scala lang.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13265: [FLINK-19055] Wait less time for all memory GC in tests (MemoryManager#verifyEmpty)

flinkbot edited a comment on pull request #13265: URL: https://github.com/apache/flink/pull/13265#issuecomment-682059106 ## CI report: * af69156ea6dbc7513cb7dde023cdf8cc454bec31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * bce753ff7f4da2cffa295bd4007517af4c5697d8 Azure:

[jira] [Closed] (FLINK-18899) The property yarn.application-attempts default value is not none

[ https://issues.apache.org/jira/browse/FLINK-18899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18899. - Resolution: Fixed Fixed via e690793c6e65b711ab6cbd699e0b781adcafd03b > The property

[GitHub] [flink] tillrohrmann closed pull request #13258: [FLINK-18899][yarn] Enrich the description of 'yarn.application-attempts'

tillrohrmann closed pull request #13258: URL: https://github.com/apache/flink/pull/13258 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] [Updated] (FLINK-18899) The property yarn.application-attempts default value is not none

[ https://issues.apache.org/jira/browse/FLINK-18899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18899: -- Fix Version/s: 1.12.0 > The property yarn.application-attempts default value is not none >

[GitHub] [flink] azagrebin commented on a change in pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

azagrebin commented on a change in pull request #13181: URL: https://github.com/apache/flink/pull/13181#discussion_r478552732 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkChecker.java ## @@ -18,131 +18,14 @@

[GitHub] [flink] tillrohrmann commented on a change in pull request #13258: [FLINK-18899][yarn] Enrich the description of 'yarn.application-attempts'

tillrohrmann commented on a change in pull request #13258: URL: https://github.com/apache/flink/pull/13258#discussion_r478550796 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -82,9 +82,9 @@ public static final

[GitHub] [flink] flinkbot commented on pull request #13265: [FLINK-19055] Wait less time for all memory GC in tests (MemoryManager#verifyEmpty)

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

[GitHub] [flink] flinkbot edited a comment on pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

flinkbot edited a comment on pull request #13234: URL: https://github.com/apache/flink/pull/13234#issuecomment-679243226 ## CI report: * e5a866429bf22eb6aeeb26733e5ab1d705780e66 UNKNOWN * 1b6142f9dad4b3893629b2ec774c93adb5875e84 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

tillrohrmann commented on a change in pull request #13263: URL: https://github.com/apache/flink/pull/13263#discussion_r478544665 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManagerTest.java ## @@ -307,6 +308,33 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

flinkbot edited a comment on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-676985457 ## CI report: * 688923779cd4c4a10c3f05d7a5aa030ad4434785 Azure:

[GitHub] [flink] flinkbot commented on pull request #13266: [FLINK-15719] fix mistake of reading state in scala lang.

flinkbot commented on pull request #13266: URL: https://github.com/apache/flink/pull/13266#issuecomment-682058148 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] [Updated] (FLINK-15719) Exceptions when using scala types directly with the State Process API

[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15719: --- Labels: pull-request-available (was: ) > Exceptions when using scala types directly with

[GitHub] [flink] yingshin opened a new pull request #13266: [FLINK-15719] fix mistake of reading state in scala lang.

yingshin opened a new pull request #13266: URL: https://github.com/apache/flink/pull/13266 ## What is the purpose of the change give the right user guide to use state-processor api in scala language. ## Brief change log fix the code sample ##

[GitHub] [flink] flinkbot edited a comment on pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

flinkbot edited a comment on pull request #13234: URL: https://github.com/apache/flink/pull/13234#issuecomment-679243226 ## CI report: * e5a866429bf22eb6aeeb26733e5ab1d705780e66 UNKNOWN * 1b6142f9dad4b3893629b2ec774c93adb5875e84 Azure:

[GitHub] [flink] flinkbot commented on pull request #13265: [FLINK-19055] Wait less time for all memory GC in tests (MemoryManager#verifyEmpty)

flinkbot commented on pull request #13265: URL: https://github.com/apache/flink/pull/13265#issuecomment-682048215 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] azagrebin opened a new pull request #13265: [FLINK-19055] Wait less time for all memory GC in tests (MemoryManager#verifyEmpty)

azagrebin opened a new pull request #13265: URL: https://github.com/apache/flink/pull/13265 #12980 increased the waiting time to GC all allocated memory to verify that nothing is allocated in `MemoryManager`/`UnsafeMemoryBudget`. The waiting happens in a separate thread in production and

[jira] [Updated] (FLINK-19055) MemoryManagerSharedResourcesTest contains three tests running extraordinary long

[ https://issues.apache.org/jira/browse/FLINK-19055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19055: --- Labels: pull-request-available testability (was: testability) >

[jira] [Updated] (FLINK-19055) MemoryManagerSharedResourcesTest contains three tests running extraordinary long

[ https://issues.apache.org/jira/browse/FLINK-19055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19055: Fix Version/s: 1.10.3 1.11.2 1.12.0 >

[jira] [Updated] (FLINK-19055) MemoryManagerSharedResourcesTest contains three tests running extraordinary long

[ https://issues.apache.org/jira/browse/FLINK-19055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19055: Affects Version/s: (was: 1.11.1) 1.10.2 >

[GitHub] [flink] tillrohrmann commented on a change in pull request #13251: [FLINK-14435] Added memory configuration to TaskManagers REST endpoint

tillrohrmann commented on a change in pull request #13251: URL: https://github.com/apache/flink/pull/13251#discussion_r478457291 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorMemoryConfiguration.java ## @@ -0,0 +1,333 @@ +/* + *

[GitHub] [flink] pnowojski commented on pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on pull request #13234: URL: https://github.com/apache/flink/pull/13234#issuecomment-682038680 Thank you for the review @rkhachatryan, I've updated the PR. Could you take another look? This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

flinkbot edited a comment on pull request #13263: URL: https://github.com/apache/flink/pull/13263#issuecomment-681892463 ## CI report: * 990aa0f33e2fa93d40ea011082fedc6eeb37be44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13248: [FLINK-18222][e2e] Stabilize Avro Confluent Schema Registry nightly test

flinkbot edited a comment on pull request #13248: URL: https://github.com/apache/flink/pull/13248#issuecomment-680766918 ## CI report: * f89d112f560de7b16267eb66c4701c9bbf6e4112 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478513685 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -547,302 +675,38 @@ private void

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478510256 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -90,16 +91,19 @@ private

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478509078 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -208,19 +206,100 @@ public

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478505421 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -208,19 +206,100 @@ public

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478503638 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -53,42 +53,48 @@ public

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478502625 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputChainingOutput.java ## @@ -0,0 +1,138 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #13189: [FLINK-18661][Kinesis] Stream consumer Registration/Deregistration

flinkbot edited a comment on pull request #13189: URL: https://github.com/apache/flink/pull/13189#issuecomment-675350675 ## CI report: * 7594c2debe3cfeb8d4a216b65b5bda88054f12c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

flinkbot edited a comment on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-676985457 ## CI report: * 7170e6d063f5c8e7ddf4104d4beca360be3d8136 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478496041 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputChainingOutput.java ## @@ -0,0 +1,138 @@ +/* +

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478496041 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputChainingOutput.java ## @@ -0,0 +1,138 @@ +/* +

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478490967 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java ## @@ -160,81 +159,84 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13189: [FLINK-18661][Kinesis] Stream consumer Registration/Deregistration

flinkbot edited a comment on pull request #13189: URL: https://github.com/apache/flink/pull/13189#issuecomment-675350675 ## CI report: * 28ed27f1dc818d912aada32bcc2ff22a2d960c41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

flinkbot edited a comment on pull request #13193: URL: https://github.com/apache/flink/pull/13193#issuecomment-675460565 ## CI report: * dae6f793cca0d71b2aaaf860759a6f03506f9cc0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

flinkbot edited a comment on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-676985457 ## CI report: * 7170e6d063f5c8e7ddf4104d4beca360be3d8136 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 3d854c62355f9049062a7ae6a908dcceecd9c213 Azure:

[GitHub] [flink] hequn8128 commented on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

hequn8128 commented on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-682003680 @morsapaes Hi, thanks a lot for your suggestions. I have addressed the comments and updated the PR with three separate commits.

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r478469117 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java ## @@ -628,4 +622,46 @@ public String

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185887#comment-17185887 ] Jark Wu commented on FLINK-19064: - What [~rmetzger] said makes sense to me. {{configure()}} is not a

[jira] [Commented] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185883#comment-17185883 ] Yuri Gusev commented on FLINK-16504: Hi [~rmetzger], I'm an engineer working for

[jira] [Comment Edited] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185883#comment-17185883 ] Yuri Gusev edited comment on FLINK-16504 at 8/27/20, 2:24 PM: -- Hi

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185881#comment-17185881 ] Jark Wu commented on FLINK-19064: - [~nicholasjiang] you are right. The created connection should

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185878#comment-17185878 ] Robert Metzger commented on FLINK-19064: The problem is that the

[jira] [Updated] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

[ https://issues.apache.org/jira/browse/FLINK-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19065: Component/s: API / DataStream > java.lang.IllegalStateException: Auto generated UIDs have been disabled

[GitHub] [flink] wuchong commented on a change in pull request #13244: [FLINK-18333][jdbc] UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

wuchong commented on a change in pull request #13244: URL: https://github.com/apache/flink/pull/13244#discussion_r478448798 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -60,27

[GitHub] [flink] tillrohrmann commented on a change in pull request #13217: [FLINK-16866] Make job submission non-blocking

tillrohrmann commented on a change in pull request #13217: URL: https://github.com/apache/flink/pull/13217#discussion_r478403026 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java ## @@ -351,4 +352,53 @@ public static

[GitHub] [flink] hequn8128 commented on a change in pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

hequn8128 commented on a change in pull request #13203: URL: https://github.com/apache/flink/pull/13203#discussion_r478443841 ## File path: docs/dev/python/getting-started/tutorial/datastream_tutorial.md ## @@ -0,0 +1,126 @@ +--- +title: "Python DataStream API Tutorial"

[GitHub] [flink] wuchong merged pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

wuchong merged pull request #13212: URL: https://github.com/apache/flink/pull/13212 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-18973) Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18973. --- Fix Version/s: 1.12.0 Resolution: Fixed Translated in master (1.12.0):

[GitHub] [flink] wuchong commented on pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

wuchong commented on pull request #13212: URL: https://github.com/apache/flink/pull/13212#issuecomment-681967702 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Closed] (FLINK-18555) Make TableConfig options can be configured by string-based Configuration

[ https://issues.apache.org/jira/browse/FLINK-18555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18555. --- Resolution: Fixed Implemented in master(1.12.0): 94a27b5e36e9d224221ee7316d062dbd9dfa83f1 > Make

[GitHub] [flink] wuchong merged pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

wuchong merged pull request #12880: URL: https://github.com/apache/flink/pull/12880 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 edited a comment on pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

flinkbot edited a comment on pull request #13193: URL: https://github.com/apache/flink/pull/13193#issuecomment-675460565 ## CI report: * 6ca3029fb50b58d12bbfb87fbe79012195ba0b10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 76f5d0cbc997d1b0f6c47345900e09abed2f52bb Azure:

[GitHub] [flink] wuchong commented on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

wuchong commented on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-681966698 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185856#comment-17185856 ] Nicholas Jiang edited comment on FLINK-19064 at 8/27/20, 1:56 PM: --

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185856#comment-17185856 ] Nicholas Jiang commented on FLINK-19064: [~rmetzger] HBaseRowDataInputFormat should create

[GitHub] [flink] liming30 commented on a change in pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

liming30 commented on a change in pull request #13109: URL: https://github.com/apache/flink/pull/13109#discussion_r478431177 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/SelectedOutputsCollectorImpl.java ## @@ -0,0 +1,61

[GitHub] [flink] hequn8128 commented on a change in pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

hequn8128 commented on a change in pull request #13203: URL: https://github.com/apache/flink/pull/13203#discussion_r478430827 ## File path: docs/dev/python/getting-started/tutorial/datastream_tutorial.md ## @@ -0,0 +1,126 @@ +--- +title: "Python DataStream API Tutorial"

[GitHub] [flink] flinkbot edited a comment on pull request #13264: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

flinkbot edited a comment on pull request #13264: URL: https://github.com/apache/flink/pull/13264#issuecomment-681943815 ## CI report: * 9098d03ed03d2427315216819ac216b88b124f85 Azure:

[GitHub] [flink] liming30 commented on a change in pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

liming30 commented on a change in pull request #13109: URL: https://github.com/apache/flink/pull/13109#discussion_r478424895 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/SelectedOutputsCollectorImpl.java ## @@ -0,0 +1,62

[GitHub] [flink] flinkbot edited a comment on pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

flinkbot edited a comment on pull request #13193: URL: https://github.com/apache/flink/pull/13193#issuecomment-675460565 ## CI report: * 6ca3029fb50b58d12bbfb87fbe79012195ba0b10 Azure:

[jira] [Created] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

Maris created FLINK-19065: - Summary: java.lang.IllegalStateException: Auto generated UIDs have been disabled on join Key: FLINK-19065 URL: https://issues.apache.org/jira/browse/FLINK-19065 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metrics] Include side outputs in numRecordsOut metric.

flinkbot edited a comment on pull request #13109: URL: https://github.com/apache/flink/pull/13109#issuecomment-671381707 ## CI report: * 775d504a5713a48cfc59c98b4ec26cde75a60002 Azure:

[jira] [Created] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

Robert Metzger created FLINK-19064: -- Summary: HBaseRowDataInputFormat is leaking resources Key: FLINK-19064 URL: https://issues.apache.org/jira/browse/FLINK-19064 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #13264: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * 9e7d2cb792556814b91b8f580d9a1cbe98433274 Azure:

[GitHub] [flink] hequn8128 commented on pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

hequn8128 commented on pull request #13193: URL: https://github.com/apache/flink/pull/13193#issuecomment-681942105 @dianfu Thanks a lot for the review. I have addressed the comments and updated the PR. This is an automated

[GitHub] [flink] flinkbot commented on pull request #13264: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

flinkbot commented on pull request #13264: URL: https://github.com/apache/flink/pull/13264#issuecomment-681938644 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] [Updated] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19061: --- Fix Version/s: 1.11.2 > HiveCatalog fails to get partition column stats if partition value contains >

[GitHub] [flink] lirui-apache opened a new pull request #13264: [FLINK-19061][hive] HiveCatalog fails to get partition column stats i…

lirui-apache opened a new pull request #13264: URL: https://github.com/apache/flink/pull/13264 …f partition value contains special characters ## What is the purpose of the change Fix the issue that HiveCatalog fails to get partition column stats if partition value

[jira] [Updated] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19061: --- Labels: pull-request-available (was: ) > HiveCatalog fails to get partition column stats

[GitHub] [flink] tillrohrmann commented on a change in pull request #13217: [FLINK-16866] Make job submission non-blocking

tillrohrmann commented on a change in pull request #13217: URL: https://github.com/apache/flink/pull/13217#discussion_r478371328 ## File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java ## @@ -111,4 +122,48 @@ public static void executeProgram(

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * 9e7d2cb792556814b91b8f580d9a1cbe98433274 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * 9e7d2cb792556814b91b8f580d9a1cbe98433274 Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

azagrebin commented on a change in pull request #13181: URL: https://github.com/apache/flink/pull/13181#discussion_r478385445 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImpl.java ## @@ -87,9 +86,12 @@

[GitHub] [flink] azagrebin commented on a change in pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

azagrebin commented on a change in pull request #13181: URL: https://github.com/apache/flink/pull/13181#discussion_r478384390 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java ## @@ -98,14 +101,15 @@ public SchedulerImpl(

[jira] [Commented] (FLINK-17845) Can't remove a table connector property with ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-17845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185820#comment-17185820 ] Fabian Hueske commented on FLINK-17845: --- [~lzljs3620320] I think that's a goop proposal and would

[GitHub] [flink] XComp commented on a change in pull request #13260: [FLINK-16768][tests] Let the watchdog also monitor mvn logs

XComp commented on a change in pull request #13260: URL: https://github.com/apache/flink/pull/13260#discussion_r478375435 ## File path: tools/ci/watchdog.sh ## @@ -38,8 +38,26 @@ CMD_EXIT="/tmp/watchdog.exit" # Utility functions #

[GitHub] [flink] zhuxiaoshang commented on pull request #13240: [FLINK-19050][Documentation]Doc of MAX_DECIMAL_PRECISION should be DECIMAL

zhuxiaoshang commented on pull request #13240: URL: https://github.com/apache/flink/pull/13240#issuecomment-681912255 @JingsongLi @libenchao could plz have a review? This is an automated message from the Apache Git Service.

[jira] [Created] (FLINK-19063) Support join late event from dimension table side in temporal table join

Leonard Xu created FLINK-19063: -- Summary: Support join late event from dimension table side in temporal table join Key: FLINK-19063 URL: https://issues.apache.org/jira/browse/FLINK-19063 Project: Flink

[GitHub] [flink] XComp commented on a change in pull request #13260: [FLINK-16768][tests] Let the watchdog also monitor mvn logs

XComp commented on a change in pull request #13260: URL: https://github.com/apache/flink/pull/13260#discussion_r478365211 ## File path: tools/ci/test_controller.sh ## @@ -69,6 +69,10 @@ export JAVA_TOOL_OPTIONS="-XX:+HeapDumpOnOutOfMemoryError" # some tests provide additional

[GitHub] [flink] flinkbot edited a comment on pull request #13248: [FLINK-18222][e2e] Stabilize Avro Confluent Schema Registry nightly test

flinkbot edited a comment on pull request #13248: URL: https://github.com/apache/flink/pull/13248#issuecomment-680766918 ## CI report: * c67f4e27864b0af383d58248c2767e04342c9fbb Azure:

[jira] [Commented] (FLINK-19060) Checkpoint not triggered when use broadcast stream

[ https://issues.apache.org/jira/browse/FLINK-19060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185800#comment-17185800 ] henvealf commented on FLINK-19060: --  [~yunta] [~aljoscha] ,Hi,The output of the relevant log in

[GitHub] [flink] flinkbot edited a comment on pull request #13263: [FLINK-17273][runtime] ActiveResourceManager closes task manager connection on worker terminated.

flinkbot edited a comment on pull request #13263: URL: https://github.com/apache/flink/pull/13263#issuecomment-681892463 ## CI report: * 990aa0f33e2fa93d40ea011082fedc6eeb37be44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 4eae231a2cd3edbb2ba34f7bef983f64a4c4fefa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13248: [FLINK-18222][e2e] Stabilize Avro Confluent Schema Registry nightly test

flinkbot edited a comment on pull request #13248: URL: https://github.com/apache/flink/pull/13248#issuecomment-680766918 ## CI report: * c67f4e27864b0af383d58248c2767e04342c9fbb Azure:

[jira] [Comment Edited] (FLINK-18797) docs and examples use deprecated forms of keyBy

[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185788#comment-17185788 ] Dawid Wysakowicz edited comment on FLINK-18797 at 8/27/20, 11:42 AM: -

[jira] [Comment Edited] (FLINK-18797) docs and examples use deprecated forms of keyBy

[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185788#comment-17185788 ] Dawid Wysakowicz edited comment on FLINK-18797 at 8/27/20, 11:42 AM: -

[jira] [Updated] (FLINK-18797) docs and examples use deprecated forms of keyBy

[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18797: - Fix Version/s: 1.11.2 > docs and examples use deprecated forms of keyBy >

[jira] [Closed] (FLINK-18797) docs and examples use deprecated forms of keyBy

[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18797. Fix Version/s: 1.12.0 Resolution: Fixed Implemented in

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 11:35 AM: ---

<    1   2   3   >