[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=375030=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-375030 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 21/Jan/20 15:49 Start Date: 21/Jan/20 15:49 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-576744672 Thanks everyone! This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 375030) Time Spent: 7h 20m (was: 7h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 7h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=375028=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-375028 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 21/Jan/20 15:43 Start Date: 21/Jan/20 15:43 Worklog Time Spent: 10m Work Description: Ardagan commented on pull request #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 375028) Time Spent: 7h 10m (was: 7h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 7h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=374527=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-374527 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 20/Jan/20 12:00 Start Date: 20/Jan/20 12:00 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-576243800 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 374527) Time Spent: 7h (was: 6h 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 7h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=374511=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-374511 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 20/Jan/20 10:48 Start Date: 20/Jan/20 10:48 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-576217588 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 374511) Time Spent: 6h 50m (was: 6h 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 6h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=374498=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-374498
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 20/Jan/20 10:19
Start Date: 20/Jan/20 10:19
Worklog Time Spent: 10m
Work Description: kamilwu commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r368468572
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
Review comment:
https://issues.apache.org/jira/browse/BEAM-9154
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 374498)
Time Spent: 6h 40m (was: 6.5h)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 6h 40m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=372298=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-372298
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 15/Jan/20 12:36
Start Date: 15/Jan/20 12:36
Worklog Time Spent: 10m
Work Description: kamilwu commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r366852290
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
Review comment:
I ran the test in py3 (both SDK harness and the pipeline program) and there
are some errors connected with `dill` package. What do you think about leaving
it "as is" and creating a jira ticket to move chicago taxi to py3? We will have
to do the migration anyway in the nearest future.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 372298)
Time Spent: 6.5h (was: 6h 20m)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 6.5h
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=372049=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-372049 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 15/Jan/20 01:03 Start Date: 15/Jan/20 01:03 Worklog Time Spent: 10m Work Description: pabloem commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-574447464 feel free to merge afterwards @Ardagan @kkucharc This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 372049) Time Spent: 6h 20m (was: 6h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 6h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=371760=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-371760
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 14/Jan/20 18:23
Start Date: 14/Jan/20 18:23
Worklog Time Spent: 10m
Work Description: pabloem commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r366498321
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
Review comment:
though maybe then we'd have to run everything in py3 (meaning the target
`:portable:py2:chicagoTaxiExample`). LMK what you think.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 371760)
Time Spent: 6h 10m (was: 6h)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 6h 10m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=371759=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-371759
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 14/Jan/20 18:23
Start Date: 14/Jan/20 18:23
Worklog Time Spent: 10m
Work Description: pabloem commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r366497682
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
Review comment:
I wonder if we should be using a py3 container straight out
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 371759)
Time Spent: 6h 10m (was: 6h)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 6h 10m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=370696=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-370696
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 13/Jan/20 10:19
Start Date: 13/Jan/20 10:19
Worklog Time Spent: 10m
Work Description: kamilwu commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r365728040
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
+publisher.publish(':runners:flink:1.9:job-server-container:docker',
'flink1.9_job_server')
+String pythonHarnessImageTag = publisher.getFullImageName('python2.7_sdk')
+Flink flink = new Flink(scope, 'beam_PostCommit_Python_Chicago_Taxi_Flink')
+flink.setUp([pythonHarnessImageTag], numberOfWorkers,
publisher.getFullImageName('flink1.9_job_server'))
+
+def pipelineOptions = [
+parallelism : numberOfWorkers,
+job_endpoint: 'localhost:8099',
+environment_config : pythonHarnessImageTag,
+environment_type: 'DOCKER',
+execution_mode_for_batch: 'BATCH_FORCED',
+]
+
+scope.steps {
+gradle {
+rootBuildScriptDir(commonJobProperties.checkoutDir)
+tasks(':sdks:python:test-suites:portable:py2:chicagoTaxiExample')
+switches('-PgcsRoot=gs://temp-storage-for-perf-tests/chicago-taxi')
+
switches("-PpipelineOptions=\"${LoadTestsBuilder.parseOptions(pipelineOptions)}\"")
+}
+}
+}
+
+PostcommitJobBuilder.postCommitJob(
+'beam_PostCommit_Python_Chicago_Taxi_Flink',
+'Run Chicago Taxi on Flink',
+'Google Cloud Flink Runner Chicago Taxi Example',
+this
+) {
+chicagoTaxiJob(delegate)
+}
+
+CronJobBuilder.cronJob(
Review comment:
The cron job defined by PostcommitJobBuilder is executed every six hours,
which is too frequent for our needs. The extra one overrides it with more
desired setting (every 24 hours)
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 370696)
Time Spent: 6h (was: 5h 50m)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 6h
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[
https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=370025=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-370025
]
ASF GitHub Bot logged work on BEAM-8108:
Author: ASF GitHub Bot
Created on: 10/Jan/20 19:34
Start Date: 10/Jan/20 19:34
Worklog Time Spent: 10m
Work Description: Ardagan commented on pull request #10531: [BEAM-8108]
Add Chicago Taxi Example running on Flink
URL: https://github.com/apache/beam/pull/10531#discussion_r365397134
##
File path:
.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import CommonJobProperties as commonJobProperties
+import CronJobBuilder
+import Docker
+import Flink
+import LoadTestsBuilder
+import PostcommitJobBuilder
+
+def chicagoTaxiJob = { scope ->
+scope.description('Runs the Chicago Taxi Example on the Flink runner.')
+commonJobProperties.setTopLevelMainJobProperties(scope, 'master', 120)
+
+def numberOfWorkers = 5
+
+Docker publisher = new Docker(scope,
LoadTestsBuilder.DOCKER_CONTAINER_REGISTRY)
+publisher.publish(':sdks:python:container:py2:docker', 'python2.7_sdk')
+publisher.publish(':runners:flink:1.9:job-server-container:docker',
'flink1.9_job_server')
+String pythonHarnessImageTag = publisher.getFullImageName('python2.7_sdk')
+Flink flink = new Flink(scope, 'beam_PostCommit_Python_Chicago_Taxi_Flink')
+flink.setUp([pythonHarnessImageTag], numberOfWorkers,
publisher.getFullImageName('flink1.9_job_server'))
+
+def pipelineOptions = [
+parallelism : numberOfWorkers,
+job_endpoint: 'localhost:8099',
+environment_config : pythonHarnessImageTag,
+environment_type: 'DOCKER',
+execution_mode_for_batch: 'BATCH_FORCED',
+]
+
+scope.steps {
+gradle {
+rootBuildScriptDir(commonJobProperties.checkoutDir)
+tasks(':sdks:python:test-suites:portable:py2:chicagoTaxiExample')
+switches('-PgcsRoot=gs://temp-storage-for-perf-tests/chicago-taxi')
+
switches("-PpipelineOptions=\"${LoadTestsBuilder.parseOptions(pipelineOptions)}\"")
+}
+}
+}
+
+PostcommitJobBuilder.postCommitJob(
+'beam_PostCommit_Python_Chicago_Taxi_Flink',
+'Run Chicago Taxi on Flink',
+'Google Cloud Flink Runner Chicago Taxi Example',
+this
+) {
+chicagoTaxiJob(delegate)
+}
+
+CronJobBuilder.cronJob(
Review comment:
PostcommitJobBuilder already adds periodic cron job
https://github.com/apache/beam/blob/5a24fc90a58dc1b05f2faf1ea1874d1fd044071a/.test-infra/jenkins/PostcommitJobBuilder.groovy#L59
Any reason to add extra one?
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 370025)
Time Spent: 5h 50m (was: 5h 40m)
> Run Chicago Taxi Example on Flink
> -
>
> Key: BEAM-8108
> URL: https://issues.apache.org/jira/browse/BEAM-8108
> Project: Beam
> Issue Type: Test
> Components: testing
>Reporter: Kamil Wasilewski
>Assignee: Kamil Wasilewski
>Priority: Minor
> Time Spent: 5h 50m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369765=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369765 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 10/Jan/20 10:16 Start Date: 10/Jan/20 10:16 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572974602 R: @pabloem Can I ask you for a review? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369765) Time Spent: 5h 40m (was: 5.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 5h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369741=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369741 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 10/Jan/20 09:18 Start Date: 10/Jan/20 09:18 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572944458 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369741) Time Spent: 5h 20m (was: 5h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 5h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369742=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369742 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 10/Jan/20 09:18 Start Date: 10/Jan/20 09:18 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572944704 Run Chicago Taxi on Dataflow This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369742) Time Spent: 5.5h (was: 5h 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 5.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369724=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369724 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 10/Jan/20 08:47 Start Date: 10/Jan/20 08:47 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572933783 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369724) Time Spent: 5h 10m (was: 5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 5h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369723=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369723 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 10/Jan/20 08:44 Start Date: 10/Jan/20 08:44 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572932559 retest this please This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369723) Time Spent: 5h (was: 4h 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369111=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369111 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 15:35 Start Date: 09/Jan/20 15:35 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572615175 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369111) Time Spent: 4h 50m (was: 4h 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369110=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369110 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 15:34 Start Date: 09/Jan/20 15:34 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572615087 Run Chicago Taxi on Dataflow This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369110) Time Spent: 4h 40m (was: 4.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369094=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369094 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 15:15 Start Date: 09/Jan/20 15:15 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572606339 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369094) Time Spent: 4.5h (was: 4h 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369005=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369005 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 12:56 Start Date: 09/Jan/20 12:56 Worklog Time Spent: 10m Work Description: aromanenko-dev commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572549442 @kamilwu Please, let me know if you will need any other help. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369005) Time Spent: 4h 20m (was: 4h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=369002=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-369002 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 12:53 Start Date: 09/Jan/20 12:53 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572548314 Thanks for your help @aromanenko-dev! I'm investigating the failure This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 369002) Time Spent: 4h 10m (was: 4h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368998=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368998 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 12:38 Start Date: 09/Jan/20 12:38 Worklog Time Spent: 10m Work Description: aromanenko-dev commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572543530 Run Chicago Taxi on Dataflow This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 368998) Time Spent: 4h (was: 3h 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 4h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368981=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368981 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 12:25 Start Date: 09/Jan/20 12:25 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572539258 Run Chicago Taxi on Dataflow This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 368981) Time Spent: 3h 50m (was: 3h 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 3h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368941=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368941 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 09/Jan/20 10:57 Start Date: 09/Jan/20 10:57 Worklog Time Spent: 10m Work Description: aromanenko-dev commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572508959 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 368941) Time Spent: 3h 40m (was: 3.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 3h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368150=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368150 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 08/Jan/20 11:56 Start Date: 08/Jan/20 11:56 Worklog Time Spent: 10m Work Description: kkucharc commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572017000 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 368150) Time Spent: 3.5h (was: 3h 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 3.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368146=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368146 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 08/Jan/20 11:54 Start Date: 08/Jan/20 11:54 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531#issuecomment-572016600 @kkucharc Could you trigger some tests for me, please? First, I need a seed job to be run: `Run Seed Job` After that: `Run Chicago Taxi on Dataflow` `Run Chicago Taxi on Flink` Thanks! This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 368146) Time Spent: 3h 20m (was: 3h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 3h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=368139=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-368139 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 08/Jan/20 11:32 Start Date: 08/Jan/20 11:32 Worklog Time Spent: 10m Work Description: kamilwu commented on pull request #10531: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/10531 Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`). - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier). Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/) Python | [](https://builds.apache.org/job/beam_PostCommit_Python2/lastCompletedBuild/)[![Build
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=306172=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-306172 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 04/Sep/19 07:53 Start Date: 04/Sep/19 07:53 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-527787195 Closing this PR as it's currently not possible to read from BigQuery on runners other than Dataflow This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 306172) Time Spent: 2h 50m (was: 2h 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=306173=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-306173 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 04/Sep/19 07:53 Start Date: 04/Sep/19 07:53 Worklog Time Spent: 10m Work Description: kamilwu commented on pull request #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 306173) Time Spent: 3h (was: 2h 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 3h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304262=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304262 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 13:43 Start Date: 30/Aug/19 13:43 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526606539 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304262) Time Spent: 2h 40m (was: 2.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304249=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304249 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 13:18 Start Date: 30/Aug/19 13:18 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526598603 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304249) Time Spent: 2.5h (was: 2h 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304121=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304121 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 09:00 Start Date: 30/Aug/19 09:00 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526522706 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304121) Time Spent: 2h 20m (was: 2h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304117=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304117 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 08:49 Start Date: 30/Aug/19 08:49 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526518498 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304117) Time Spent: 2h 10m (was: 2h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304096=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304096 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 08:10 Start Date: 30/Aug/19 08:10 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526504969 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304096) Time Spent: 2h (was: 1h 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 2h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=304083=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-304083 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 30/Aug/19 07:56 Start Date: 30/Aug/19 07:56 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526500601 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 304083) Time Spent: 1h 50m (was: 1h 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303774=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303774 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 15:48 Start Date: 29/Aug/19 15:48 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526247150 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303774) Time Spent: 1h 40m (was: 1.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303753=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303753 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 15:06 Start Date: 29/Aug/19 15:06 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526228045 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303753) Time Spent: 1.5h (was: 1h 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303741=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303741 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 14:44 Start Date: 29/Aug/19 14:44 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Add Chicago Taxi Example running on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526218614 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303741) Time Spent: 1h 20m (was: 1h 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303711=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303711 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 13:40 Start Date: 29/Aug/19 13:40 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526189897 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303711) Time Spent: 1h 10m (was: 1h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303495=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303495 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 09:41 Start Date: 29/Aug/19 09:41 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526109750 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303495) Time Spent: 1h (was: 50m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 1h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303459=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303459 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 08:28 Start Date: 29/Aug/19 08:28 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526082164 Google Cloud Flink Runner Chicago Taxi Example This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303459) Time Spent: 50m (was: 40m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303458=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303458 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 08:28 Start Date: 29/Aug/19 08:28 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526082717 Run Chicago Taxi on Flink This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303458) Time Spent: 40m (was: 0.5h) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303455=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303455 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 08:26 Start Date: 29/Aug/19 08:26 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526082164 Google Cloud Flink Runner Chicago Taxi Example This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303455) Time Spent: 0.5h (was: 20m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 0.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Work logged] (BEAM-8108) Run Chicago Taxi Example on Flink
[ https://issues.apache.org/jira/browse/BEAM-8108?focusedWorklogId=303449=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-303449 ] ASF GitHub Bot logged work on BEAM-8108: Author: ASF GitHub Bot Created on: 29/Aug/19 08:06 Start Date: 29/Aug/19 08:06 Worklog Time Spent: 10m Work Description: kamilwu commented on issue #9448: [BEAM-8108] Run Chicago Taxi Example on Flink URL: https://github.com/apache/beam/pull/9448#issuecomment-526074915 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 303449) Time Spent: 20m (was: 10m) > Run Chicago Taxi Example on Flink > - > > Key: BEAM-8108 > URL: https://issues.apache.org/jira/browse/BEAM-8108 > Project: Beam > Issue Type: Test > Components: testing >Reporter: Kamil Wasilewski >Assignee: Kamil Wasilewski >Priority: Minor > Time Spent: 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.2#803003)
